Frequently unable to make a JDBC connection oadd.org.apache.drill.exec.rpc.RpcException: Future failed

[the6campbells <th...@gmail.com>]

Have installed Apache Drill 1.4.0 onto two Windows 2012 server (A)  and
Windows 2008 R2 server(B).
Drill bit running on (A) and (B)
Zookeeper running on (B)
Drill browser UI shows both bits as initialized etc

Am able to use SQLSquirrel 3.7 on machine (A) where the URL references
zookeeper on (B)
Am unable to use SQLSquirrel on machine (B) using the same URL

Unable to make connections from other machines (Windows 7 Pro) in the
network using SQLSquirrel or simple program
Have explicitly defined firewall rules on both (A) and (B) for the ports
Drill uses

Simple Java programs can also experience similar problems where the
following exception is thrown and the program is blocked.

Similar problem trying to use a URL to a drillbit versus zookeeper style of
URL.


zookeeper style URL fails as shown

WARNING: An exception was thrown by
oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete()
oadd.org.apache.drill.exec.rpc.RpcException: Future failed
at oadd.org.apache.drill.exec.rpc.RpcException.<init>(RpcException.java:46)
at
oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete(CoordinationQueue.java:87)
at
oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete(CoordinationQueue.java:67)
at
oadd.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680)
at
oadd.io.netty.util.concurrent.DefaultPromise.notifyLateListener(DefaultPromise.java:621)
at
oadd.io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:138)
at
oadd.io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:93)
at
oadd.io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:28)
at oadd.org.apache.drill.exec.rpc.RpcBus.send(RpcBus.java:128)
at
oadd.org.apache.drill.exec.rpc.BasicClient$ConnectionMultiListener$ConnectionHandler.operationComplete(BasicClient.java:220)
at
oadd.org.apache.drill.exec.rpc.BasicClient$ConnectionMultiListener$ConnectionHandler.operationComplete(BasicClient.java:200)
at
oadd.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680)
at
oadd.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:603)
at
oadd.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:563)
at
oadd.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:406)
at
oadd.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:82)
at
oadd.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:247)
at
oadd.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:282)
at
oadd.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:528)
at
oadd.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
at
oadd.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
at oadd.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
at
oadd.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
at java.lang.Thread.run(Thread.java:780)

drillbit style

Feb 08, 2016 9:12:03 AM oadd.io.netty.util.concurrent.DefaultPromise
notifyListener0
WARNING: An exception was thrown by
oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete()
oadd.org.apache.drill.exec.rpc.RpcException: Future failed
at
oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete(CoordinationQueue.java:87)
at
oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete(CoordinationQueue.java:67)
at
oadd.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680)
at
oadd.io.netty.util.concurrent.DefaultPromise.notifyLateListener(DefaultPromise.java:621)
at
oadd.io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:138)
at
oadd.io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:93)
at
oadd.io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:28)
at oadd.org.apache.drill.exec.rpc.RpcBus.send(RpcBus.java:128)
at
oadd.org.apache.drill.exec.rpc.BasicClient$ConnectionMultiListener$ConnectionHandler.operationComplete(BasicClient.java:220)
at
oadd.org.apache.drill.exec.rpc.BasicClient$ConnectionMultiListener$ConnectionHandler.operationComplete(BasicClient.java:200)
at
oadd.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680)
at
oadd.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:603)
at
oadd.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:563)
at
oadd.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:406)
at
oadd.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:82)
at
oadd.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:247)
at
oadd.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:282)
at
oadd.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:528)
at
oadd.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
at
oadd.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
at oadd.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
at
oadd.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
at java.lang.Thread.run(Thread.java:780)

Re: Frequently unable to make a JDBC connection oadd.org.apache.drill.exec.rpc.RpcException: Future failed

[Andries Engelbrecht <ae...@maprtech.com>]

Check DNS (or hosts file) on all machines, including clients and servers to make sure the hostnames of A & B are resolved properly.
Also check that all ports used are open, 2181 or 5181 for ZK, 8047 for WebUI and 31010 for Drill client connections, ICMP also needs to work.

Are both A & B connected to ZK for the Drill cluster and does the WebUI work to both A & B? 31011 and 31012 for Drill internal cluster.

I recommend to start with double checking the network and ZK cluster config first.

What URLs are you using? And what does the drill-override.con look like?

--Andries


> On Feb 8, 2016, at 6:16 AM, the6campbells <th...@gmail.com> wrote:
> 
> Have installed Apache Drill 1.4.0 onto two Windows 2012 server (A)  and
> Windows 2008 R2 server(B).
> Drill bit running on (A) and (B)
> Zookeeper running on (B)
> Drill browser UI shows both bits as initialized etc
> 
> Am able to use SQLSquirrel 3.7 on machine (A) where the URL references
> zookeeper on (B)
> Am unable to use SQLSquirrel on machine (B) using the same URL
> 
> Unable to make connections from other machines (Windows 7 Pro) in the
> network using SQLSquirrel or simple program
> Have explicitly defined firewall rules on both (A) and (B) for the ports
> Drill uses
> 
> Simple Java programs can also experience similar problems where the
> following exception is thrown and the program is blocked.
> 
> Similar problem trying to use a URL to a drillbit versus zookeeper style of
> URL.
> 
> 
> zookeeper style URL fails as shown
> 
> WARNING: An exception was thrown by
> oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete()
> oadd.org.apache.drill.exec.rpc.RpcException: Future failed
> at oadd.org.apache.drill.exec.rpc.RpcException.<init>(RpcException.java:46)
> at
> oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete(CoordinationQueue.java:87)
> at
> oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete(CoordinationQueue.java:67)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.notifyLateListener(DefaultPromise.java:621)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:138)
> at
> oadd.io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:93)
> at
> oadd.io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:28)
> at oadd.org.apache.drill.exec.rpc.RpcBus.send(RpcBus.java:128)
> at
> oadd.org.apache.drill.exec.rpc.BasicClient$ConnectionMultiListener$ConnectionHandler.operationComplete(BasicClient.java:220)
> at
> oadd.org.apache.drill.exec.rpc.BasicClient$ConnectionMultiListener$ConnectionHandler.operationComplete(BasicClient.java:200)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:603)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:563)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:406)
> at
> oadd.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:82)
> at
> oadd.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:247)
> at
> oadd.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:282)
> at
> oadd.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:528)
> at
> oadd.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
> at
> oadd.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
> at oadd.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
> at
> oadd.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:780)
> 
> drillbit style
> 
> Feb 08, 2016 9:12:03 AM oadd.io.netty.util.concurrent.DefaultPromise
> notifyListener0
> WARNING: An exception was thrown by
> oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete()
> oadd.org.apache.drill.exec.rpc.RpcException: Future failed
> at
> oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete(CoordinationQueue.java:87)
> at
> oadd.org.apache.drill.exec.rpc.CoordinationQueue$RpcListener.operationComplete(CoordinationQueue.java:67)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.notifyLateListener(DefaultPromise.java:621)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:138)
> at
> oadd.io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:93)
> at
> oadd.io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:28)
> at oadd.org.apache.drill.exec.rpc.RpcBus.send(RpcBus.java:128)
> at
> oadd.org.apache.drill.exec.rpc.BasicClient$ConnectionMultiListener$ConnectionHandler.operationComplete(BasicClient.java:220)
> at
> oadd.org.apache.drill.exec.rpc.BasicClient$ConnectionMultiListener$ConnectionHandler.operationComplete(BasicClient.java:200)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:680)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:603)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:563)
> at
> oadd.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:406)
> at
> oadd.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:82)
> at
> oadd.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:247)
> at
> oadd.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:282)
> at
> oadd.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:528)
> at
> oadd.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
> at
> oadd.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
> at oadd.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
> at
> oadd.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:780)