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 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:
"[email protected]<mailto:[email protected]>"
Date: Sunday, May 8, 2016 at 3:51 AM
To:
"[email protected]<mailto:[email protected]>"
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
<[email protected]<mailto:[email protected]>> 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:
"[email protected]<mailto:[email protected]>"
Date: Friday, May 6, 2016 at 7:32 AM
To:
"[email protected]<mailto:[email protected]>"
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
<[email protected]<mailto:[email protected]>> 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
