JackrayWang commented on issue #14592:
URL: https://github.com/apache/pulsar/issues/14592#issuecomment-1061348244
function log is as follows.
```
No such ledger exists on Metadata Server - ledger=239 - operation=Failed
to open ledger","reqId":2327396040063173539,
"remote":"192.168.228.107/192.168.228.107:6650",
"local":"/192.168.228.107:36150"}
java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
{"errorMsg":"org.apache.pulsar.broker.service.schema.exceptions.SchemaException:
No such ledger exists on Metadata Server - ledger=239 - operation=Failed to
open ledger","reqId":2327396040063173539,
"remote":"192.168.228.107/192.168.228.107:6650",
"local":"/192.168.228.107:36150"}
at
java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:367)
~[?:?]
at
java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:376)
~[?:?]
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1074)
~[?:?]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
[?:?]
at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
[?:?]
at
org.apache.pulsar.client.impl.ClientCnx.handleGetSchemaResponse(ClientCnx.java:827)
[org.apache.pulsar-pulsar-client-original-2.9.1.jar:2.9.1]
at
org.apache.pulsar.common.protocol.PulsarDecoder.channelRead(PulsarDecoder.java:335)
[org.apache.pulsar-pulsar-common-2.9.1.jar:2.9.1]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)
[io.netty-netty-codec-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)
[io.netty-netty-codec-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:795)
[io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:480)
[io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:4.1.72.Final]
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378)
[io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
[io.netty-netty-common-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
[io.netty-netty-common-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
[io.netty-netty-common-4.1.72.Final.jar:4.1.72.Final]
at java.lang.Thread.run(Thread.java:834) [?:?]
Caused by: org.apache.pulsar.client.api.PulsarClientException:
{"errorMsg":"org.apache.pulsar.broker.service.schema.exceptions.SchemaException:
No such ledger exists on Metadata Server - ledger=239 - operation=Failed to
open ledger","reqId":2327396040063173539,
"remote":"192.168.228.107/192.168.228.107:6650",
"local":"/192.168.228.107:36150"}
at
org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:1177)
~[org.apache.pulsar-pulsar-client-original-2.9.1.jar:2.9.1]
at
org.apache.pulsar.client.impl.ClientCnx.lambda$sendGetSchema$11(ClientCnx.java:908)
~[org.apache.pulsar-pulsar-client-original-2.9.1.jar:2.9.1]
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1072)
~[?:?]
... 23 more
2022-03-08T10:39:46,064+0800 [public/default/elasticsearch-test-sink-0]
ERROR org.apache.pulsar.functions.instance.JavaInstanceRunnable - Source open
produced uncaught exception:
java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
{"errorMsg":"org.apache.pulsar.broker.service.schema.exceptions.SchemaException:
No such ledger exists on Metadata Server - ledger=239 - operation=Failed to
open ledger","reqId":2327396040063173539,
"remote":"192.168.228.107/192.168.228.107:6650",
"local":"/192.168.228.107:36150"}
at
java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:367)
~[?:?]
at
java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:376)
~[?:?]
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1074)
~[?:?]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
~[?:?]
at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
~[?:?]
at
org.apache.pulsar.client.impl.ClientCnx.handleGetSchemaResponse(ClientCnx.java:827)
~[org.apache.pulsar-pulsar-client-original-2.9.1.jar:2.9.1]
at
org.apache.pulsar.common.protocol.PulsarDecoder.channelRead(PulsarDecoder.java:335)
~[org.apache.pulsar-pulsar-common-2.9.1.jar:2.9.1]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)
~[io.netty-netty-codec-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)
~[io.netty-netty-codec-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:795)
~[io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:480)
~[io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:4.1.72.Final]
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378)
~[io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
~[io.netty-netty-common-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
~[io.netty-netty-common-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
~[io.netty-netty-common-4.1.72.Final.jar:4.1.72.Final]
at java.lang.Thread.run(Thread.java:834) [?:?]
Caused by: org.apache.pulsar.client.api.PulsarClientException:
{"errorMsg":"org.apache.pulsar.broker.service.schema.exceptions.SchemaException:
No such ledger exists on Metadata Server - ledger=239 - operation=Failed to
open ledger","reqId":2327396040063173539,
"remote":"192.168.228.107/192.168.228.107:6650",
"local":"/192.168.228.107:36150"}
at
org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:1177)
~[org.apache.pulsar-pulsar-client-original-2.9.1.jar:2.9.1]
at
org.apache.pulsar.client.impl.ClientCnx.lambda$sendGetSchema$11(ClientCnx.java:908)
~[org.apache.pulsar-pulsar-client-original-2.9.1.jar:2.9.1]
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1072)
~[?:?]
... 23 more
2022-03-08T10:39:46,065+0800 [public/default/elasticsearch-test-sink-0]
ERROR org.apache.pulsar.functions.instance.JavaInstanceRunnable -
[public/default/elasticsearch-test-sink:0] Uncaught exception in Java Instance
java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
{"errorMsg":"org.apache.pulsar.broker.service.schema.exceptions.SchemaException:
No such ledger exists on Metadata Server - ledger=239 - operation=Failed to
open ledger","reqId":2327396040063173539,
"remote":"192.168.228.107/192.168.228.107:6650",
"local":"/192.168.228.107:36150"}
at
java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:367)
~[?:?]
at
java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:376)
~[?:?]
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1074)
~[?:?]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
~[?:?]
at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
~[?:?]
at
org.apache.pulsar.client.impl.ClientCnx.handleGetSchemaResponse(ClientCnx.java:827)
~[org.apache.pulsar-pulsar-client-original-2.9.1.jar:2.9.1]
at
org.apache.pulsar.common.protocol.PulsarDecoder.channelRead(PulsarDecoder.java:335)
~[org.apache.pulsar-pulsar-common-2.9.1.jar:2.9.1]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324)
~[io.netty-netty-codec-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296)
~[io.netty-netty-codec-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
~[io.netty-netty-transport-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:795)
~[io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:480)
~[io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:4.1.72.Final]
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378)
~[io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
~[io.netty-netty-common-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
~[io.netty-netty-common-4.1.72.Final.jar:4.1.72.Final]
at
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
~[io.netty-netty-common-4.1.72.Final.jar:4.1.72.Final]
at java.lang.Thread.run(Thread.java:834) [?:?]
Caused by: org.apache.pulsar.client.api.PulsarClientException:
{"errorMsg":"org.apache.pulsar.broker.service.schema.exceptions.SchemaException:
No such ledger exists on Metadata Server - ledger=239 - operation=Failed to
open ledger","reqId":2327396040063173539,
"remote":"192.168.228.107/192.168.228.107:6650",
"local":"/192.168.228.107:36150"}
at
org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:1177)
~[org.apache.pulsar-pulsar-client-original-2.9.1.jar:2.9.1]
at
org.apache.pulsar.client.impl.ClientCnx.lambda$sendGetSchema$11(ClientCnx.java:908)
~[org.apache.pulsar-pulsar-client-original-2.9.1.jar:2.9.1]
at
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1072)
~[?:?]
... 23 more
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
