Ошибка DataStax с созданием Job Tracker

Question

Я загрузил DataStax Enterprise, и я пытался запустить следующий пример Portfolio (www.datastax.com/docs/datastax_enterprise2.2/solutions/dse_demo#dse-demo), но я застрял. Проблема, с которой я сталкиваюсь, заключается в том, что я не могу запустить диспетчер заданий на узле.

Я использую версию 3.0.1 dse на Ubuntu. Я также создал его с одним узлом, так как я просто использую одну машину. Я уже запустил узел и запускаю как opscenterd, так и opscenter-agent.

Когда я бегу:

dse cassandra -t -j

Я получаю следующий вывод:

xss = -ea -javaagent:/usr/share/dse/cassandra/lib/jamm-0.2.5.jar -XX:+UseThreadPriorities -XX:ThreadPriorityPolicy=42 -Xms1024M -Xmx1024M -Xmn200M -XX:+HeapDumpOnOutOfMemoryError -Xss180k

Error: Exception thrown by the agent : java.rmi.server.ExportException: Port already in use: 7199; nested exception is: java.net.BindException: Address already in use

Когда попробовать и использовать dsetool вместо:

dsetool movejt localhost

Я вижу, в журнале/Cassandra/system.log, если сбой:

Caused by: InvalidRequestException(why:Keyspace dse_system does not exist)

at org.apache.cassandra.thrift.ThriftValidation.validateTable(ThriftValidation.java:83) 
at org.apache.cassandra.thrift.ThriftValidation.validateColumnFamily(ThriftValidation.java:135) 
at org.apache.cassandra.cql3.statements.SelectStatement$RawStatement.prepare(SelectStatement.java:973) 
at org.apache.cassandra.cql3.QueryProcessor.getStatement(QueryProcessor.java:243) 
at org.apache.cassandra.cql3.QueryProcessor.processInternal(QueryProcessor.java:129) 
at com.datastax.bdp.hadoop.mapred.TrackerManager.queryForJobTrackers(TrackerManager.java:202) 
at com.datastax.bdp.hadoop.mapred.TrackerManager.getJTNodes(TrackerManager.java:170) 

Что может быть причиной этого? И как это можно исправить?

Answer 1

Я предполагаю, что вы начали DSE как простой узел C *. Чтобы проверить пробег: nodetool ring и dsetool ring, и вы увидите нагрузку Cassandra для вашего узла

Поэтому я считаю, что это происходит потому, что: 1) у вас есть порт по ошибке использования указывая на то, ас * служба уже началась 2) dse_system создается только при запуске в качестве узла hadoop, -t

Чтобы обойти это, уничтожьте все процессы java и попробуйте перезапустить его с помощью опции -t. Он должен обнаружить, что вы не создали dse_system, а затем создали ее. Затем проверьте с помощью dsetool ring.

Answer 2

Выше работал для меня. Ошибки были выброшенные:

$ dse pig 
Error when fetching jobtracker address: 
Exception in thread "main" java.lang.NoClassDefFoundError: Could 
$ dsetool jobtracker 
Error when fetching jobtracker address: 
java.io.IOException: Could not find Job Tracker. 

Для решения я сделал следующее:

$ dse cassandra-stop 
$ dse cassandra -t