lhotari commented on issue #10097:
URL: https://github.com/apache/pulsar/issues/10097#issuecomment-810997397


   After fixing the exception in the description with #10098 changes, a new 
issue appears:
   ```
   11:38:04.969 [broker-topic-workers-OrderedScheduler-3-0] ERROR 
org.apache.bookkeeper.common.util.SafeRunnable - Unexpected throwable caught
   io.netty.util.IllegalReferenceCountException: refCnt: 0
   at 
io.netty.buffer.AbstractByteBuf.ensureAccessible(AbstractByteBuf.java:1454) 
~[io.netty-netty-buffer-4.1.60.Final.jar:4.1.60.Final]
   at io.netty.buffer.AbstractByteBuf.checkIndex(AbstractByteBuf.java:1383) 
~[io.netty-netty-buffer-4.1.60.Final.jar:4.1.60.Final]
   at io.netty.buffer.UnsafeByteBufUtil.getBytes(UnsafeByteBufUtil.java:481) 
~[io.netty-netty-buffer-4.1.60.Final.jar:4.1.60.Final]
   at 
io.netty.buffer.PooledUnsafeDirectByteBuf.getBytes(PooledUnsafeDirectByteBuf.java:130)
 ~[io.netty-netty-buffer-4.1.60.Final.jar:4.1.60.Final]
   at 
io.netty.buffer.AbstractUnpooledSlicedByteBuf.getBytes(AbstractUnpooledSlicedByteBuf.java:243)
 ~[io.netty-netty-buffer-4.1.60.Final.jar:4.1.60.Final]
   at io.netty.buffer.ByteBufUtil.decodeString(ByteBufUtil.java:1147) 
~[io.netty-netty-buffer-4.1.60.Final.jar:4.1.60.Final]
   at io.netty.buffer.AbstractByteBuf.toString(AbstractByteBuf.java:1246) 
~[io.netty-netty-buffer-4.1.60.Final.jar:4.1.60.Final]
   at 
org.apache.pulsar.common.api.proto.LightProtoCodec.readString(LightProtoCodec.java:250)
 ~[org.apache.pulsar-pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
   at 
org.apache.pulsar.common.api.proto.ClusterMessageId.getCluster(ClusterMessageId.java:19)
 ~[org.apache.pulsar-pulsar-common-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
   at 
org.apache.pulsar.broker.service.persistent.ReplicatedSubscriptionsController.localSubscriptionUpdated(ReplicatedSubscriptionsController.java:116)
 ~[org.apache.pulsar-pulsar-broker-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
   at 
org.apache.pulsar.broker.service.persistent.PersistentSubscription.lambda$acknowledgeMessage$8(PersistentSubscription.java:358)
 ~[org.apache.pulsar-pulsar-broker-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
   at java.util.Optional.ifPresent(Optional.java:159) ~[?:1.8.0_282]
   at 
org.apache.pulsar.broker.service.persistent.PersistentSubscription.acknowledgeMessage(PersistentSubscription.java:358)
 ~[org.apache.pulsar-pulsar-broker-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
   at 
org.apache.pulsar.broker.service.AbstractBaseDispatcher.filterEntriesForConsumer(AbstractBaseDispatcher.java:114)
 ~[org.apache.pulsar-pulsar-broker-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
   at 
org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer.internalReadEntriesComplete(PersistentDispatcherSingleActiveConsumer.java:200)
 ~[org.apache.pulsar-pulsar-broker-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
   at 
org.apache.pulsar.broker.service.persistent.PersistentDispatcherSingleActiveConsumer.lambda$readEntriesComplete$1(PersistentDispatcherSingleActiveConsumer.java:146)
 ~[org.apache.pulsar-pulsar-broker-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
   at org.apache.bookkeeper.mledger.util.SafeRun$1.safeRun(SafeRun.java:32) 
~[org.apache.pulsar-managed-ledger-2.8.0-SNAPSHOT.jar:2.8.0-SNAPSHOT]
   at org.apache.bookkeeper.common.util.SafeRunnable.run(SafeRunnable.java:36) 
[org.apache.bookkeeper-bookkeeper-common-4.13.0.jar:4.13.0]
   at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) 
[?:1.8.0_282]
   at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_282]
   at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
 [?:1.8.0_282]
   at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
 [?:1.8.0_282]
   at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
[?:1.8.0_282]
   at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
[?:1.8.0_282]
   at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 [io.netty-netty-common-4.1.60.Final.jar:4.1.60.Final]
   at java.lang.Thread.run(Thread.java:748) [?:1.8.0_282]
   ```


-- 
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.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to