zuzuou opened a new issue, #5212: URL: https://github.com/apache/seatunnel/issues/5212
### 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 When I sink doris from sqlserver with bath mode, the source table had been sink into the doris table, but the seatunnel job not ended. Please let me know if you need any further information.  ### SeaTunnel Version 2.3.1 ### SeaTunnel Config ```conf env { execution.parallelism = 1 job.mode = "BATCH" checkpoint.interval = 10000 } source { Jdbc{ url = "jdbc:sqlserver://10.30.2.84:1433;encrypt=true;trustServerCertificate=true;SelectMethod=cursor;DatabaseName=dotnet_erp60" driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver" connection_check_timeout_sec = 100 user = "dpview" password = "DP###" query = "select REPLACE(REPLACE(REPLACE(REPLACE([BuyerGUID], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [BuyerGUID] , REPLACE(REPLACE(REPLACE(REPLACE([Address], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [Address] , REPLACE(REPLACE(REPLACE(REPLACE([SaleGUID], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [SaleGUID] , REPLACE(REPLACE(REPLACE(REPLACE([CardID], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [CardID] , REPLACE(REPLACE(REPLACE(REPLACE([CstName], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [CstName] , [CreatedTime] , REPLACE(REPLACE(REPLACE(REPLACE([CreatedGUID], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [CreatedGUID] , [ModifiedTime] , REPLACE(REPLACE(REPLACE(REPLACE([ModifiedGUID], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [ModifiedGUID] , NULL AS [VersionNumber] , REPLACE(REPLACE(REPLACE(REPLACE([Tel], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [Tel] , [CstNum] , REPLACE(REPLACE(REPLACE(REPLACE([Corporation], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [Corporation] , REPLACE(REPLACE(REPLACE(REPLACE([BizLicence], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [BizLicence] , REPLACE(REPLACE(REPLACE(REPLACE([CardTypeEnum], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [CardTypeEnum] , REPLACE(REPLACE(REPLACE(REPLACE([Country], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [Country] , REPLACE(REPLACE(REPLACE(REPLACE([City], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [City] , REPLACE(REPLACE(REPLACE(REPLACE([CstGUID], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [CstGUID] , [PropertyRate] , [CstTypeEnum] , REPLACE(REPLACE(REPLACE(REPLACE([AlternativePhone], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [AlternativePhone] , REPLACE(REPLACE (REPLACE(REPLACE([Province], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [Province] , REPLACE(REPLACE(REPLACE(REPLACE([Area], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [Area] , REPLACE(REPLACE(REPLACE(REPLACE([Street], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [Street] , REPLACE(REPLACE(REPLACE(REPLACE([CstType], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [CstType] , REPLACE(REPLACE(REPLACE(REPLACE([CardType], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [CardType] , REPLACE(REPLACE(REPLACE(REPLACE([CreatedName], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [CreatedName] , REPLACE(REPLACE(REPLACE(REPLACE([ModifiedName], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [ModifiedName] , REPLACE(REPLACE(REPLACE(REPLACE([TaxNo], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [TaxNo] , REPLACE(REPLACE(REPLACE(REPLACE([TaxAddTel ], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [TaxAddTel] , REPLACE(REPLACE(REPLACE(REPLACE([TaxBankAcct], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [TaxBankAcct] , REPLACE(REPLACE(REPLACE(REPLACE([OppCstGUID], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [OppCstGUID] , REPLACE(REPLACE(REPLACE(REPLACE([x_SignGUID], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [x_SignGUID] , REPLACE(REPLACE(REPLACE(REPLACE([x_KingDeeSignGUID], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [x_KingDeeSignGUID] , REPLACE(REPLACE(REPLACE(REPLACE([x_PasswordAlternativePhone], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [x_PasswordAlternativePhone] , REPLACE(REPLACE(REPLACE(REPLACE([x_PasswordTel], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [x_PasswordTel] , REPLACE(REPLACE(REPLACE(REPLACE([x_PostCode], CHAR(9), ' '), CHAR(10), ' '), CHAR(13), ' '), CHAR(15), ' ') AS [x_PostCode] , GETDATE() AS _LOAD_TIME_ from [dbo].[s_buyer] WITH(NOLOCK) " } } sink { Doris{ fenodes = "10.129.3.188:8030" username = "etl" password = "@98Ku##" table.identifier = "ods.mys_s_buyer_tmp" sink.enable-2pc = true sink.label-prefix = "ods_mys_s_buyer_tmp_20230803_103931_11" doris.config = { format = "csv" column_separator = "\t" } } } ``` ### Running Command ```shell /app/seatunnel/bin/seatunnel.sh --config /app/ods_new/conf/mys/tmp/ods_mys_s_buyer ``` ### Error Exception ```log 2023-08-03 15:44:04,401 INFO com.hazelcast.spi.impl.operationservice.impl.InvocationMonitor - [10.129.3.56]:5801 [seatunnel-uat] [5.1] Invocations:7 timeouts:1 backup-timeouts:0 2023-08-03 15:44:04,405 WARN org.apache.seatunnel.engine.server.dag.physical.SubPlan - Job SeaTunnel_Job (739385117801185333), Pipeline: [(1/1)] checkpoint have error, cancel the pipeline 2023-08-03 15:44:04,406 WARN com.hazelcast.internal.server.tcp.TcpServerConnection - [10.129.3.56]:5801 [seatunnel-uat] [5.1] Connection[id=31, /10.129.3.56:5801->/10.129.80.27:54075, qualifier=null, endpoint=[10.129.80.27]:5801, remoteUuid=7bf67782-5ea4-4215-9d75-3460670200cd, alive=false, connectionType=MEMBER, planeIndex=0] closed. Reason: Exception in Connection[id=31, /10.129.3.56:5801->/10.129.80.27:54075, qualifier=null, endpoint=[10.129.80.27]:5801, remoteUuid=7bf67782-5ea4-4215-9d75-3460670200cd, alive=true, connectionType=MEMBER, planeIndex=0], thread=checkpoint-coordinator-1/739385117801185333 java.nio.channels.ClosedByInterruptException: null at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:202) ~[?:1.8.0_192] at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:478) ~[?:1.8.0_192] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.flushToSocket(NioOutboundPipeline.java:439) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.process(NioOutboundPipeline.java:324) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.executePipeline(NioOutboundPipeline.java:240) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.internal.networking.nio.NioOutboundPipeline.write(NioOutboundPipeline.java:218) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.internal.networking.nio.NioChannel.write(NioChannel.java:79) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.internal.server.tcp.TcpServerConnection.write(TcpServerConnection.java:222) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OutboundOperationHandler.send(OutboundOperationHandler.java:59) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeRemote(Invocation.java:612) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:582) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:541) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:241) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.InvocationBuilderImpl.invoke(InvocationBuilderImpl.java:61) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.map.impl.proxy.MapProxySupport.invokeOperation(MapProxySupport.java:478) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.map.impl.proxy.MapProxySupport.getInternal(MapProxySupport.java:371) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.map.impl.proxy.MapProxyImpl.get(MapProxyImpl.java:123) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.dag.physical.SubPlan.getPipelineState(SubPlan.java:534) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.dag.physical.SubPlan.cancelPipeline(SubPlan.java:353) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.dag.physical.SubPlan.handleCheckpointError(SubPlan.java:555) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.master.JobMaster.lambda$handleCheckpointError$2(JobMaster.java:328) ~[seatunnel-starter.jar:2.3.1] at java.util.ArrayList.forEach(ArrayList.java:1257) ~[?:1.8.0_192] at org.apache.seatunnel.engine.server.master.JobMaster.handleCheckpointError(JobMaster.java:325) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.handleCheckpointError(CheckpointManager.java:175) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.handleCoordinatorError(CheckpointCoordinator.java:221) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.lambda$null$9(CheckpointCoordinator.java:436) ~[seatunnel-starter.jar:2.3.1] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_192] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_192] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) ~[?:1.8.0_192] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) ~[?:1.8.0_192] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_192] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_192] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_192] 2023-08-03 15:44:04,410 INFO com.hazelcast.internal.server.tcp.TcpServerConnection - [10.129.3.56]:5801 [seatunnel-uat] [5.1] Initialized new cluster connection between /10.129.3.56:5801 and /10.129.80.27:52640 2023-08-03 15:44:54,154 INFO org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSourceReader - Closed the bounded jdbc source 2023-08-03 15:44:54,164 ERROR org.apache.seatunnel.engine.server.checkpoint.operation.TaskAcknowledgeOperation - [10.129.3.56]:5801 [seatunnel-uat] [5.1] null java.lang.NullPointerException: null at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.acknowledgeTask(CheckpointCoordinator.java:584) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.acknowledgeTask(CheckpointManager.java:261) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.checkpoint.operation.TaskAcknowledgeOperation.run(TaskAcknowledgeOperation.java:81) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.run(OperationExecutorImpl.java:411) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.runOrExecute(OperationExecutorImpl.java:438) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeLocal(Invocation.java:601) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:580) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:541) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:241) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.InvocationBuilderImpl.invoke(InvocationBuilderImpl.java:61) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.utils.NodeEngineUtil.sendOperationToMasterNode(NodeEngineUtil.java:41) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.execution.TaskExecutionContext.sendToMaster(TaskExecutionContext.java:43) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.ack(SeaTunnelTask.java:335) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:67) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.received(IntermediateBlockingQueue.java:39) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:46) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:28) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.sendRecordToNext(SeaTunnelSourceCollector.java:72) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.triggerBarrier(SourceFlowLifeCycle.java:223) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.triggerBarrier(SourceSeaTunnelTask.java:101) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.operation.checkpoint.BarrierFlowOperation.lambda$run$0(BarrierFlowOperation.java:85) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.common.utils.RetryUtils.retryWithException(RetryUtils.java:48) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.operation.checkpoint.BarrierFlowOperation.run(BarrierFlowOperation.java:76) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:471) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:197) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:137) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) ~[seatunnel-starter.jar:2.3.1] 2023-08-03 15:44:54,167 INFO org.apache.seatunnel.connectors.doris.sink.writer.DorisStreamLoad - stream load stopped. 2023-08-03 15:44:54,168 ERROR org.apache.seatunnel.engine.server.checkpoint.operation.TaskAcknowledgeOperation - [10.129.3.56]:5801 [seatunnel-uat] [5.1] null java.lang.NullPointerException: null at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.acknowledgeTask(CheckpointCoordinator.java:584) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.acknowledgeTask(CheckpointManager.java:261) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.checkpoint.operation.TaskAcknowledgeOperation.run(TaskAcknowledgeOperation.java:81) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.run(OperationExecutorImpl.java:411) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl.runOrExecute(OperationExecutorImpl.java:438) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvokeLocal(Invocation.java:601) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.doInvoke(Invocation.java:580) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke0(Invocation.java:541) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.Invocation.invoke(Invocation.java:241) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.InvocationBuilderImpl.invoke(InvocationBuilderImpl.java:61) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.utils.NodeEngineUtil.sendOperationToMasterNode(NodeEngineUtil.java:41) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.execution.TaskExecutionContext.sendToMaster(TaskExecutionContext.java:43) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.SeaTunnelTask.ack(SeaTunnelTask.java:335) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.handleRecord(IntermediateBlockingQueue.java:67) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.group.queue.IntermediateBlockingQueue.received(IntermediateBlockingQueue.java:39) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:46) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.flow.IntermediateQueueFlowLifeCycle.received(IntermediateQueueFlowLifeCycle.java:28) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.SeaTunnelSourceCollector.sendRecordToNext(SeaTunnelSourceCollector.java:72) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.triggerBarrier(SourceFlowLifeCycle.java:223) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.triggerBarrier(SourceSeaTunnelTask.java:101) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.operation.checkpoint.BarrierFlowOperation.lambda$run$0(BarrierFlowOperation.java:85) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.common.utils.RetryUtils.retryWithException(RetryUtils.java:48) ~[seatunnel-starter.jar:2.3.1] at org.apache.seatunnel.engine.server.task.operation.checkpoint.BarrierFlowOperation.run(BarrierFlowOperation.java:76) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:471) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:197) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:137) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123) ~[seatunnel-starter.jar:2.3.1] at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) ~[seatunnel-starter.jar:2.3.1] ``` ### Zeta or Flink or Spark Version zeta ### Java or Scala Version jdk-11.0.18 ### 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]
