CheneyYin opened a new issue, #5342: URL: https://github.com/apache/seatunnel/issues/5342
### 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 During the execution of CI, `connector-seatunnel-e2e-base` will fail randomly. ### SeaTunnel Version dev ### SeaTunnel Config ```conf no ``` ### Running Command ```shell no ``` ### Error Exception ```log 2023-08-21T02:16:53.0373169Z 2023-08-21 02:16:53,036 WARN com.hazelcast.internal.cluster.impl.MembershipManager - [localhost]:5802 [runner_ClusterFaultToleranceTwoPipelineIT_testTwoPipelineStreamJobRunOkIn2Node] [5.1] Member [localhost]:5801 - 5f743673-55a3-48ea-b818-24621eb949f0 is suspected to be dead for reason: No connection 2023-08-21T02:16:53.0375353Z 2023-08-21 02:16:53,037 WARN org.apache.seatunnel.engine.server.SeaTunnelServer - This is master node, waiting the coordinator service init finished 2023-08-21T02:16:54.0387664Z 2023-08-21 02:16:54,037 ERROR org.apache.seatunnel.engine.server.SeaTunnelServer - Error when handle member removed event 2023-08-21T02:16:54.0389152Z org.apache.seatunnel.engine.common.exception.SeaTunnelEngineException: cluster have no master node 2023-08-21T02:16:54.0390933Z at org.apache.seatunnel.engine.server.SeaTunnelServer.isMasterNode(SeaTunnelServer.java:243) ~[seatunnel-engine-server-2.3.3-SNAPSHOT-2.11.12.jar:2.3.3-SNAPSHOT] 2023-08-21T02:16:54.0392376Z at org.apache.seatunnel.engine.server.SeaTunnelServer.getCoordinatorService(SeaTunnelServer.java:183) ~[seatunnel-engine-server-2.3.3-SNAPSHOT-2.11.12.jar:2.3.3-SNAPSHOT] 2023-08-21T02:16:54.0394174Z at org.apache.seatunnel.engine.server.SeaTunnelServer.memberRemoved(SeaTunnelServer.java:141) ~[seatunnel-engine-server-2.3.3-SNAPSHOT-2.11.12.jar:2.3.3-SNAPSHOT] 2023-08-21T02:16:54.0396045Z at com.hazelcast.internal.cluster.impl.MembershipManager.lambda$sendMembershipEventNotifications$2(MembershipManager.java:835) ~[hazelcast-5.1.jar:5.1] 2023-08-21T02:16:54.0397178Z at com.hazelcast.internal.util.executor.CachedExecutorServiceDelegate$Worker.run(CachedExecutorServiceDelegate.java:217) [hazelcast-5.1.jar:5.1] 2023-08-21T02:16:54.0397840Z at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_382] 2023-08-21T02:16:54.0399902Z at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_382] 2023-08-21T02:16:54.0400367Z at java.lang.Thread.run(Thread.java:750) [?:1.8.0_382] 2023-08-21T02:16:54.0401428Z at com.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76) [hazelcast-5.1.jar:5.1] 2023-08-21T02:16:54.0402764Z at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) [hazelcast-5.1.jar:5.1] 2023-08-21T02:16:54.0405330Z Caused by: java.lang.NullPointerException 2023-08-21T02:16:54.0406171Z at org.apache.seatunnel.engine.server.SeaTunnelServer.lambda$isMasterNode$0(SeaTunnelServer.java:233) ~[seatunnel-engine-server-2.3.3-SNAPSHOT-2.11.12.jar:2.3.3-SNAPSHOT] 2023-08-21T02:16:54.0407258Z at org.apache.seatunnel.common.utils.RetryUtils.retryWithException(RetryUtils.java:48) ~[seatunnel-common-2.3.3-SNAPSHOT-2.11.12.jar:2.3.3-SNAPSHOT] 2023-08-21T02:16:54.0408701Z at org.apache.seatunnel.engine.server.SeaTunnelServer.isMasterNode(SeaTunnelServer.java:232) ~[seatunnel-engine-server-2.3.3-SNAPSHOT-2.11.12.jar:2.3.3-SNAPSHOT] 2023-08-21T02:16:54.0409291Z ... 9 more 2023-08-21T02:16:54.0415058Z ##[error]Exception in thread "hz.zen_poitras.cached.thread-5" java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@955e3e8 rejected from com.hazelcast.internal.util.executor.LoggingScheduledExecutor@1f8677e3[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 522] 2023-08-21T02:16:54.0420308Z at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063) 2023-08-21T02:16:54.0421092Z at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830) 2023-08-21T02:16:54.0421722Z at java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:326) 2023-08-21T02:16:54.0422425Z at java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533) 2023-08-21T02:16:54.0423453Z at com.hazelcast.spi.impl.executionservice.impl.DelegatingTaskScheduler.schedule(DelegatingTaskScheduler.java:49) 2023-08-21T02:16:54.0424310Z at com.hazelcast.spi.impl.executionservice.impl.ExecutionServiceImpl.schedule(ExecutionServiceImpl.java:270) 2023-08-21T02:16:54.0425134Z at com.hazelcast.internal.crdt.CRDTReplicationMigrationService.scheduleMigrationTask(CRDTReplicationMigrationService.java:256) 2023-08-21T02:16:54.0425996Z at com.hazelcast.internal.crdt.CRDTReplicationMigrationService.memberRemoved(CRDTReplicationMigrationService.java:245) 2023-08-21T02:16:54.0426769Z at com.hazelcast.internal.cluster.impl.MembershipManager.lambda$sendMembershipEventNotifications$2(MembershipManager.java:835) 2023-08-21T02:16:54.0427526Z at com.hazelcast.internal.util.executor.CachedExecutorServiceDelegate$Worker.run(CachedExecutorServiceDelegate.java:217) 2023-08-21T02:16:54.0428186Z at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 2023-08-21T02:16:54.0428729Z at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 2023-08-21T02:16:54.0429141Z at java.lang.Thread.run(Thread.java:750) 2023-08-21T02:16:54.0429671Z at com.hazelcast.internal.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76) 2023-08-21T02:16:54.0430740Z at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) 2023-08-21T02:16:54.1007603Z [ERROR] Tests run: 7, Failures: 0, Errors: 1, Skipped: 1, Time elapsed: 223.538 s <<< FAILURE! - in org.apache.seatunnel.engine.e2e.ClusterFaultToleranceTwoPipelineIT 2023-08-21T02:16:54.1015282Z Aug 21, 2023 2:16:54 AM com.hazelcast.internal.config.AbstractConfigLocator 2023-08-21T02:16:54.1015888Z [ERROR] testTwoPipelineStreamJobRestoreIn2NodeMasterDown Time elapsed: 76.027 s <<< ERROR! 2023-08-21T02:16:54.1018047Z INFO: Loading 'seatunnel.yaml' from the classpath. 2023-08-21T02:16:54.1018738Z java.lang.NullPointerException 2023-08-21T02:16:54.1019732Z at org.apache.seatunnel.engine.e2e.ClusterFaultToleranceTwoPipelineIT.lambda$testTwoPipelineStreamJobRestoreIn2NodeMasterDown$18(ClusterFaultToleranceTwoPipelineIT.java:736) 2023-08-21T02:16:54.1020420Z 2023-08-21T02:16:54.1020701Z [INFO] Running org.apache.seatunnel.engine.e2e.ClusterIT ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] 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]
