Below is my cassandra interpreter folder. Let me know if something is missing. I added the cassandra-driver-core-3.0.0-rc1.jar manually.
kyle.burke@vsand-dsmodeling-002:~/zeppelin/zeppelin-0.5.6-incubating-bin-all$ ls interpreter/cassandra/ cassandra-driver-core-2.1.7.1.jar.old netty-buffer-4.0.27.Final.jar scala-library-2.11.7.jar slf4j-api-1.7.10.jar cassandra-driver-core-3.0.0-rc1.jar netty-codec-4.0.27.Final.jar scala-parser-combinators_2.11-1.0.4.jar snappy-java-1.0.5.4.jar commons-lang3-3.4.jar netty-common-4.0.27.Final.jar scala-reflect-2.11.7.jar zeppelin-cassandra-0.5.6-incubating.jar guava-18.0.jar netty-handler-4.0.27.Final.jar scalate-core_2.11-1.7.1.jar lz4-1.2.0.jar netty-transport-4.0.27.Final.jar scalate-util_2.11-1.7.1.jar metrics-core-3.0.2.jar scala-compiler-2.11.7.jar scala-xml_2.11-1.0.4.jar Respectfully, Kyle Burke | Data Science Engineer IgnitionOne - Marketing Technology. Simplified. Office: 1545 Peachtree St NE, Suite 500 | Atlanta, GA | 30309 Direct: 404.961.3918 From: DuyHai Doan Reply-To: "users@zeppelin.incubator.apache.org<mailto:users@zeppelin.incubator.apache.org>" Date: Monday, May 9, 2016 at 4:21 PM To: "users@zeppelin.incubator.apache.org<mailto:users@zeppelin.incubator.apache.org>" Subject: Re: cassandra interpreter You can build the latest version from master but it should also work with release version 0.5.6, just verify the jar files in interpreter/cassandra folder On Mon, May 9, 2016 at 8:56 PM, Kyle Burke <kyle.bu...@ignitionone.com<mailto:kyle.bu...@ignitionone.com>> wrote: DuyHai, It looks like you’re using 0.6.0 version and I’m using 0.5.6. Sounds like I need to build the latest version. Respectfully, Kyle Burke | Data Science Engineer IgnitionOne - Marketing Technology. Simplified. Office: 1545 Peachtree St NE, Suite 500 | Atlanta, GA | 30309 Direct: 404.961.3918<tel:404.961.3918> From: DuyHai Doan Reply-To: "users@zeppelin.incubator.apache.org<mailto:users@zeppelin.incubator.apache.org>" Date: Monday, May 9, 2016 at 2:13 PM To: "users@zeppelin.incubator.apache.org<mailto:users@zeppelin.incubator.apache.org>" Subject: Re: cassandra interpreter 1. You don't have to add the driver jar to interpreter/cassandra folder, it should be there already. Here is my interpreter/cassandra folder content: cassandra-driver-core-3.0.0-rc1.jar commons-lang3-3.3.2.jar guava-16.0.1.jar lz4-1.3.0.jar metrics-core-3.1.2.jar netty-buffer-4.0.33.Final.jar netty-codec-4.0.33.Final.jar netty-common-4.0.33.Final.jar netty-handler-4.0.33.Final.jar netty-transport-4.0.33.Final.jar scala-compiler-2.10.4.jar scala-library-2.10.4.jar scala-reflect-2.10.4.jar scalate-core_2.10-1.7.1.jar scalate-util_2.10-1.7.1.jar slf4j-api-1.7.10.jar snappy-java-1.0.5.4.jar zeppelin-cassandra-0.6.0-incubating-SNAPSHOT.jar What is the content of your interpreter/cassandra folder ? 2. You don't have to add the property "cassandra.driver.version". What is the value of the property "cassandra.protocol.version" for Cassandra interpreter ? The exception stack trace seems to show that you don't have the correct Java driver jar On Mon, May 9, 2016 at 6:04 PM, Kyle Burke <kyle.bu...@ignitionone.com<mailto:kyle.bu...@ignitionone.com>> wrote: Hey DuyHai, I’m still not able to use the cassandra interpreter. I’ve perform that following setup tasks. I’m not sure if I missing something. Any suggestions on how to correct? 1. I added the 3.0.0-rc1 cassandra driver to the interpreter/cassandra folder. 2. On the interpreter page I’ve updated the cassandra interpreter properties with a cassandra.driver.version name property and a value of 3.0.0-rc1. 3. I restarted the zepellin daemon. When I do a simple “DESCRIBE KEYSPACES;” I get an error. Below is the stack from the cassandra interpreter log. DESCRIBE KEYSPACES; ERROR [2016-05-09 13:53:36,598] ({pool-2-thread-2} Job.java[run]:182) - Job failed java.lang.NoSuchMethodError: com.datastax.driver.core.ProtocolOptions.getProtocolVersionEnum()Lcom/datastax/driver/core/ProtocolVersion; at org.apache.zeppelin.cassandra.InterpreterLogic.interpret(InterpreterLogic.scala:103) at org.apache.zeppelin.cassandra.CassandraInterpreter.interpret(CassandraInterpreter.java:304) at org.apache.zeppelin.interpreter.ClassloaderInterpreter.interpret(ClassloaderInterpreter.java:57) at org.apache.zeppelin.interpreter.LazyOpenInterpreter.interpret(LazyOpenInterpreter.java:93) at org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:300) at org.apache.zeppelin.scheduler.Job.run(Job.java:169) at org.apache.zeppelin.scheduler.ParallelScheduler$JobRunner.run(ParallelScheduler.java:157) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) INFO [2016-05-09 13:53:36,604] ({pool-2-thread-2} SchedulerFactory.java[jobFinished]:135) - Job remoteInterpretJob_1462802013711 finished by scheduler org.apache.zeppelin.cassandra.CassandraInterpreter148$ INFO [2016-05-09 13:56:55,582] ({Thread-0} RemoteInterpreterServer.java[run]:97) - Starting remote interpreter server on port 54741 INFO [2016-05-09 13:56:55,925] ({pool-1-thread-2} CassandraInterpreter.java[<clinit>]:154) - Bootstrapping Cassandra Interpreter INFO [2016-05-09 13:56:55,927] ({pool-1-thread-2} RemoteInterpreterServer.java[createInterpreter]:168) - Instantiate interpreter org.apache.zeppelin.cassandra.CassandraInterpreter INFO [2016-05-09 13:56:55,977] ({pool-2-thread-2} SchedulerFactory.java[jobStarted]:129) - Job remoteInterpretJob_1462802215975 started by scheduler org.apache.zeppelin.cassandra.CassandraInterpreter12904$ INFO [2016-05-09 13:56:55,978] ({pool-2-thread-2} CassandraInterpreter.java[open]:268) - Bootstrapping Cassandra Java Driver to connect to 10.205.33.12,10.205.43.59,on port 9042 INFO [2016-05-09 13:56:56,194] ({pool-2-thread-2} NettyUtil.java[<clinit>]:83) - Did not find Netty's native epoll transport in the classpath, defaulting to NIO. INFO [2016-05-09 13:56:56,600] ({pool-2-thread-2} DCAwareRoundRobinPolicy.java[init]:95) - Using data-center name 'us-east' for DCAwareRoundRobinPolicy (if this is incorrect, please provide the correct da$ INFO [2016-05-09 13:56:56,601] ({pool-2-thread-2} Cluster.java[init]:1443) - New Cassandra host /X.X.X.X:9042 added INFO [2016-05-09 13:56:56,601] ({pool-2-thread-2} Cluster.java[init]:1443) - New Cassandra host /X.X.X.X:9042 added INFO [2016-05-09 13:56:56,601] ({pool-2-thread-2} Cluster.java[init]:1443) - New Cassandra host /127.0.0.1:9042<http://127.0.0.1:9042> added INFO [2016-05-09 13:56:56,601] ({pool-2-thread-2} Cluster.java[init]:1443) - New Cassandra host /X.X.X.X:9042 added Respectfully, Kyle Burke | Data Science Engineer IgnitionOne - Marketing Technology. Simplified. Office: 1545 Peachtree St NE, Suite 500 | Atlanta, GA | 30309 From: DuyHai Doan Reply-To: "users@zeppelin.incubator.apache.org<mailto:users@zeppelin.incubator.apache.org>" Date: Sunday, May 8, 2016 at 3:51 AM To: "users@zeppelin.incubator.apache.org<mailto:users@zeppelin.incubator.apache.org>" Subject: Re: cassandra interpreter The Cassandra interpreter supports all Cassandra 3.x branch, it is using the driver version <cassandra.driver.version>3.0.0-rc1</cassandra.driver.version> I will update the interpreter soon to upgrade driver version to 3.0.0 On Sun, May 8, 2016 at 5:38 AM, Kyle Burke <kyle.bu...@ignitionone.com<mailto:kyle.bu...@ignitionone.com>> wrote: Hi DuyHai, Does the Cassandra interpreter support Cassandra 3.5? The system table error I’m getting leads me to believe it’s not. Respectfully, Kyle Burke | Data Science Engineer IgnitionOne - Marketing Technology. Simplified. Office: 1545 Peachtree St NE, Suite 500 | Atlanta, GA | 30309 From: DuyHai Doan Reply-To: "users@zeppelin.incubator.apache.org<mailto:users@zeppelin.incubator.apache.org>" Date: Friday, May 6, 2016 at 7:32 AM To: "users@zeppelin.incubator.apache.org<mailto:users@zeppelin.incubator.apache.org>" Subject: Re: cassandra interpreter Hello No you're mistaking, the Cassandra interpreter is only using the binary protocol to communicate with Cassandra (port 9042 by default). In the logs, what you see is the Thrift protocol used by Zeppelin to communicate between the Zeppelin server and the interpreter JVM process. By the way can you please copy/paste the complete stack trace so we can track down the root cause ? On Fri, May 6, 2016 at 12:50 AM, Kyle Burke <kyle.bu...@ignitionone.com<mailto:kyle.bu...@ignitionone.com>> wrote: All, I’m having connection issues trying to get zeppelin to connect to our Cassandra cluster. Below is the error I’m getting. I’m assuming from the error that Zeppelin uses the thrift api to connect to Cassandra. My thrift port 9160 is open (based on netstat) so I can't seem to figure out why the connection is refused. Any suggestions on what to test or changes required in the cassandra config files to successfully connect would be appreciated. ERROR [2016-05-05 22:29:16,939] ({pool-1-thread-2} Job.java[run]:182) - Job failed org.apache.zeppelin.interpreter.InterpreterException: org.apache.zeppelin.interpreter.InterpreterException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.interpret(RemoteInterpreter.java:190) at org.apache.zeppelin.interpreter.LazyOpenInterpreter.interpret(LazyOpenInterpreter.java:93) at org.apache.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:211) at org.apache.zeppelin.scheduler.Job.run(Job.java:169) at org.apache.zeppelin.scheduler.RemoteScheduler$JobRunner.run(RemoteScheduler.java:322) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: org.apache.zeppelin.interpreter.InterpreterException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused at org.apache.zeppelin.interpreter.remote.ClientFactory.create(ClientFactory.java:53) at org.apache.zeppelin.interpreter.remote.ClientFactory.create(ClientFactory.java:37) at org.apache.commons.pool2.BasePooledObjectFactory.makeObject(BasePooledObjectFactory.java:60) at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:861) at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:435) at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:363) at org.apache.zeppelin.interpreter.remote.RemoteInterpreterProcess.getClient(RemoteInterpreterProcess.java:139) at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.interpret(RemoteInterpreter.java:188) ... 11 more Respectfully, Kyle Burke | Data Science Engineer IgnitionOne - Marketing Technology. Simplified. Office: 1545 Peachtree St NE, Suite 500 | Atlanta, GA | 30309
