You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Avi Levi <av...@bluevoyant.com> on 2019/06/30 14:37:21 UTC
Connection refused while trying to query state
Hi,
I am trying to query state (cluster 1.8.0 is running on my local machine) .
I do see in the logs "Started the Queryable State Proxy Server @ ...".
but when I am trying to query the state from the client ,
val descriptor = new ValueStateDescriptor("queryable-state",
Types.CASE_CLASS[State])
client.getKvState(jobId, "seen-domains",key,
BasicTypeInfo.STRING_TYPE_INFO, descriptor)
I am getting the following exception :
[ERROR] [06/30/2019 16:59:48.850]
[bvAkkaHttpServer-akka.actor.default-dispatcher-10]
[akka.actor.ActorSystemImpl(AkkaHttpServer)] Error during processing of
request:
'org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: /127.0.0.1:9069'. Completing with 500 Internal Server
Error response. To change default exception handling behavior, provide a
custom ExceptionHandler.
java.util.concurrent.CompletionException:
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: /127.0.0.1:9069
at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:593)
at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577)
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
at
org.apache.flink.queryablestate.network.Client$PendingConnection.close(Client.java:377)
at
org.apache.flink.queryablestate.network.Client$PendingConnection.operationComplete(Client.java:270)
at
org.apache.flink.queryablestate.network.Client$PendingConnection.operationComplete(Client.java:231)
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:121)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:327)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:343)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
at java.lang.Thread.run(Thread.java:748)
Caused by:
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: /127.0.0.1:9069
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
at
org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:327)
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:340)
... 6 more
Caused by: java.net.ConnectException: Connection refused
... 10 more
Re: Connection refused while trying to query state
Posted by Kostas Kloudas <kk...@gmail.com>.
No problem! Glad I could help.
Kostas
On Tue, Jul 2, 2019 at 12:11 PM Avi Levi <av...@bluevoyant.com> wrote:
> No, it doesn't. Thanks for pointing it. I just noticed that I wasn't using
> the proxy server address.
> Thanks !!!
>
>
> On Tue, Jul 2, 2019 at 12:16 PM Kostas Kloudas <kk...@gmail.com> wrote:
>
>> *This Message originated outside your organization.*
>> ------------------------------
>> Hi Avi,
>>
>> Do you point the client to the correct address? This means where the
>> "Queryable State Proxy Server @ ..." says?
>>
>> Cheers,
>> Kostas
>>
>> On Sun, Jun 30, 2019 at 4:37 PM Avi Levi <av...@bluevoyant.com> wrote:
>>
>>> Hi,
>>> I am trying to query state (cluster 1.8.0 is running on my local
>>> machine) .
>>> I do see in the logs "Started the Queryable State Proxy Server @ ...".
>>>
>>> but when I am trying to query the state from the client ,
>>> val descriptor = new ValueStateDescriptor("queryable-state",
>>> Types.CASE_CLASS[State])
>>> client.getKvState(jobId, "seen-domains",key,
>>> BasicTypeInfo.STRING_TYPE_INFO, descriptor)
>>> I am getting the following exception :
>>>
>>> [ERROR] [06/30/2019 16:59:48.850]
>>> [bvAkkaHttpServer-akka.actor.default-dispatcher-10]
>>> [akka.actor.ActorSystemImpl(AkkaHttpServer)] Error during processing of
>>> request:
>>> 'org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
>>> Connection refused: /127.0.0.1:9069'. Completing with 500 Internal
>>> Server Error response. To change default exception handling behavior,
>>> provide a custom ExceptionHandler.
>>> java.util.concurrent.CompletionException:
>>> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
>>> Connection refused: /127.0.0.1:9069
>>> at
>>> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
>>> at
>>> java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
>>> at
>>> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:593)
>>> at
>>> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577)
>>> at
>>> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
>>> at
>>> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
>>> at
>>> org.apache.flink.queryablestate.network.Client$PendingConnection.close(Client.java:377)
>>> at
>>> org.apache.flink.queryablestate.network.Client$PendingConnection.operationComplete(Client.java:270)
>>> at
>>> org.apache.flink.queryablestate.network.Client$PendingConnection.operationComplete(Client.java:231)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:121)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:327)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:343)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
>>> at java.lang.Thread.run(Thread.java:748)
>>> Caused by:
>>> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
>>> Connection refused: /127.0.0.1:9069
>>> at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>>> at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:327)
>>> at
>>> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:340)
>>> ... 6 more
>>> Caused by: java.net.ConnectException: Connection refused
>>> ... 10 more
>>>
>>>
Re: Connection refused while trying to query state
Posted by Avi Levi <av...@bluevoyant.com>.
No, it doesn't. Thanks for pointing it. I just noticed that I wasn't using
the proxy server address.
Thanks !!!
On Tue, Jul 2, 2019 at 12:16 PM Kostas Kloudas <kk...@gmail.com> wrote:
> *This Message originated outside your organization.*
> ------------------------------
> Hi Avi,
>
> Do you point the client to the correct address? This means where the
> "Queryable State Proxy Server @ ..." says?
>
> Cheers,
> Kostas
>
> On Sun, Jun 30, 2019 at 4:37 PM Avi Levi <av...@bluevoyant.com> wrote:
>
>> Hi,
>> I am trying to query state (cluster 1.8.0 is running on my local machine)
>> .
>> I do see in the logs "Started the Queryable State Proxy Server @ ...".
>>
>> but when I am trying to query the state from the client ,
>> val descriptor = new ValueStateDescriptor("queryable-state",
>> Types.CASE_CLASS[State])
>> client.getKvState(jobId, "seen-domains",key,
>> BasicTypeInfo.STRING_TYPE_INFO, descriptor)
>> I am getting the following exception :
>>
>> [ERROR] [06/30/2019 16:59:48.850]
>> [bvAkkaHttpServer-akka.actor.default-dispatcher-10]
>> [akka.actor.ActorSystemImpl(AkkaHttpServer)] Error during processing of
>> request:
>> 'org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
>> Connection refused: /127.0.0.1:9069
>> <http://127.0.0.1:9069>'.
>> Completing with 500 Internal Server Error response. To change default
>> exception handling behavior, provide a custom ExceptionHandler.
>> java.util.concurrent.CompletionException:
>> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
>> Connection refused: /127.0.0.1:9069
>> <http://127.0.0.1:9069>
>> at
>> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
>> at
>> java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
>> at
>> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:593)
>> at
>> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577)
>> at
>> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
>> at
>> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
>> at
>> org.apache.flink.queryablestate.network.Client$PendingConnection.close(Client.java:377)
>> at
>> org.apache.flink.queryablestate.network.Client$PendingConnection.operationComplete(Client.java:270)
>> at
>> org.apache.flink.queryablestate.network.Client$PendingConnection.operationComplete(Client.java:231)
>> at
>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
>> at
>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
>> at
>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
>> at
>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
>> at
>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:121)
>> at
>> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:327)
>> at
>> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:343)
>> at
>> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
>> at
>> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
>> at
>> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
>> at
>> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
>> at
>> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
>> at java.lang.Thread.run(Thread.java:748)
>> Caused by:
>> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
>> Connection refused: /127.0.0.1:9069
>> <http://127.0.0.1:9069>
>> at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>> at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>> at
>> org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:327)
>> at
>> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:340)
>> ... 6 more
>> Caused by: java.net.ConnectException: Connection refused
>> ... 10 more
>>
>>
Re: Connection refused while trying to query state
Posted by Kostas Kloudas <kk...@gmail.com>.
Hi Avi,
Do you point the client to the correct address? This means where the
"Queryable State Proxy Server @ ..." says?
Cheers,
Kostas
On Sun, Jun 30, 2019 at 4:37 PM Avi Levi <av...@bluevoyant.com> wrote:
> Hi,
> I am trying to query state (cluster 1.8.0 is running on my local machine) .
> I do see in the logs "Started the Queryable State Proxy Server @ ...".
>
> but when I am trying to query the state from the client ,
> val descriptor = new ValueStateDescriptor("queryable-state",
> Types.CASE_CLASS[State])
> client.getKvState(jobId, "seen-domains",key,
> BasicTypeInfo.STRING_TYPE_INFO, descriptor)
> I am getting the following exception :
>
> [ERROR] [06/30/2019 16:59:48.850]
> [bvAkkaHttpServer-akka.actor.default-dispatcher-10]
> [akka.actor.ActorSystemImpl(AkkaHttpServer)] Error during processing of
> request:
> 'org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
> Connection refused: /127.0.0.1:9069'. Completing with 500 Internal Server
> Error response. To change default exception handling behavior, provide a
> custom ExceptionHandler.
> java.util.concurrent.CompletionException:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
> Connection refused: /127.0.0.1:9069
> at
> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
> at
> java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
> at
> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:593)
> at
> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577)
> at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
> at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
> at
> org.apache.flink.queryablestate.network.Client$PendingConnection.close(Client.java:377)
> at
> org.apache.flink.queryablestate.network.Client$PendingConnection.operationComplete(Client.java:270)
> at
> org.apache.flink.queryablestate.network.Client$PendingConnection.operationComplete(Client.java:231)
> at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
> at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
> at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
> at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
> at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:121)
> at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:327)
> at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:343)
> at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
> at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:591)
> at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:508)
> at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:470)
> at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)
> at java.lang.Thread.run(Thread.java:748)
> Caused by:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
> Connection refused: /127.0.0.1:9069
> at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
> at
> org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:327)
> at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:340)
> ... 6 more
> Caused by: java.net.ConnectException: Connection refused
> ... 10 more
>
>