I have the same problem. I am running Zeppelin version 0.6.0 and Drill 1.5.
When I attempt a Drill query from Zeppelin I receive a "Connection refused"
error. The query works successfully in Drill. My Interpreter configurations:
default.url: jdbc:drill:zk=myServerName:8121/drill/drillbits1
default.user:
default.password:
Dependency: org.apache.drill.exec:drill-jdbc:1.5.0
The query I run is very simple, but the Zeppelin paragraph runs for a few
seconds and then returns the connection refused error. I pasted the full error
below.
Any recommendations?
Thanks!
Kevin
Zeppelin Paragraph:
%drill
SELECT * FROM asdf LIMIT 100
Zeppelin Error:
java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at org.apache.thrift.transport.TSocket.open(TSocket.java:182)
at
org.apache.zeppelin.interpreter.remote.ClientFactory.create(ClientFactory.java:51)
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:96)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreter.init(RemoteInterpreter.java:216)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getFormType(RemoteInterpreter.java:383)
at
org.apache.zeppelin.interpreter.LazyOpenInterpreter.getFormType(LazyOpenInterpreter.java:105)
at
org.apache.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:263)
at org.apache.zeppelin.scheduler.Job.run(Job.java:176)
at
org.apache.zeppelin.scheduler.RemoteScheduler$JobRunner.run(RemoteScheduler.java:329)
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)
From: Jongyoul Lee [mailto:[email protected]]
Sent: Tuesday, July 12, 2016 10:53 PM
To: [email protected]
Subject: Re: Drill JDBC Interpreter: Connection Refused
Hello,
It seem not to launch remote Interpreter properly. Which version are you using?
I've found the error file and couldn't find the version which you are using
JL
On Wed, Jul 13, 2016 at 2:32 PM, Krishnaprasad A S
<[email protected]<mailto:[email protected]>> wrote:
I tried with,
%jdbc(drill)
%drill
%drill(jdbc)
Currently I made the drill interpretor as the default one and ran the sql
without using a %drill,
select count(*) from `dfs`.`POC/Sample10000.csv`
Please find attached error log.
On Wed, Jul 13, 2016 at 5:26 AM, Jongyoul Lee
<[email protected]<mailto:[email protected]>> wrote:
Hello,
It looks like a kind of initialization error. Could you tell me your script
starting from %....? And interpreter logs which is located under logs/ will
help solve this error.
Hope this help,
JL
On Wednesday, 13 July 2016, Krishnaprasad A S
<[email protected]<mailto:[email protected]>> wrote:
hi,
I'm trying to create a drill interpreter in zeppelin.
drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1
drill.driver = org.apache.drill.jdbc.Driver
my drillbit runs on the same server as of zeppelin.
Added the dependency 'apache-drill-1.7.0/jars/drill-jdbc-all-1.7.0.jar' in
zeppelin ui.
I'm the getting the following error while running a sample SQL from zeppelin,
ERROR [2016-07-12 01:11:41,946] ({pool-1-thread-4}
NotebookServer.java[afterStatusChange]:1135) - Error
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.init(RemoteInterpreter.java:165)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getFormType(RemoteInterpreter.java:328)
at
org.apache.zeppelin.interpreter.LazyOpenInterpreter.getFormType(LazyOpenInterpreter.java:105)
at org.apache.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:260)
at org.apache.zeppelin.scheduler.Job.run(Job.java:176)
at
org.apache.zeppelin.scheduler.RemoteScheduler$JobRunner.run(RemoteScheduler.java:328)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
at java.util.concurrent.FutureTask.run(FutureTask.java:166)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:722)
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:184)
at
org.apache.zeppelin.interpreter.remote.RemoteInterpreter.init(RemoteInterpreter.java:163)
... 13 more
Caused by: org.apache.thrift.transport.TTransportException:
java.net.ConnectException: Connection refused
at org.apache.thrift.transport.TSocket.open(TSocket.java:187)
at
org.apache.zeppelin.interpreter.remote.ClientFactory.create(ClientFactory.java:51)
... 20 more
Caused by: java.net.ConnectException: Connection refused
reference used https://community.mapr.com/docs/DOC-1493
--
이종열, Jongyoul Lee, 李宗烈
http://madeng.net
--
Krishnaprasad A S
Lead Engineer
Flytxt
Skype: krishnaprasadas
M: +91 8907209454<tel:%2B91%208907209454> | O: +91
471.3082753<tel:%2B91%20471.3082753> | F: +91
471.2700202<tel:%2B91%20471.2700202>
www.flytxt.com<http://www.flytxt.com/> | Visit our
blog<http://blog.flytxt.com/> | Follow us<http://www.twitter.com/flytxt> |
Connect on
LinkedIn<http://www.linkedin.com/company/22166?goback=%2Efcs_GLHD_flytxt_false_*2_*2_*2_*2_*2_*2_*2_*2_*2_*2_*2_*2&trk=ncsrch_hits>
--
이종열, Jongyoul Lee, 李宗烈
http://madeng.net
