You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@drill.apache.org by Krishnaprasad A S <kr...@flytxt.com> on 2016/07/11 19:55:58 UTC
Drill JDBC Interpreter: Connection Refused
hi,
I'm trying to create a drill interpreter in zeppelin using the existing
jdbc interpreter.
*drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
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
Re: Drill JDBC Interpreter: Connection Refused
Posted by Andries Engelbrecht <ae...@maprtech.com>.
Perhaps try to create a separate interpreter.
Create a new interpreter and call it Drill or another name than just jdbc.
Below an example I did for a MapR cluster - adjust as needed
Also make sure all hostnames can be properly resolved in the network!! (seen way too many issues due to this)
Perhaps add a user and password even if security is not configured.
Name : Drill
Interpreter : jdbc
zeppelin.interpreter.localRepo <your local repo>
common.max_count 1000
drill.user drill
drill.password password
drill.driver org.apache.drill.jdbc.Driver
drill.url jdbc:drill:zk=<hostname>:5181/drill/cluster-drillbits
Dependencies
Artifacts
/opt//mapr/drill/drill-1.6.0/jars/jdbc-driver/drill-jdbc-all-1.6.0.jar
--Andries
> On Jul 12, 2016, at 10:48 AM, Krishnaprasad A S <kr...@flytxt.com> wrote:
>
> I have restarted zeppelin each time. Also zeppelin runs on a drillbit node.
>
> Please find below properties for jdbc interpreter,
>
> name value
> common.max_count 1000d
> default.driver org.postgresql.Driver
> default.password
> default.url jdbc:postgresql://localhost:5432/
> default.user gpadmin
> drill.driver org.apache.drill.jdbc.Driver
> drill.password
> drill.url jdbc:drill:schema=dfs;drillbit=dk-slv8
> hive.driver org.apache.hive.jdbc.HiveDriver
> hive.password
> hive.url jdbc:hive2://localhost:10000
> hive.user hive
> phoenix.driver org.apache.phoenix.jdbc.PhoenixDriver
> phoenix.password
> phoenix.url jdbc:phoenix:localhost:2181:/hbase-unsecure
> phoenix.user phoenixuser
> psql.driver org.postgresql.Driver
> psql.password
> psql.url jdbc:postgresql://localhost:5432/
> psql.user phoenixuser
> tajo.driver org.apache.tajo.jdbc.TajoDriver
> tajo.url jdbc:tajo://localhost:26002/default
> zeppelin.interpreter.localRepo
> /data/installables/zeppelin-0.6.0-bin-all/local-repo/2BQT8WFCV
>
> zeppelin.jdbc.concurrent.max_connection 10
> zeppelin.jdbc.concurrent.use true
> Dependencies
> artifact exclude
> /data/installables/apache-drill-1.7.0/jars/drill-jdbc-1.7.0.jar
>
>
>
>
> Thanks,
> Krishnaprasad
>
>
> On Tue, Jul 12, 2016 at 8:06 PM, Andries Engelbrecht <
> aengelbrecht@maprtech.com> wrote:
>
>> Perhaps share the Zeppelin interpreter config line by line so we can see.
>> Properties and Dependencies.
>>
>> Also did you restart the interpreter after you made the config changes?
>>
>> I assume you are running Zeppelin on one of the Drill nodes, where is ZK
>> located?
>>
>> --Andries
>>
>>
>>> On Jul 12, 2016, at 5:31 AM, Krishnaprasad A S <
>> krishna.prasad@flytxt.com> wrote:
>>>
>>> My zookeeper runs on port 2181, thats why I used the same port.
>>> I think drill won't start zookeeper by its own.
>>> I also tried using url "jdbc:drill:schema=dfs.tmp;drillbit=<IPADDRESS>"
>>> same error. Is there something I'm missing,
>>>
>>>
>>> On Tue, Jul 12, 2016 at 1:11 PM, Khurram Faraaz <kf...@maprtech.com>
>>> wrote:
>>>
>>>> Also try using port number 5181 in your drill-override.conf, instead of
>>>> 2181, and then stop and start Drillbit and re-run your program.
>>>>
>>>> On Tue, Jul 12, 2016 at 1:08 PM, Khurram Faraaz <kf...@maprtech.com>
>>>> wrote:
>>>>
>>>>> This one works just fine for me
>>>>>
>>>>> final String URL_STRING =
>>>> "jdbc:drill:schema=dfs.tmp;drillbit=<IPADDRESS>";
>>>>>
>>>>> replace IPADDRESS with your IP address in the above line.
>>>>>
>>>>> On Tue, Jul 12, 2016 at 12:08 PM, Krishnaprasad A S <
>>>>> krishna.prasad@flytxt.com> wrote:
>>>>>
>>>>>> Yes, I tried with url *jdbc:drill:drillbit=<IP>:31010* but same error,
>>>>>> Error in zeppelin console,
>>>>>> java.net.ConnectException: Connection refused at
>>>>>> java.net.PlainSocketImpl.socketConnect(Native Method) at
>>>>>>
>>>>>>
>>>>
>> java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
>>>>>> at
>>>>>>
>>>>>>
>>>>
>> java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
>>>>>> ....
>>>>>>
>>>>>> *drill-override.conf *
>>>>>> drill.exec: {
>>>>>> cluster-id: "drillbits1",
>>>>>> zk.connect: "dk-slv8:2181"
>>>>>> }
>>>>>>
>>>>>> Some more details,
>>>>>> I'm querying from hdfs (select count(*) from
>>>> `dfs`.`/POC/Sample10000.csv`)
>>>>>> the same query works with Drill Web UI.
>>>>>> Also the errors are logged in 'zeppelin-hadoop-dk-slv8.log' and not
>> in
>>>>>> 'zeppelin-interpreter-jdbc-hadoop-dk-slv8.log'
>>>>>>
>>>>>> I think there is something I'm missing because I tried removing the
>>>>>> drill.url and kept it blank again the same error is coming.
>>>>>> But there is no host or port mentioned for the ConnectException:
>>>>>> Connection
>>>>>> refused.
>>>>>>
>>>>>>
>>>>>>
>>>>>> On Tue, Jul 12, 2016 at 3:31 AM, Andries Engelbrecht <
>>>>>> aengelbrecht@maprtech.com> wrote:
>>>>>>
>>>>>>> Have you tried to connect to a drillbit directly from Zeppelin using
>>>> the
>>>>>>> jdbc url jdbc:drill:drillbit=<hostname>:31010?
>>>>>>>
>>>>>>> What does your drill-override.conf file look like?
>>>>>>>
>>>>>>>
>>>>>>>> On Jul 11, 2016, at 2:33 PM, Krishnaprasad A S <
>>>>>>> krishna.prasad@flytxt.com> wrote:
>>>>>>>>
>>>>>>>> I can see all the 4 drillbits in ui. Aso I tried the query in web ui
>>>>>>> before
>>>>>>>> running it in zeppelin. In web ui it works currently. Then what may
>>>> be
>>>>>>> the
>>>>>>>> issue.?
>>>>>>>> On Jul 12, 2016 3:00 AM, "Andries Engelbrecht" <
>>>>>>> aengelbrecht@maprtech.com>
>>>>>>>> wrote:
>>>>>>>>
>>>>>>>> What happens if you try to connect to a drillbit directly?
>>>>>>>>
>>>>>>>> This will help to see if it is a zk connection issue.
>>>>>>>>
>>>>>>>> Also I assume the dill cluster is up and running, and if you go to
>>>> the
>>>>>>>> webUI it shows all drillbits in the cluster connected and running.
>>>>>>>>
>>>>>>>>
>>>>>>>>> On Jul 11, 2016, at 2:27 PM, Krishnaprasad A S <
>>>>>>> krishna.prasad@flytxt.com>
>>>>>>>> wrote:
>>>>>>>>>
>>>>>>>>> I went through the same link before configuring the interpreter,
>>>> also
>>>>>>>> there
>>>>>>>>> is no security configured.
>>>>>>>>> On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <
>>>>>>> aengelbrecht@maprtech.com>
>>>>>>>>> wrote:
>>>>>>>>>
>>>>>>>>>> Do you have security configured on the Drill cluster? If so make
>>>>>> sure
>>>>>>> to
>>>>>>>>>> add the user and password info for the Drill connection.
>>>>>>>>>>
>>>>>>>>>> Some good info for configuring Zeppelin with Drill here
>>>>>>>>>>
>>>>>>>>>> https://community.mapr.com/docs/DOC-1493 <
>>>>>>>>>> https://community.mapr.com/docs/DOC-1493>
>>>>>>>>>>
>>>>>>>>>> --Andries
>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>>>> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
>>>>>>>>>> krishna.prasad@flytxt.com> wrote:
>>>>>>>>>>>
>>>>>>>>>>> My drill runs in clustered mode, with 4 drillbits running in 4
>>>>>> nodes.
>>>>>>> I
>>>>>>>>>>> started it using drillbit.sh start command.
>>>>>>>>>>> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
>>>>>>>>>> aengelbrecht@maprtech.com>
>>>>>>>>>>> wrote:
>>>>>>>>>>>
>>>>>>>>>>>> Are you running Drill in embedded mode or clustered mode?
>>>>>>>>>>>>
>>>>>>>>>>>> If in embedded mode you may want to try to connect directly to
>>>> the
>>>>>>>>>> drillbit
>>>>>>>>>>>> jdbc:drill:drillbit=<hostname>:31010
>>>>>>>>>>>>
>>>>>>>>>>>> It looks like you are trying to connect to a zk with a drill
>>>>>> cluster,
>>>>>>>>>> and
>>>>>>>>>>>> your setup may just be embedded mode.
>>>>>>>>>>>>
>>>>>>>>>>>> --Andries
>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
>>>>>>>>>>>> krishna.prasad@flytxt.com> wrote:
>>>>>>>>>>>>>
>>>>>>>>>>>>> hi,
>>>>>>>>>>>>> I'm trying to create a drill interpreter in zeppelin using the
>>>>>>>> existing
>>>>>>>>>>>>> jdbc interpreter.
>>>>>>>>>>>>>
>>>>>>>>>>>>> *drill.url =
>>>>>> jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
>>>>>>>>>>>>> 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
>>>>>>>>>>>>
>>>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>
>>>>>>
>>>>>> --
>>>>>> Krishnaprasad A S
>>>>>> Lead Engineer
>>>>>> Flytxt
>>>>>> Skype: krishnaprasadas
>>>>>> M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
>>>>>> 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
>>>>>>>
>>>>>>
>>>>>
>>>>>
>>>>
>>>
>>>
>>>
>>> --
>>> Krishnaprasad A S
>>> Lead Engineer
>>> Flytxt
>>> Skype: krishnaprasadas
>>> M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
>>> 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
>>>
>>
>>
>
>
> --
> Krishnaprasad A S
> Lead Engineer
> Flytxt
> Skype: krishnaprasadas
> M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
> 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>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Krishnaprasad A S <kr...@flytxt.com>.
I have restarted zeppelin each time. Also zeppelin runs on a drillbit node.
Please find below properties for jdbc interpreter,
name value
common.max_count 1000d
default.driver org.postgresql.Driver
default.password
default.url jdbc:postgresql://localhost:5432/
default.user gpadmin
drill.driver org.apache.drill.jdbc.Driver
drill.password
drill.url jdbc:drill:schema=dfs;drillbit=dk-slv8
hive.driver org.apache.hive.jdbc.HiveDriver
hive.password
hive.url jdbc:hive2://localhost:10000
hive.user hive
phoenix.driver org.apache.phoenix.jdbc.PhoenixDriver
phoenix.password
phoenix.url jdbc:phoenix:localhost:2181:/hbase-unsecure
phoenix.user phoenixuser
psql.driver org.postgresql.Driver
psql.password
psql.url jdbc:postgresql://localhost:5432/
psql.user phoenixuser
tajo.driver org.apache.tajo.jdbc.TajoDriver
tajo.url jdbc:tajo://localhost:26002/default
zeppelin.interpreter.localRepo
/data/installables/zeppelin-0.6.0-bin-all/local-repo/2BQT8WFCV
zeppelin.jdbc.concurrent.max_connection 10
zeppelin.jdbc.concurrent.use true
Dependencies
artifact exclude
/data/installables/apache-drill-1.7.0/jars/drill-jdbc-1.7.0.jar
Thanks,
Krishnaprasad
On Tue, Jul 12, 2016 at 8:06 PM, Andries Engelbrecht <
aengelbrecht@maprtech.com> wrote:
> Perhaps share the Zeppelin interpreter config line by line so we can see.
> Properties and Dependencies.
>
> Also did you restart the interpreter after you made the config changes?
>
> I assume you are running Zeppelin on one of the Drill nodes, where is ZK
> located?
>
> --Andries
>
>
> > On Jul 12, 2016, at 5:31 AM, Krishnaprasad A S <
> krishna.prasad@flytxt.com> wrote:
> >
> > My zookeeper runs on port 2181, thats why I used the same port.
> > I think drill won't start zookeeper by its own.
> > I also tried using url "jdbc:drill:schema=dfs.tmp;drillbit=<IPADDRESS>"
> > same error. Is there something I'm missing,
> >
> >
> > On Tue, Jul 12, 2016 at 1:11 PM, Khurram Faraaz <kf...@maprtech.com>
> > wrote:
> >
> >> Also try using port number 5181 in your drill-override.conf, instead of
> >> 2181, and then stop and start Drillbit and re-run your program.
> >>
> >> On Tue, Jul 12, 2016 at 1:08 PM, Khurram Faraaz <kf...@maprtech.com>
> >> wrote:
> >>
> >>> This one works just fine for me
> >>>
> >>> final String URL_STRING =
> >> "jdbc:drill:schema=dfs.tmp;drillbit=<IPADDRESS>";
> >>>
> >>> replace IPADDRESS with your IP address in the above line.
> >>>
> >>> On Tue, Jul 12, 2016 at 12:08 PM, Krishnaprasad A S <
> >>> krishna.prasad@flytxt.com> wrote:
> >>>
> >>>> Yes, I tried with url *jdbc:drill:drillbit=<IP>:31010* but same error,
> >>>> Error in zeppelin console,
> >>>> java.net.ConnectException: Connection refused at
> >>>> java.net.PlainSocketImpl.socketConnect(Native Method) at
> >>>>
> >>>>
> >>
> java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
> >>>> at
> >>>>
> >>>>
> >>
> java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
> >>>> ....
> >>>>
> >>>> *drill-override.conf *
> >>>> drill.exec: {
> >>>> cluster-id: "drillbits1",
> >>>> zk.connect: "dk-slv8:2181"
> >>>> }
> >>>>
> >>>> Some more details,
> >>>> I'm querying from hdfs (select count(*) from
> >> `dfs`.`/POC/Sample10000.csv`)
> >>>> the same query works with Drill Web UI.
> >>>> Also the errors are logged in 'zeppelin-hadoop-dk-slv8.log' and not
> in
> >>>> 'zeppelin-interpreter-jdbc-hadoop-dk-slv8.log'
> >>>>
> >>>> I think there is something I'm missing because I tried removing the
> >>>> drill.url and kept it blank again the same error is coming.
> >>>> But there is no host or port mentioned for the ConnectException:
> >>>> Connection
> >>>> refused.
> >>>>
> >>>>
> >>>>
> >>>> On Tue, Jul 12, 2016 at 3:31 AM, Andries Engelbrecht <
> >>>> aengelbrecht@maprtech.com> wrote:
> >>>>
> >>>>> Have you tried to connect to a drillbit directly from Zeppelin using
> >> the
> >>>>> jdbc url jdbc:drill:drillbit=<hostname>:31010?
> >>>>>
> >>>>> What does your drill-override.conf file look like?
> >>>>>
> >>>>>
> >>>>>> On Jul 11, 2016, at 2:33 PM, Krishnaprasad A S <
> >>>>> krishna.prasad@flytxt.com> wrote:
> >>>>>>
> >>>>>> I can see all the 4 drillbits in ui. Aso I tried the query in web ui
> >>>>> before
> >>>>>> running it in zeppelin. In web ui it works currently. Then what may
> >> be
> >>>>> the
> >>>>>> issue.?
> >>>>>> On Jul 12, 2016 3:00 AM, "Andries Engelbrecht" <
> >>>>> aengelbrecht@maprtech.com>
> >>>>>> wrote:
> >>>>>>
> >>>>>> What happens if you try to connect to a drillbit directly?
> >>>>>>
> >>>>>> This will help to see if it is a zk connection issue.
> >>>>>>
> >>>>>> Also I assume the dill cluster is up and running, and if you go to
> >> the
> >>>>>> webUI it shows all drillbits in the cluster connected and running.
> >>>>>>
> >>>>>>
> >>>>>>> On Jul 11, 2016, at 2:27 PM, Krishnaprasad A S <
> >>>>> krishna.prasad@flytxt.com>
> >>>>>> wrote:
> >>>>>>>
> >>>>>>> I went through the same link before configuring the interpreter,
> >> also
> >>>>>> there
> >>>>>>> is no security configured.
> >>>>>>> On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <
> >>>>> aengelbrecht@maprtech.com>
> >>>>>>> wrote:
> >>>>>>>
> >>>>>>>> Do you have security configured on the Drill cluster? If so make
> >>>> sure
> >>>>> to
> >>>>>>>> add the user and password info for the Drill connection.
> >>>>>>>>
> >>>>>>>> Some good info for configuring Zeppelin with Drill here
> >>>>>>>>
> >>>>>>>> https://community.mapr.com/docs/DOC-1493 <
> >>>>>>>> https://community.mapr.com/docs/DOC-1493>
> >>>>>>>>
> >>>>>>>> --Andries
> >>>>>>>>
> >>>>>>>>
> >>>>>>>>> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
> >>>>>>>> krishna.prasad@flytxt.com> wrote:
> >>>>>>>>>
> >>>>>>>>> My drill runs in clustered mode, with 4 drillbits running in 4
> >>>> nodes.
> >>>>> I
> >>>>>>>>> started it using drillbit.sh start command.
> >>>>>>>>> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
> >>>>>>>> aengelbrecht@maprtech.com>
> >>>>>>>>> wrote:
> >>>>>>>>>
> >>>>>>>>>> Are you running Drill in embedded mode or clustered mode?
> >>>>>>>>>>
> >>>>>>>>>> If in embedded mode you may want to try to connect directly to
> >> the
> >>>>>>>> drillbit
> >>>>>>>>>> jdbc:drill:drillbit=<hostname>:31010
> >>>>>>>>>>
> >>>>>>>>>> It looks like you are trying to connect to a zk with a drill
> >>>> cluster,
> >>>>>>>> and
> >>>>>>>>>> your setup may just be embedded mode.
> >>>>>>>>>>
> >>>>>>>>>> --Andries
> >>>>>>>>>>
> >>>>>>>>>>
> >>>>>>>>>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
> >>>>>>>>>> krishna.prasad@flytxt.com> wrote:
> >>>>>>>>>>>
> >>>>>>>>>>> hi,
> >>>>>>>>>>> I'm trying to create a drill interpreter in zeppelin using the
> >>>>>> existing
> >>>>>>>>>>> jdbc interpreter.
> >>>>>>>>>>>
> >>>>>>>>>>> *drill.url =
> >>>> jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
> >>>>>>>>>>> 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
> >>>>>>>>>>
> >>>>>>>>>>
> >>>>>>>>
> >>>>>>>>
> >>>>>
> >>>>>
> >>>>
> >>>>
> >>>> --
> >>>> Krishnaprasad A S
> >>>> Lead Engineer
> >>>> Flytxt
> >>>> Skype: krishnaprasadas
> >>>> M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
> >>>> 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
> >>>>>
> >>>>
> >>>
> >>>
> >>
> >
> >
> >
> > --
> > Krishnaprasad A S
> > Lead Engineer
> > Flytxt
> > Skype: krishnaprasadas
> > M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
> > 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
> >
>
>
--
Krishnaprasad A S
Lead Engineer
Flytxt
Skype: krishnaprasadas
M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
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>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Andries Engelbrecht <ae...@maprtech.com>.
Perhaps share the Zeppelin interpreter config line by line so we can see. Properties and Dependencies.
Also did you restart the interpreter after you made the config changes?
I assume you are running Zeppelin on one of the Drill nodes, where is ZK located?
--Andries
> On Jul 12, 2016, at 5:31 AM, Krishnaprasad A S <kr...@flytxt.com> wrote:
>
> My zookeeper runs on port 2181, thats why I used the same port.
> I think drill won't start zookeeper by its own.
> I also tried using url "jdbc:drill:schema=dfs.tmp;drillbit=<IPADDRESS>"
> same error. Is there something I'm missing,
>
>
> On Tue, Jul 12, 2016 at 1:11 PM, Khurram Faraaz <kf...@maprtech.com>
> wrote:
>
>> Also try using port number 5181 in your drill-override.conf, instead of
>> 2181, and then stop and start Drillbit and re-run your program.
>>
>> On Tue, Jul 12, 2016 at 1:08 PM, Khurram Faraaz <kf...@maprtech.com>
>> wrote:
>>
>>> This one works just fine for me
>>>
>>> final String URL_STRING =
>> "jdbc:drill:schema=dfs.tmp;drillbit=<IPADDRESS>";
>>>
>>> replace IPADDRESS with your IP address in the above line.
>>>
>>> On Tue, Jul 12, 2016 at 12:08 PM, Krishnaprasad A S <
>>> krishna.prasad@flytxt.com> wrote:
>>>
>>>> Yes, I tried with url *jdbc:drill:drillbit=<IP>:31010* but same error,
>>>> Error in zeppelin console,
>>>> java.net.ConnectException: Connection refused at
>>>> java.net.PlainSocketImpl.socketConnect(Native Method) at
>>>>
>>>>
>> java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
>>>> at
>>>>
>>>>
>> java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
>>>> ....
>>>>
>>>> *drill-override.conf *
>>>> drill.exec: {
>>>> cluster-id: "drillbits1",
>>>> zk.connect: "dk-slv8:2181"
>>>> }
>>>>
>>>> Some more details,
>>>> I'm querying from hdfs (select count(*) from
>> `dfs`.`/POC/Sample10000.csv`)
>>>> the same query works with Drill Web UI.
>>>> Also the errors are logged in 'zeppelin-hadoop-dk-slv8.log' and not in
>>>> 'zeppelin-interpreter-jdbc-hadoop-dk-slv8.log'
>>>>
>>>> I think there is something I'm missing because I tried removing the
>>>> drill.url and kept it blank again the same error is coming.
>>>> But there is no host or port mentioned for the ConnectException:
>>>> Connection
>>>> refused.
>>>>
>>>>
>>>>
>>>> On Tue, Jul 12, 2016 at 3:31 AM, Andries Engelbrecht <
>>>> aengelbrecht@maprtech.com> wrote:
>>>>
>>>>> Have you tried to connect to a drillbit directly from Zeppelin using
>> the
>>>>> jdbc url jdbc:drill:drillbit=<hostname>:31010?
>>>>>
>>>>> What does your drill-override.conf file look like?
>>>>>
>>>>>
>>>>>> On Jul 11, 2016, at 2:33 PM, Krishnaprasad A S <
>>>>> krishna.prasad@flytxt.com> wrote:
>>>>>>
>>>>>> I can see all the 4 drillbits in ui. Aso I tried the query in web ui
>>>>> before
>>>>>> running it in zeppelin. In web ui it works currently. Then what may
>> be
>>>>> the
>>>>>> issue.?
>>>>>> On Jul 12, 2016 3:00 AM, "Andries Engelbrecht" <
>>>>> aengelbrecht@maprtech.com>
>>>>>> wrote:
>>>>>>
>>>>>> What happens if you try to connect to a drillbit directly?
>>>>>>
>>>>>> This will help to see if it is a zk connection issue.
>>>>>>
>>>>>> Also I assume the dill cluster is up and running, and if you go to
>> the
>>>>>> webUI it shows all drillbits in the cluster connected and running.
>>>>>>
>>>>>>
>>>>>>> On Jul 11, 2016, at 2:27 PM, Krishnaprasad A S <
>>>>> krishna.prasad@flytxt.com>
>>>>>> wrote:
>>>>>>>
>>>>>>> I went through the same link before configuring the interpreter,
>> also
>>>>>> there
>>>>>>> is no security configured.
>>>>>>> On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <
>>>>> aengelbrecht@maprtech.com>
>>>>>>> wrote:
>>>>>>>
>>>>>>>> Do you have security configured on the Drill cluster? If so make
>>>> sure
>>>>> to
>>>>>>>> add the user and password info for the Drill connection.
>>>>>>>>
>>>>>>>> Some good info for configuring Zeppelin with Drill here
>>>>>>>>
>>>>>>>> https://community.mapr.com/docs/DOC-1493 <
>>>>>>>> https://community.mapr.com/docs/DOC-1493>
>>>>>>>>
>>>>>>>> --Andries
>>>>>>>>
>>>>>>>>
>>>>>>>>> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
>>>>>>>> krishna.prasad@flytxt.com> wrote:
>>>>>>>>>
>>>>>>>>> My drill runs in clustered mode, with 4 drillbits running in 4
>>>> nodes.
>>>>> I
>>>>>>>>> started it using drillbit.sh start command.
>>>>>>>>> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
>>>>>>>> aengelbrecht@maprtech.com>
>>>>>>>>> wrote:
>>>>>>>>>
>>>>>>>>>> Are you running Drill in embedded mode or clustered mode?
>>>>>>>>>>
>>>>>>>>>> If in embedded mode you may want to try to connect directly to
>> the
>>>>>>>> drillbit
>>>>>>>>>> jdbc:drill:drillbit=<hostname>:31010
>>>>>>>>>>
>>>>>>>>>> It looks like you are trying to connect to a zk with a drill
>>>> cluster,
>>>>>>>> and
>>>>>>>>>> your setup may just be embedded mode.
>>>>>>>>>>
>>>>>>>>>> --Andries
>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
>>>>>>>>>> krishna.prasad@flytxt.com> wrote:
>>>>>>>>>>>
>>>>>>>>>>> hi,
>>>>>>>>>>> I'm trying to create a drill interpreter in zeppelin using the
>>>>>> existing
>>>>>>>>>>> jdbc interpreter.
>>>>>>>>>>>
>>>>>>>>>>> *drill.url =
>>>> jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
>>>>>>>>>>> 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
>>>>>>>>>>
>>>>>>>>>>
>>>>>>>>
>>>>>>>>
>>>>>
>>>>>
>>>>
>>>>
>>>> --
>>>> Krishnaprasad A S
>>>> Lead Engineer
>>>> Flytxt
>>>> Skype: krishnaprasadas
>>>> M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
>>>> 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
>>>>>
>>>>
>>>
>>>
>>
>
>
>
> --
> Krishnaprasad A S
> Lead Engineer
> Flytxt
> Skype: krishnaprasadas
> M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
> 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>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Krishnaprasad A S <kr...@flytxt.com>.
My zookeeper runs on port 2181, thats why I used the same port.
I think drill won't start zookeeper by its own.
I also tried using url "jdbc:drill:schema=dfs.tmp;drillbit=<IPADDRESS>"
same error. Is there something I'm missing,
On Tue, Jul 12, 2016 at 1:11 PM, Khurram Faraaz <kf...@maprtech.com>
wrote:
> Also try using port number 5181 in your drill-override.conf, instead of
> 2181, and then stop and start Drillbit and re-run your program.
>
> On Tue, Jul 12, 2016 at 1:08 PM, Khurram Faraaz <kf...@maprtech.com>
> wrote:
>
> > This one works just fine for me
> >
> > final String URL_STRING =
> "jdbc:drill:schema=dfs.tmp;drillbit=<IPADDRESS>";
> >
> > replace IPADDRESS with your IP address in the above line.
> >
> > On Tue, Jul 12, 2016 at 12:08 PM, Krishnaprasad A S <
> > krishna.prasad@flytxt.com> wrote:
> >
> >> Yes, I tried with url *jdbc:drill:drillbit=<IP>:31010* but same error,
> >> Error in zeppelin console,
> >> java.net.ConnectException: Connection refused at
> >> java.net.PlainSocketImpl.socketConnect(Native Method) at
> >>
> >>
> java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
> >> at
> >>
> >>
> java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
> >> ....
> >>
> >> *drill-override.conf *
> >> drill.exec: {
> >> cluster-id: "drillbits1",
> >> zk.connect: "dk-slv8:2181"
> >> }
> >>
> >> Some more details,
> >> I'm querying from hdfs (select count(*) from
> `dfs`.`/POC/Sample10000.csv`)
> >> the same query works with Drill Web UI.
> >> Also the errors are logged in 'zeppelin-hadoop-dk-slv8.log' and not in
> >> 'zeppelin-interpreter-jdbc-hadoop-dk-slv8.log'
> >>
> >> I think there is something I'm missing because I tried removing the
> >> drill.url and kept it blank again the same error is coming.
> >> But there is no host or port mentioned for the ConnectException:
> >> Connection
> >> refused.
> >>
> >>
> >>
> >> On Tue, Jul 12, 2016 at 3:31 AM, Andries Engelbrecht <
> >> aengelbrecht@maprtech.com> wrote:
> >>
> >> > Have you tried to connect to a drillbit directly from Zeppelin using
> the
> >> > jdbc url jdbc:drill:drillbit=<hostname>:31010?
> >> >
> >> > What does your drill-override.conf file look like?
> >> >
> >> >
> >> > > On Jul 11, 2016, at 2:33 PM, Krishnaprasad A S <
> >> > krishna.prasad@flytxt.com> wrote:
> >> > >
> >> > > I can see all the 4 drillbits in ui. Aso I tried the query in web ui
> >> > before
> >> > > running it in zeppelin. In web ui it works currently. Then what may
> be
> >> > the
> >> > > issue.?
> >> > > On Jul 12, 2016 3:00 AM, "Andries Engelbrecht" <
> >> > aengelbrecht@maprtech.com>
> >> > > wrote:
> >> > >
> >> > > What happens if you try to connect to a drillbit directly?
> >> > >
> >> > > This will help to see if it is a zk connection issue.
> >> > >
> >> > > Also I assume the dill cluster is up and running, and if you go to
> the
> >> > > webUI it shows all drillbits in the cluster connected and running.
> >> > >
> >> > >
> >> > >> On Jul 11, 2016, at 2:27 PM, Krishnaprasad A S <
> >> > krishna.prasad@flytxt.com>
> >> > > wrote:
> >> > >>
> >> > >> I went through the same link before configuring the interpreter,
> also
> >> > > there
> >> > >> is no security configured.
> >> > >> On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <
> >> > aengelbrecht@maprtech.com>
> >> > >> wrote:
> >> > >>
> >> > >>> Do you have security configured on the Drill cluster? If so make
> >> sure
> >> > to
> >> > >>> add the user and password info for the Drill connection.
> >> > >>>
> >> > >>> Some good info for configuring Zeppelin with Drill here
> >> > >>>
> >> > >>> https://community.mapr.com/docs/DOC-1493 <
> >> > >>> https://community.mapr.com/docs/DOC-1493>
> >> > >>>
> >> > >>> --Andries
> >> > >>>
> >> > >>>
> >> > >>>> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
> >> > >>> krishna.prasad@flytxt.com> wrote:
> >> > >>>>
> >> > >>>> My drill runs in clustered mode, with 4 drillbits running in 4
> >> nodes.
> >> > I
> >> > >>>> started it using drillbit.sh start command.
> >> > >>>> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
> >> > >>> aengelbrecht@maprtech.com>
> >> > >>>> wrote:
> >> > >>>>
> >> > >>>>> Are you running Drill in embedded mode or clustered mode?
> >> > >>>>>
> >> > >>>>> If in embedded mode you may want to try to connect directly to
> the
> >> > >>> drillbit
> >> > >>>>> jdbc:drill:drillbit=<hostname>:31010
> >> > >>>>>
> >> > >>>>> It looks like you are trying to connect to a zk with a drill
> >> cluster,
> >> > >>> and
> >> > >>>>> your setup may just be embedded mode.
> >> > >>>>>
> >> > >>>>> --Andries
> >> > >>>>>
> >> > >>>>>
> >> > >>>>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
> >> > >>>>> krishna.prasad@flytxt.com> wrote:
> >> > >>>>>>
> >> > >>>>>> hi,
> >> > >>>>>> I'm trying to create a drill interpreter in zeppelin using the
> >> > > existing
> >> > >>>>>> jdbc interpreter.
> >> > >>>>>>
> >> > >>>>>> *drill.url =
> >> jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
> >> > >>>>>> 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
> >> > >>>>>
> >> > >>>>>
> >> > >>>
> >> > >>>
> >> >
> >> >
> >>
> >>
> >> --
> >> Krishnaprasad A S
> >> Lead Engineer
> >> Flytxt
> >> Skype: krishnaprasadas
> >> M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
> >> 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
> >> >
> >>
> >
> >
>
--
Krishnaprasad A S
Lead Engineer
Flytxt
Skype: krishnaprasadas
M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
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>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Khurram Faraaz <kf...@maprtech.com>.
Also try using port number 5181 in your drill-override.conf, instead of
2181, and then stop and start Drillbit and re-run your program.
On Tue, Jul 12, 2016 at 1:08 PM, Khurram Faraaz <kf...@maprtech.com>
wrote:
> This one works just fine for me
>
> final String URL_STRING = "jdbc:drill:schema=dfs.tmp;drillbit=<IPADDRESS>";
>
> replace IPADDRESS with your IP address in the above line.
>
> On Tue, Jul 12, 2016 at 12:08 PM, Krishnaprasad A S <
> krishna.prasad@flytxt.com> wrote:
>
>> Yes, I tried with url *jdbc:drill:drillbit=<IP>:31010* but same error,
>> Error in zeppelin console,
>> java.net.ConnectException: Connection refused at
>> java.net.PlainSocketImpl.socketConnect(Native Method) at
>>
>> java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
>> at
>>
>> java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
>> ....
>>
>> *drill-override.conf *
>> drill.exec: {
>> cluster-id: "drillbits1",
>> zk.connect: "dk-slv8:2181"
>> }
>>
>> Some more details,
>> I'm querying from hdfs (select count(*) from `dfs`.`/POC/Sample10000.csv`)
>> the same query works with Drill Web UI.
>> Also the errors are logged in 'zeppelin-hadoop-dk-slv8.log' and not in
>> 'zeppelin-interpreter-jdbc-hadoop-dk-slv8.log'
>>
>> I think there is something I'm missing because I tried removing the
>> drill.url and kept it blank again the same error is coming.
>> But there is no host or port mentioned for the ConnectException:
>> Connection
>> refused.
>>
>>
>>
>> On Tue, Jul 12, 2016 at 3:31 AM, Andries Engelbrecht <
>> aengelbrecht@maprtech.com> wrote:
>>
>> > Have you tried to connect to a drillbit directly from Zeppelin using the
>> > jdbc url jdbc:drill:drillbit=<hostname>:31010?
>> >
>> > What does your drill-override.conf file look like?
>> >
>> >
>> > > On Jul 11, 2016, at 2:33 PM, Krishnaprasad A S <
>> > krishna.prasad@flytxt.com> wrote:
>> > >
>> > > I can see all the 4 drillbits in ui. Aso I tried the query in web ui
>> > before
>> > > running it in zeppelin. In web ui it works currently. Then what may be
>> > the
>> > > issue.?
>> > > On Jul 12, 2016 3:00 AM, "Andries Engelbrecht" <
>> > aengelbrecht@maprtech.com>
>> > > wrote:
>> > >
>> > > What happens if you try to connect to a drillbit directly?
>> > >
>> > > This will help to see if it is a zk connection issue.
>> > >
>> > > Also I assume the dill cluster is up and running, and if you go to the
>> > > webUI it shows all drillbits in the cluster connected and running.
>> > >
>> > >
>> > >> On Jul 11, 2016, at 2:27 PM, Krishnaprasad A S <
>> > krishna.prasad@flytxt.com>
>> > > wrote:
>> > >>
>> > >> I went through the same link before configuring the interpreter, also
>> > > there
>> > >> is no security configured.
>> > >> On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <
>> > aengelbrecht@maprtech.com>
>> > >> wrote:
>> > >>
>> > >>> Do you have security configured on the Drill cluster? If so make
>> sure
>> > to
>> > >>> add the user and password info for the Drill connection.
>> > >>>
>> > >>> Some good info for configuring Zeppelin with Drill here
>> > >>>
>> > >>> https://community.mapr.com/docs/DOC-1493 <
>> > >>> https://community.mapr.com/docs/DOC-1493>
>> > >>>
>> > >>> --Andries
>> > >>>
>> > >>>
>> > >>>> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
>> > >>> krishna.prasad@flytxt.com> wrote:
>> > >>>>
>> > >>>> My drill runs in clustered mode, with 4 drillbits running in 4
>> nodes.
>> > I
>> > >>>> started it using drillbit.sh start command.
>> > >>>> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
>> > >>> aengelbrecht@maprtech.com>
>> > >>>> wrote:
>> > >>>>
>> > >>>>> Are you running Drill in embedded mode or clustered mode?
>> > >>>>>
>> > >>>>> If in embedded mode you may want to try to connect directly to the
>> > >>> drillbit
>> > >>>>> jdbc:drill:drillbit=<hostname>:31010
>> > >>>>>
>> > >>>>> It looks like you are trying to connect to a zk with a drill
>> cluster,
>> > >>> and
>> > >>>>> your setup may just be embedded mode.
>> > >>>>>
>> > >>>>> --Andries
>> > >>>>>
>> > >>>>>
>> > >>>>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
>> > >>>>> krishna.prasad@flytxt.com> wrote:
>> > >>>>>>
>> > >>>>>> hi,
>> > >>>>>> I'm trying to create a drill interpreter in zeppelin using the
>> > > existing
>> > >>>>>> jdbc interpreter.
>> > >>>>>>
>> > >>>>>> *drill.url =
>> jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
>> > >>>>>> 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
>> > >>>>>
>> > >>>>>
>> > >>>
>> > >>>
>> >
>> >
>>
>>
>> --
>> Krishnaprasad A S
>> Lead Engineer
>> Flytxt
>> Skype: krishnaprasadas
>> M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
>> 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
>> >
>>
>
>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Khurram Faraaz <kf...@maprtech.com>.
This one works just fine for me
final String URL_STRING = "jdbc:drill:schema=dfs.tmp;drillbit=<IPADDRESS>";
replace IPADDRESS with your IP address in the above line.
On Tue, Jul 12, 2016 at 12:08 PM, Krishnaprasad A S <
krishna.prasad@flytxt.com> wrote:
> Yes, I tried with url *jdbc:drill:drillbit=<IP>:31010* but same error,
> Error in zeppelin console,
> java.net.ConnectException: Connection refused at
> java.net.PlainSocketImpl.socketConnect(Native Method) at
>
> java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
> at
>
> java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
> ....
>
> *drill-override.conf *
> drill.exec: {
> cluster-id: "drillbits1",
> zk.connect: "dk-slv8:2181"
> }
>
> Some more details,
> I'm querying from hdfs (select count(*) from `dfs`.`/POC/Sample10000.csv`)
> the same query works with Drill Web UI.
> Also the errors are logged in 'zeppelin-hadoop-dk-slv8.log' and not in
> 'zeppelin-interpreter-jdbc-hadoop-dk-slv8.log'
>
> I think there is something I'm missing because I tried removing the
> drill.url and kept it blank again the same error is coming.
> But there is no host or port mentioned for the ConnectException: Connection
> refused.
>
>
>
> On Tue, Jul 12, 2016 at 3:31 AM, Andries Engelbrecht <
> aengelbrecht@maprtech.com> wrote:
>
> > Have you tried to connect to a drillbit directly from Zeppelin using the
> > jdbc url jdbc:drill:drillbit=<hostname>:31010?
> >
> > What does your drill-override.conf file look like?
> >
> >
> > > On Jul 11, 2016, at 2:33 PM, Krishnaprasad A S <
> > krishna.prasad@flytxt.com> wrote:
> > >
> > > I can see all the 4 drillbits in ui. Aso I tried the query in web ui
> > before
> > > running it in zeppelin. In web ui it works currently. Then what may be
> > the
> > > issue.?
> > > On Jul 12, 2016 3:00 AM, "Andries Engelbrecht" <
> > aengelbrecht@maprtech.com>
> > > wrote:
> > >
> > > What happens if you try to connect to a drillbit directly?
> > >
> > > This will help to see if it is a zk connection issue.
> > >
> > > Also I assume the dill cluster is up and running, and if you go to the
> > > webUI it shows all drillbits in the cluster connected and running.
> > >
> > >
> > >> On Jul 11, 2016, at 2:27 PM, Krishnaprasad A S <
> > krishna.prasad@flytxt.com>
> > > wrote:
> > >>
> > >> I went through the same link before configuring the interpreter, also
> > > there
> > >> is no security configured.
> > >> On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <
> > aengelbrecht@maprtech.com>
> > >> wrote:
> > >>
> > >>> Do you have security configured on the Drill cluster? If so make sure
> > to
> > >>> add the user and password info for the Drill connection.
> > >>>
> > >>> Some good info for configuring Zeppelin with Drill here
> > >>>
> > >>> https://community.mapr.com/docs/DOC-1493 <
> > >>> https://community.mapr.com/docs/DOC-1493>
> > >>>
> > >>> --Andries
> > >>>
> > >>>
> > >>>> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
> > >>> krishna.prasad@flytxt.com> wrote:
> > >>>>
> > >>>> My drill runs in clustered mode, with 4 drillbits running in 4
> nodes.
> > I
> > >>>> started it using drillbit.sh start command.
> > >>>> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
> > >>> aengelbrecht@maprtech.com>
> > >>>> wrote:
> > >>>>
> > >>>>> Are you running Drill in embedded mode or clustered mode?
> > >>>>>
> > >>>>> If in embedded mode you may want to try to connect directly to the
> > >>> drillbit
> > >>>>> jdbc:drill:drillbit=<hostname>:31010
> > >>>>>
> > >>>>> It looks like you are trying to connect to a zk with a drill
> cluster,
> > >>> and
> > >>>>> your setup may just be embedded mode.
> > >>>>>
> > >>>>> --Andries
> > >>>>>
> > >>>>>
> > >>>>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
> > >>>>> krishna.prasad@flytxt.com> wrote:
> > >>>>>>
> > >>>>>> hi,
> > >>>>>> I'm trying to create a drill interpreter in zeppelin using the
> > > existing
> > >>>>>> jdbc interpreter.
> > >>>>>>
> > >>>>>> *drill.url =
> jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
> > >>>>>> 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
> > >>>>>
> > >>>>>
> > >>>
> > >>>
> >
> >
>
>
> --
> Krishnaprasad A S
> Lead Engineer
> Flytxt
> Skype: krishnaprasadas
> M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
> 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
> >
>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Krishnaprasad A S <kr...@flytxt.com>.
Yes, I tried with url *jdbc:drill:drillbit=<IP>:31010* but same error,
Error in zeppelin console,
java.net.ConnectException: Connection refused at
java.net.PlainSocketImpl.socketConnect(Native Method) at
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
at
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
....
*drill-override.conf *
drill.exec: {
cluster-id: "drillbits1",
zk.connect: "dk-slv8:2181"
}
Some more details,
I'm querying from hdfs (select count(*) from `dfs`.`/POC/Sample10000.csv`)
the same query works with Drill Web UI.
Also the errors are logged in 'zeppelin-hadoop-dk-slv8.log' and not in
'zeppelin-interpreter-jdbc-hadoop-dk-slv8.log'
I think there is something I'm missing because I tried removing the
drill.url and kept it blank again the same error is coming.
But there is no host or port mentioned for the ConnectException: Connection
refused.
On Tue, Jul 12, 2016 at 3:31 AM, Andries Engelbrecht <
aengelbrecht@maprtech.com> wrote:
> Have you tried to connect to a drillbit directly from Zeppelin using the
> jdbc url jdbc:drill:drillbit=<hostname>:31010?
>
> What does your drill-override.conf file look like?
>
>
> > On Jul 11, 2016, at 2:33 PM, Krishnaprasad A S <
> krishna.prasad@flytxt.com> wrote:
> >
> > I can see all the 4 drillbits in ui. Aso I tried the query in web ui
> before
> > running it in zeppelin. In web ui it works currently. Then what may be
> the
> > issue.?
> > On Jul 12, 2016 3:00 AM, "Andries Engelbrecht" <
> aengelbrecht@maprtech.com>
> > wrote:
> >
> > What happens if you try to connect to a drillbit directly?
> >
> > This will help to see if it is a zk connection issue.
> >
> > Also I assume the dill cluster is up and running, and if you go to the
> > webUI it shows all drillbits in the cluster connected and running.
> >
> >
> >> On Jul 11, 2016, at 2:27 PM, Krishnaprasad A S <
> krishna.prasad@flytxt.com>
> > wrote:
> >>
> >> I went through the same link before configuring the interpreter, also
> > there
> >> is no security configured.
> >> On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <
> aengelbrecht@maprtech.com>
> >> wrote:
> >>
> >>> Do you have security configured on the Drill cluster? If so make sure
> to
> >>> add the user and password info for the Drill connection.
> >>>
> >>> Some good info for configuring Zeppelin with Drill here
> >>>
> >>> https://community.mapr.com/docs/DOC-1493 <
> >>> https://community.mapr.com/docs/DOC-1493>
> >>>
> >>> --Andries
> >>>
> >>>
> >>>> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
> >>> krishna.prasad@flytxt.com> wrote:
> >>>>
> >>>> My drill runs in clustered mode, with 4 drillbits running in 4 nodes.
> I
> >>>> started it using drillbit.sh start command.
> >>>> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
> >>> aengelbrecht@maprtech.com>
> >>>> wrote:
> >>>>
> >>>>> Are you running Drill in embedded mode or clustered mode?
> >>>>>
> >>>>> If in embedded mode you may want to try to connect directly to the
> >>> drillbit
> >>>>> jdbc:drill:drillbit=<hostname>:31010
> >>>>>
> >>>>> It looks like you are trying to connect to a zk with a drill cluster,
> >>> and
> >>>>> your setup may just be embedded mode.
> >>>>>
> >>>>> --Andries
> >>>>>
> >>>>>
> >>>>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
> >>>>> krishna.prasad@flytxt.com> wrote:
> >>>>>>
> >>>>>> hi,
> >>>>>> I'm trying to create a drill interpreter in zeppelin using the
> > existing
> >>>>>> jdbc interpreter.
> >>>>>>
> >>>>>> *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
> >>>>>> 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
> >>>>>
> >>>>>
> >>>
> >>>
>
>
--
Krishnaprasad A S
Lead Engineer
Flytxt
Skype: krishnaprasadas
M: +91 8907209454 | O: +91 471.3082753 | F: +91 471.2700202
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>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Andries Engelbrecht <ae...@maprtech.com>.
Have you tried to connect to a drillbit directly from Zeppelin using the jdbc url jdbc:drill:drillbit=<hostname>:31010?
What does your drill-override.conf file look like?
> On Jul 11, 2016, at 2:33 PM, Krishnaprasad A S <kr...@flytxt.com> wrote:
>
> I can see all the 4 drillbits in ui. Aso I tried the query in web ui before
> running it in zeppelin. In web ui it works currently. Then what may be the
> issue.?
> On Jul 12, 2016 3:00 AM, "Andries Engelbrecht" <ae...@maprtech.com>
> wrote:
>
> What happens if you try to connect to a drillbit directly?
>
> This will help to see if it is a zk connection issue.
>
> Also I assume the dill cluster is up and running, and if you go to the
> webUI it shows all drillbits in the cluster connected and running.
>
>
>> On Jul 11, 2016, at 2:27 PM, Krishnaprasad A S <kr...@flytxt.com>
> wrote:
>>
>> I went through the same link before configuring the interpreter, also
> there
>> is no security configured.
>> On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <ae...@maprtech.com>
>> wrote:
>>
>>> Do you have security configured on the Drill cluster? If so make sure to
>>> add the user and password info for the Drill connection.
>>>
>>> Some good info for configuring Zeppelin with Drill here
>>>
>>> https://community.mapr.com/docs/DOC-1493 <
>>> https://community.mapr.com/docs/DOC-1493>
>>>
>>> --Andries
>>>
>>>
>>>> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
>>> krishna.prasad@flytxt.com> wrote:
>>>>
>>>> My drill runs in clustered mode, with 4 drillbits running in 4 nodes. I
>>>> started it using drillbit.sh start command.
>>>> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
>>> aengelbrecht@maprtech.com>
>>>> wrote:
>>>>
>>>>> Are you running Drill in embedded mode or clustered mode?
>>>>>
>>>>> If in embedded mode you may want to try to connect directly to the
>>> drillbit
>>>>> jdbc:drill:drillbit=<hostname>:31010
>>>>>
>>>>> It looks like you are trying to connect to a zk with a drill cluster,
>>> and
>>>>> your setup may just be embedded mode.
>>>>>
>>>>> --Andries
>>>>>
>>>>>
>>>>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
>>>>> krishna.prasad@flytxt.com> wrote:
>>>>>>
>>>>>> hi,
>>>>>> I'm trying to create a drill interpreter in zeppelin using the
> existing
>>>>>> jdbc interpreter.
>>>>>>
>>>>>> *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
>>>>>> 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
>>>>>
>>>>>
>>>
>>>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Krishnaprasad A S <kr...@flytxt.com>.
I can see all the 4 drillbits in ui. Aso I tried the query in web ui before
running it in zeppelin. In web ui it works currently. Then what may be the
issue.?
On Jul 12, 2016 3:00 AM, "Andries Engelbrecht" <ae...@maprtech.com>
wrote:
What happens if you try to connect to a drillbit directly?
This will help to see if it is a zk connection issue.
Also I assume the dill cluster is up and running, and if you go to the
webUI it shows all drillbits in the cluster connected and running.
> On Jul 11, 2016, at 2:27 PM, Krishnaprasad A S <kr...@flytxt.com>
wrote:
>
> I went through the same link before configuring the interpreter, also
there
> is no security configured.
> On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <ae...@maprtech.com>
> wrote:
>
>> Do you have security configured on the Drill cluster? If so make sure to
>> add the user and password info for the Drill connection.
>>
>> Some good info for configuring Zeppelin with Drill here
>>
>> https://community.mapr.com/docs/DOC-1493 <
>> https://community.mapr.com/docs/DOC-1493>
>>
>> --Andries
>>
>>
>>> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
>> krishna.prasad@flytxt.com> wrote:
>>>
>>> My drill runs in clustered mode, with 4 drillbits running in 4 nodes. I
>>> started it using drillbit.sh start command.
>>> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
>> aengelbrecht@maprtech.com>
>>> wrote:
>>>
>>>> Are you running Drill in embedded mode or clustered mode?
>>>>
>>>> If in embedded mode you may want to try to connect directly to the
>> drillbit
>>>> jdbc:drill:drillbit=<hostname>:31010
>>>>
>>>> It looks like you are trying to connect to a zk with a drill cluster,
>> and
>>>> your setup may just be embedded mode.
>>>>
>>>> --Andries
>>>>
>>>>
>>>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
>>>> krishna.prasad@flytxt.com> wrote:
>>>>>
>>>>> hi,
>>>>> I'm trying to create a drill interpreter in zeppelin using the
existing
>>>>> jdbc interpreter.
>>>>>
>>>>> *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
>>>>> 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
>>>>
>>>>
>>
>>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Andries Engelbrecht <ae...@maprtech.com>.
What happens if you try to connect to a drillbit directly?
This will help to see if it is a zk connection issue.
Also I assume the dill cluster is up and running, and if you go to the webUI it shows all drillbits in the cluster connected and running.
> On Jul 11, 2016, at 2:27 PM, Krishnaprasad A S <kr...@flytxt.com> wrote:
>
> I went through the same link before configuring the interpreter, also there
> is no security configured.
> On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <ae...@maprtech.com>
> wrote:
>
>> Do you have security configured on the Drill cluster? If so make sure to
>> add the user and password info for the Drill connection.
>>
>> Some good info for configuring Zeppelin with Drill here
>>
>> https://community.mapr.com/docs/DOC-1493 <
>> https://community.mapr.com/docs/DOC-1493>
>>
>> --Andries
>>
>>
>>> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
>> krishna.prasad@flytxt.com> wrote:
>>>
>>> My drill runs in clustered mode, with 4 drillbits running in 4 nodes. I
>>> started it using drillbit.sh start command.
>>> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
>> aengelbrecht@maprtech.com>
>>> wrote:
>>>
>>>> Are you running Drill in embedded mode or clustered mode?
>>>>
>>>> If in embedded mode you may want to try to connect directly to the
>> drillbit
>>>> jdbc:drill:drillbit=<hostname>:31010
>>>>
>>>> It looks like you are trying to connect to a zk with a drill cluster,
>> and
>>>> your setup may just be embedded mode.
>>>>
>>>> --Andries
>>>>
>>>>
>>>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
>>>> krishna.prasad@flytxt.com> wrote:
>>>>>
>>>>> hi,
>>>>> I'm trying to create a drill interpreter in zeppelin using the existing
>>>>> jdbc interpreter.
>>>>>
>>>>> *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
>>>>> 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
>>>>
>>>>
>>
>>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Krishnaprasad A S <kr...@flytxt.com>.
I went through the same link before configuring the interpreter, also there
is no security configured.
On Jul 12, 2016 2:48 AM, "Andries Engelbrecht" <ae...@maprtech.com>
wrote:
> Do you have security configured on the Drill cluster? If so make sure to
> add the user and password info for the Drill connection.
>
> Some good info for configuring Zeppelin with Drill here
>
> https://community.mapr.com/docs/DOC-1493 <
> https://community.mapr.com/docs/DOC-1493>
>
> --Andries
>
>
> > On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <
> krishna.prasad@flytxt.com> wrote:
> >
> > My drill runs in clustered mode, with 4 drillbits running in 4 nodes. I
> > started it using drillbit.sh start command.
> > On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <
> aengelbrecht@maprtech.com>
> > wrote:
> >
> >> Are you running Drill in embedded mode or clustered mode?
> >>
> >> If in embedded mode you may want to try to connect directly to the
> drillbit
> >> jdbc:drill:drillbit=<hostname>:31010
> >>
> >> It looks like you are trying to connect to a zk with a drill cluster,
> and
> >> your setup may just be embedded mode.
> >>
> >> --Andries
> >>
> >>
> >>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
> >> krishna.prasad@flytxt.com> wrote:
> >>>
> >>> hi,
> >>> I'm trying to create a drill interpreter in zeppelin using the existing
> >>> jdbc interpreter.
> >>>
> >>> *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
> >>> 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
> >>
> >>
>
>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Andries Engelbrecht <ae...@maprtech.com>.
Do you have security configured on the Drill cluster? If so make sure to add the user and password info for the Drill connection.
Some good info for configuring Zeppelin with Drill here
https://community.mapr.com/docs/DOC-1493 <https://community.mapr.com/docs/DOC-1493>
--Andries
> On Jul 11, 2016, at 2:13 PM, Krishnaprasad A S <kr...@flytxt.com> wrote:
>
> My drill runs in clustered mode, with 4 drillbits running in 4 nodes. I
> started it using drillbit.sh start command.
> On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <ae...@maprtech.com>
> wrote:
>
>> Are you running Drill in embedded mode or clustered mode?
>>
>> If in embedded mode you may want to try to connect directly to the drillbit
>> jdbc:drill:drillbit=<hostname>:31010
>>
>> It looks like you are trying to connect to a zk with a drill cluster, and
>> your setup may just be embedded mode.
>>
>> --Andries
>>
>>
>>> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
>> krishna.prasad@flytxt.com> wrote:
>>>
>>> hi,
>>> I'm trying to create a drill interpreter in zeppelin using the existing
>>> jdbc interpreter.
>>>
>>> *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
>>> 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
>>
>>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Krishnaprasad A S <kr...@flytxt.com>.
My drill runs in clustered mode, with 4 drillbits running in 4 nodes. I
started it using drillbit.sh start command.
On Jul 12, 2016 2:18 AM, "Andries Engelbrecht" <ae...@maprtech.com>
wrote:
> Are you running Drill in embedded mode or clustered mode?
>
> If in embedded mode you may want to try to connect directly to the drillbit
> jdbc:drill:drillbit=<hostname>:31010
>
> It looks like you are trying to connect to a zk with a drill cluster, and
> your setup may just be embedded mode.
>
> --Andries
>
>
> > On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <
> krishna.prasad@flytxt.com> wrote:
> >
> > hi,
> > I'm trying to create a drill interpreter in zeppelin using the existing
> > jdbc interpreter.
> >
> > *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
> > 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
>
>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Andries Engelbrecht <ae...@maprtech.com>.
Are you running Drill in embedded mode or clustered mode?
If in embedded mode you may want to try to connect directly to the drillbit
jdbc:drill:drillbit=<hostname>:31010
It looks like you are trying to connect to a zk with a drill cluster, and your setup may just be embedded mode.
--Andries
> On Jul 11, 2016, at 12:55 PM, Krishnaprasad A S <kr...@flytxt.com> wrote:
>
> hi,
> I'm trying to create a drill interpreter in zeppelin using the existing
> jdbc interpreter.
>
> *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
> 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
Re: Drill JDBC Interpreter: Connection Refused
Posted by Alexander Bezzubov <bz...@apache.org>.
Hi Kevin,
this is very strange indeed.
Could you please try to delete ./logs/* restart Zeppelin and try again, and
then post 2 full log files, of both zeppelin server and drill interpreter
I.e on gist or pastebin and share a link here?
This should help to debug the situation.
--
Alex
On Fri, Jul 29, 2016, 01:17 Kevin Verhoeven <Ke...@ds-iq.com>
wrote:
> Thanks Jongyoul,
>
>
>
> I tried your suggestion and used %drill with:
>
>
>
> drill.driver
>
> drill.url
>
> drill.user
>
> drill.password
>
>
>
> However, the query still failed with a “Connection refused” error.
>
>
>
> My drill.url is: jdbc:drill:zk=localhost:2181/drill/drillbits1
>
>
>
> ZooKeeper and Drill both work, I’ve run many queries through Drill’s UI.
> Only Zeppelin throws an error.
>
>
>
> Do you have any other suggestions?
>
>
>
> Thanks,
>
>
>
> Kevin
>
>
>
> The error I found in the log:
>
>
>
> ERROR [2016-07-28 09:13:37,639] ({Thread-97}
> RemoteScheduler.java[getStatus]:256) - Can't get status information
>
> 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:96)
>
> at
> org.apache.zeppelin.scheduler.RemoteScheduler$JobStatusPoller.getStatus(RemoteScheduler.java:254)
>
> at
> org.apache.zeppelin.scheduler.RemoteScheduler$JobStatusPoller.run(RemoteScheduler.java:212)
>
> 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)
>
> ... 8 more
>
> Caused by: 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)
>
> ... 9 more
>
>
>
> *From:* Jongyoul Lee [mailto:jongyoul@gmail.com]
> *Sent:* Thursday, July 28, 2016 3:02 AM
>
>
> *To:* users@zeppelin.apache.org
> *Subject:* Re: Drill JDBC Interpreter: Connection Refused
>
>
>
> Hello Kevin,
>
>
>
> I've got to know what the problem is.
>
>
>
> If you are running query with "%drill ...", you can set
>
>
>
> drill.url
>
> drill.user
>
> drill.password
>
>
>
> If you set default.*, you should use "%jdbc ..."
>
>
>
> It's a little bit confused, and it will be improved by 0.7.0.
>
>
>
> Hope this help,
>
> Jongyoul
>
>
>
> On Thu, Jul 28, 2016 at 7:56 AM, Kevin Verhoeven <
> Kevin.Verhoeven@ds-iq.com> wrote:
>
> 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=my*ServerName*: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:jongyoul@gmail.com]
> *Sent:* Tuesday, July 12, 2016 10:53 PM
> *To:* users@zeppelin.apache.org
> *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 <
> krishna.prasad@flytxt.com> 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 <jo...@gmail.com> 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 <kr...@flytxt.com>
> 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 | O: +91 471.3082753 <%2B91%20471.3082753> | F: +91
> 471.2700202
> 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
>
>
>
>
>
> --
>
> 이종열, Jongyoul Lee, 李宗烈
>
> http://madeng.net
>
RE: Drill JDBC Interpreter: Connection Refused
Posted by Kevin Verhoeven <Ke...@ds-iq.com>.
Thanks Jongyoul,
I tried your suggestion and used %drill with:
drill.driver
drill.url
drill.user
drill.password
However, the query still failed with a “Connection refused” error.
My drill.url is: jdbc:drill:zk=localhost:2181/drill/drillbits1
ZooKeeper and Drill both work, I’ve run many queries through Drill’s UI. Only Zeppelin throws an error.
Do you have any other suggestions?
Thanks,
Kevin
The error I found in the log:
ERROR [2016-07-28 09:13:37,639] ({Thread-97} RemoteScheduler.java[getStatus]:256) - Can't get status information
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:96)
at org.apache.zeppelin.scheduler.RemoteScheduler$JobStatusPoller.getStatus(RemoteScheduler.java:254)
at org.apache.zeppelin.scheduler.RemoteScheduler$JobStatusPoller.run(RemoteScheduler.java:212)
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)
... 8 more
Caused by: 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)
... 9 more
From: Jongyoul Lee [mailto:jongyoul@gmail.com]
Sent: Thursday, July 28, 2016 3:02 AM
To: users@zeppelin.apache.org
Subject: Re: Drill JDBC Interpreter: Connection Refused
Hello Kevin,
I've got to know what the problem is.
If you are running query with "%drill ...", you can set
drill.url
drill.user
drill.password
If you set default.*, you should use "%jdbc ..."
It's a little bit confused, and it will be improved by 0.7.0.
Hope this help,
Jongyoul
On Thu, Jul 28, 2016 at 7:56 AM, Kevin Verhoeven <Ke...@ds-iq.com>> wrote:
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:jongyoul@gmail.com<ma...@gmail.com>]
Sent: Tuesday, July 12, 2016 10:53 PM
To: users@zeppelin.apache.org<ma...@zeppelin.apache.org>
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 <kr...@flytxt.com>> 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 <jo...@gmail.com>> 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 <kr...@flytxt.com>> 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
--
이종열, Jongyoul Lee, 李宗烈
http://madeng.net
Re: Drill JDBC Interpreter: Connection Refused
Posted by Jongyoul Lee <jo...@gmail.com>.
Hello Kevin,
I've got to know what the problem is.
If you are running query with "%drill ...", you can set
drill.url
drill.user
drill.password
If you set default.*, you should use "%jdbc ..."
It's a little bit confused, and it will be improved by 0.7.0.
Hope this help,
Jongyoul
On Thu, Jul 28, 2016 at 7:56 AM, Kevin Verhoeven <Ke...@ds-iq.com>
wrote:
> 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=my*ServerName*: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:jongyoul@gmail.com]
> *Sent:* Tuesday, July 12, 2016 10:53 PM
> *To:* users@zeppelin.apache.org
> *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 <
> krishna.prasad@flytxt.com> 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 <jo...@gmail.com> 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 <kr...@flytxt.com>
> 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 | O: +91 471.3082753 <%2B91%20471.3082753> | F: +91
> 471.2700202
> 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
>
--
이종열, Jongyoul Lee, 李宗烈
http://madeng.net
RE: Drill JDBC Interpreter: Connection Refused
Posted by Kevin Verhoeven <Ke...@ds-iq.com>.
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:jongyoul@gmail.com]
Sent: Tuesday, July 12, 2016 10:53 PM
To: users@zeppelin.apache.org
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 <kr...@flytxt.com>> 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 <jo...@gmail.com>> 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 <kr...@flytxt.com>> 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
Re: Drill JDBC Interpreter: Connection Refused
Posted by Jongyoul Lee <jo...@gmail.com>.
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 <
krishna.prasad@flytxt.com> 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 <jo...@gmail.com> 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 <kr...@flytxt.com>
>> wrote:
>>
>>> hi,
>>> I'm trying to create a drill interpreter in zeppelin.
>>>
>>> *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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 | O: +91 471.3082753 | F: +91 471.2700202
> 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
Re: Drill JDBC Interpreter: Connection Refused
Posted by Krishnaprasad A S <kr...@flytxt.com>.
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 <jo...@gmail.com> 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 <kr...@flytxt.com>
> wrote:
>
>> hi,
>> I'm trying to create a drill interpreter in zeppelin.
>>
>> *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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 | O: +91 471.3082753 | F: +91 471.2700202
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>
Re: Drill JDBC Interpreter: Connection Refused
Posted by Jongyoul Lee <jo...@gmail.com>.
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 <kr...@flytxt.com>
wrote:
> hi,
> I'm trying to create a drill interpreter in zeppelin.
>
> *drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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
Fwd: Drill JDBC Interpreter: Connection Refused
Posted by Krishnaprasad A S <kr...@flytxt.com>.
hi,
I'm trying to create a drill interpreter in zeppelin.
*drill.url = jdbc:drill:zk=<host>:2181/drill/drillbits1drill.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