我正在齐柏林飞艇上安装CassandraInterpreter。正如文件中所说的那样,我做到了:
bin/install-interpreter.sh --name cassandra这使得卡桑德拉文件夹与所有的依赖。我现在有点担心。我使用的是开源卡桑德拉3.10.和齐柏林飞艇版本0.7.0.正如我所看到的,齐柏林飞艇正在下载datastax的卡桑德拉派生器,我不使用Datastaxs。
此外,我还添加了Cassandra作为整数,并编写了我的第一个脚本:
%cassandra
HELP;一些丑恶的事情发生了:
INFO [2017-06-01 12:50:42,695] ({pool-2-thread-2} SchedulerFactory.java[jobFinished]:137) - Job remoteInterpretJob_1496314241621 finished by scheduler org.apache.zeppelin.cassandra.CassandraInterpreter116220$
INFO [2017-06-01 12:54:01,128] ({pool-1-thread-2} InterpreterGroup.java[close]:156) - Close interpreter group 2CJDRW3SU:shared_process
INFO [2017-06-01 12:59:10,327] ({Thread-0} RemoteInterpreterServer.java[run]:95) - Starting remote interpreter server on port 39611
INFO [2017-06-01 12:59:10,836] ({pool-1-thread-2} RemoteInterpreterServer.java[createInterpreter]:190) - Instantiate interpreter org.apache.zeppelin.cassandra.CassandraInterpreter
INFO [2017-06-01 12:59:10,930] ({pool-2-thread-2} SchedulerFactory.java[jobStarted]:131) - Job remoteInterpretJob_1496314750927 started by scheduler org.apache.zeppelin.cassandra.CassandraInterpreter15405091$
INFO [2017-06-01 12:59:10,936] ({pool-2-thread-2} CassandraInterpreter.java[open]:164) - Bootstrapping Cassandra Java Driver to connect to 10.60.213.61,on port 9042
INFO [2017-06-01 12:59:11,281] ({pool-2-thread-2} NettyUtil.java[<clinit>]:83) - Did not find Netty's native epoll transport in the classpath, defaulting to NIO.
INFO [2017-06-01 12:59:11,880] ({pool-2-thread-2} DCAwareRoundRobinPolicy.java[init]:95) - Using data-center name 'datacenter1' for DCAwareRoundRobinPolicy (if this is incorrect, please provide the correct d$
INFO [2017-06-01 12:59:11,882] ({pool-2-thread-2} Cluster.java[init]:1485) - New Cassandra host /xx.xx.xxx.xx:9042 added
INFO [2017-06-01 12:59:11,883] ({pool-2-thread-2} Cluster.java[init]:1485) - New Cassandra host /xx.xx.xxx.xx:9042 added
INFO [2017-06-01 12:59:11,883] ({pool-2-thread-2} Cluster.java[init]:1485) - New Cassandra host /xx.xx.xxx.xx:9042 added
INFO [2017-06-01 12:59:11,883] ({pool-2-thread-2} Cluster.java[init]:1485) - New Cassandra host /xx.xx.xxx.xx:9042 added
INFO [2017-06-01 12:59:11,883] ({pool-2-thread-2} Cluster.java[init]:1485) - New Cassandra host /xx.xx.xxx.xx:9042 added
INFO [2017-06-01 12:59:11,884] ({pool-2-thread-2} Cluster.java[init]:1485) - New Cassandra host /xx.xx.xxx.xx:9042 added
ERROR [2017-06-01 12:59:11,991] ({pool-2-thread-2} Job.java[run]:188) - Job failed
java.lang.NoSuchMethodError: scala.Predef$.ArrowAssoc(Ljava/lang/Object;)Ljava/lang/Object;
at org.fusesource.scalate.TemplateEngine.<init>(TemplateEngine.scala:170)
at org.apache.zeppelin.cassandra.DisplaySystem$.<init>(DisplaySystem.scala:37)
at org.apache.zeppelin.cassandra.DisplaySystem$.<clinit>(DisplaySystem.scala)
at org.apache.zeppelin.cassandra.DisplaySystem$NoResultDisplay$.<init>(DisplaySystem.scala:369)
at org.apache.zeppelin.cassandra.DisplaySystem$NoResultDisplay$.<clinit>(DisplaySystem.scala)
at org.apache.zeppelin.cassandra.EnhancedSession.<init>(EnhancedSession.scala:40)
at org.apache.zeppelin.cassandra.InterpreterLogic.<init>(InterpreterLogic.scala:98)
at org.apache.zeppelin.cassandra.CassandraInterpreter.open(CassandraInterpreter.java:189)
at org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:69)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:482)
at org.apache.zeppelin.scheduler.Job.run(Job.java:175)
at org.apache.zeppelin.scheduler.ParallelScheduler$JobRunner.run(ParallelScheduler.java:162)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)正如我所看到的,Scala版本中的问题--默认情况下--我指的是2.10.5,齐柏林飞艇也在下载。我试着用2.12.0交换整个scala,我得到了关于显示的错误.也是scala错误。有什么想法吗?
我怀疑Cassandra驱动程序的不匹配,因为我有开源的Cassandra,而且驱动程序是用于Datastax的,而且我也找不到开源的。
发布于 2018-05-02 11:31:19
因此,为了安装cassandra驱动程序,您需要更改一些位解释器罐子。为此,在您通过齐柏林飞艇( zeppelin )解释器安装cassandra之后,您需要进入您的
ZEPPELIN_HOME/zeppelin-server/interpreter/cassandra
之后,您需要这个libs ->
cassandra-driver-core-3.0.1.jar netty-common-4.0.33.Final.jar
scalate-core_2.11-1.7.1.jar commons-lang3-3.3.2.jar
netty-handler-4.0.33.Final.jar scalate-util_2.11-1.7.1.jar
guava-16.0.1.jar
netty-transport-4.0.33.Final.jar
scala-xml_2.11-1.0.1.jar
lz4-1.3.0.jar
scala-compiler-2.11.2.jar
slf4j-api-1.7.10.jar
metrics-core-3.1.2.jar
scala-library-2.11.2.jar
snappy-java-1.0.5.4.jar
netty-buffer-4.0.33.Final.jar
scala-parser-combinators_2.11-1.0.1.jar
zeppelin-cassandra_2.11-0.7.2.jar
netty-codec-4.0.33.Final.jar
scala-reflect-2.11.2.jar在进行此更改后,只需重新启动解释器即可。
https://stackoverflow.com/questions/44305932
复制相似问题