YalikWang opened a new issue, #6645: URL: https://github.com/apache/seatunnel/issues/6645
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened The stack information of threadInterruptedException will be printed on the console, which can be confusing for developers and users who are just getting started with seatunnel rocketmq. Although this error will not affect data reading and processing, it does bring unnecessary Rpc call overhead. ### SeaTunnel Version 2.3.4 ### SeaTunnel Config ```conf env { parallelism = 8 job.mode = "STREAMING" checkpoint.interval = 2000 } source { Rocketmq { topics = "seatunnel-test-topic" name.srv.addr = "xx.xx.xx.xxx:9876" acl.enabled = true access.key = "xxx" secret.key = "xxx" result_table_name = "rocketmq-table" } } transform { } sink { console { source_table_name="rocketmq-table" } } ``` ### Running Command ```shell bin/seatunnel.sh --config config/rocketmq_to_console.config -e local ``` ### Error Exception ```log 2024-04-03 23:25:31,569 WARN RocketmqRemoting - receive response, but not matched any request, **.***.***.***:10911 2024-04-03 23:25:31,569 WARN RocketmqRemoting - RemotingCommand [code=0, language=JAVA, version=453, opaque=31, flag(B)=1, remark=FOUND, extFields={suggestWhichBrokerId=0, groupSysFlag=0, nextBeginOffset=63, maxOffset=2500, minOffset=0, topicSysFlag=0}, serializeTypeCurrentRPC=JSON] 2024-04-03 23:25:31,563 WARN RocketmqClient - Polling thread was interrupted. java.lang.InterruptedException: null at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1039) ~[?:1.8.0_191] at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) ~[?:1.8.0_191] at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:277) ~[?:1.8.0_191] at org.apache.rocketmq.remoting.netty.ResponseFuture.waitResponse(ResponseFuture.java:71) ~[rocketmq-remoting-4.9.4.jar:4.9.4] at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.invokeSyncImpl(NettyRemotingAbstract.java:435) ~[rocketmq-remoting-4.9.4.jar:4.9.4] at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:390) ~[rocketmq-remoting-4.9.4.jar:4.9.4] at org.apache.rocketmq.client.impl.MQClientAPIImpl.pullMessageSync(MQClientAPIImpl.java:779) ~[rocketmq-client-4.9.4.jar:4.9.4] at org.apache.rocketmq.client.impl.MQClientAPIImpl.pullMessage(MQClientAPIImpl.java:733) ~[rocketmq-client-4.9.4.jar:4.9.4] at org.apache.rocketmq.client.impl.consumer.PullAPIWrapper.pullKernelImpl(PullAPIWrapper.java:200) ~[rocketmq-client-4.9.4.jar:4.9.4] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.pullSyncImpl(DefaultLitePullConsumerImpl.java:930) ~[rocketmq-client-4.9.4.jar:4.9.4] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.pull(DefaultLitePullConsumerImpl.java:905) ~[rocketmq-client-4.9.4.jar:4.9.4] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.pull(DefaultLitePullConsumerImpl.java:900) ~[rocketmq-client-4.9.4.jar:4.9.4] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.access$1400(DefaultLitePullConsumerImpl.java:77) ~[rocketmq-client-4.9.4.jar:4.9.4] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl$PullTaskImpl.run(DefaultLitePullConsumerImpl.java:849) [rocketmq-client-4.9.4.jar:4.9.4] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_191] at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266) [?:1.8.0_191] at java.util.concurrent.FutureTask.run(FutureTask.java) [?:1.8.0_191] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_191] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_191] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_191] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191] 2024-04-03 23:25:31,576 WARN RocketmqClient - The Pull Task is cancelled after doPullTask, MessageQueue [topic=seatunnel-test-topic, brokerName=rfid-cloud-01, queueId=0] ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version 1.8 ### Screenshots _No response_ ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- 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]
