Lei Zhiyuan

It maybe an issue of flink classloader ``` Caused by: java.lang.ClassNotFoundException: org.apache.pulsar.shade.io.netty.buffer.PoolArena$1 at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$ChildFirstClassLoader.loadClass(FlinkUserCodeClassLoaders.java:129) ``` if you can debug this , you can print org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$ChildFirstClassLoader ```...

sometimes I can reproduce this in local machine It should be 200*10 I print some log in messagelistener. It seems there has a bug in recent change ``` 2022-08-08T16:57:10,898 -...

org.apache.bookkeeper.mledger.impl.cache.RangeEntryCacheImpl#insert maybe this should return true ,because if entry is in cache , we should release the entry. after changed this , I can not reproduce this issue.

> @leizhiyuan Do you want to create a PR to fix the issue? ok

@johanhaleby thank you,this problem occured in my project..Make TestNG test method 'final' is ok.

yes, you should have a dql, then you can ReconsumeLater the panic maybe not friendly ``` // ReconsumeLater mark a message for redelivery after custom delay ReconsumeLater(msg Message, delay time.Duration)...

you can use ``` consumer, err := client.Subscribe(pulsar.ConsumerOptions{ Topic: "topic-1", SubscriptionName: "my-sub", Type: pulsar.Exclusive, DLQ: &pulsar.DLQPolicy{MaxDeliveries: 1,DeadLetterTopic: "dlq-topic"}, }) ``` to solve this. it is helpful

ci失败了，看看是不是要吧rpc 的snapshot版本发一下。

this will occur in when you shutdown bk exceptionally, maybe oom or kill -9 , ``` 10:15:55.026 [main] ERROR org.apache.bookkeeper.bookie.Bookie - Exception while replaying journals, shutting down java.io.IOException: Invalid record...

> Does the old testcase cover this function, do you need to add a new testcase? done