xiaohundun opened a new issue, #7369: URL: https://github.com/apache/seatunnel/issues/7369
### 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 Cancelled 323 tasks, only 24 were successfully cancelled; the rest remain in Cancelling state. **Deploy SeaTunnel Engine In Separated Cluster Mode** ### SeaTunnel Version 2.3.6 ### SeaTunnel Config ```conf A configuration for a task that failed to stop： { "env": { "job.name": "gemini_dbo_API_Sales_Detail", "job.mode": "STREAMING", "parallelism": 1, "checkpoint.interval": 300000 }, "source": [ { "plugin_name": "SqlServer-CDC", "exactly_once": "true", "result_table_name": "gemini_dbo_API_Sales_Detail", "username": "cdc", "password": "q4^9!85vxFEb", "startup.mode": "latest", "database-names": ["gemini"], "table-names": ["gemini.dbo.API_Sales_Detail"], "table-names-config": [ { "table": "gemini_dbo_API_Sales_Detail", "primaryKeys": ["id"] } ], "base-url": "jdbc:sqlserver://172.16.2.3:1433;encrypt=true;trustServerCertificate=true;databaseName=gemini;" } ], "sink": [ { "plugin_name": "Jdbc", "source_table_name": "gemini_dbo_API_Sales_Detail", "driver": "com.microsoft.sqlserver.jdbc.SQLServerDriver", "url": "jdbc:sqlserver://172.16.2.14:1433;encrypt=true;trustServerCertificate=true;databaseName=gemini;", "user": "sa", "password": "!QAZxsw2", "generate_sink_sql": "true", "database": "gemini", "table": "dbo.API_Sales_Detail", "primary_keys": ["id"] } ] } ``` ``` ### Running Command ```shell http://**:5801/hazelcast/rest/maps/stop-job ``` ### Error Exception ```log 2024-08-12 08:58:50,953 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-307] - [localhost]:5802 [seatunnel] [5.1] Task TaskGroupLocation{jobId=874174348949454849, pipelineId=1, taskGroupId=1} complete with state CANCELED 2024-08-12 08:58:51,006 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=874174348949848065, pipelineId=1, taskGroupId=1}] - [localhost]:5802 [seatunnel] [5.1] try lock failed in update metrics 2024-08-12 08:58:51,058 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=874174348950044673, pipelineId=1, taskGroupId=30000}] - [localhost]:5802 [seatunnel] [5.1] try lock failed in update metrics 2024-08-12 08:58:51,058 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=874174348950044673, pipelineId=1, taskGroupId=1}] - [localhost]:5802 [seatunnel] [5.1] taskGroup TaskGroupLocation{jobId=874174348950044673, pipelineId=1, taskGroupId=1} complete with CANCELED 2024-08-12 08:58:51,058 INFO [.e.IncrementalSourceEnumerator] [BlockingWorker-TaskGroupLocation{jobId=874174348950044673, pipelineId=1, taskGroupId=1}] - Closing enumerator... 2024-08-12 08:58:51,058 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-309] - [localhost]:5802 [seatunnel] [5.1] Task TaskGroupLocation{jobId=874174348950044673, pipelineId=1, taskGroupId=1} complete with state CANCELED 2024-08-12 08:58:51,106 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=874174348950437889, pipelineId=1, taskGroupId=1}] - [localhost]:5802 [seatunnel] [5.1] try lock failed in update metrics 2024-08-12 08:58:51,154 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=874174348950634497, pipelineId=1, taskGroupId=30000}] - [localhost]:5802 [seatunnel] [5.1] try lock failed in update metrics 2024-08-12 08:58:51,204 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=874174348950831105, pipelineId=1, taskGroupId=30000}] - [localhost]:5802 [seatunnel] [5.1] try lock failed in update metrics 2024-08-12 08:58:51,382 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=874174348951617537, pipelineId=1, taskGroupId=30000}] - [localhost]:5802 [seatunnel] [5.1] try lock failed in update metrics ``` ### Zeta or Flink or Spark Version Zeta 2.3.6 ### Java or Scala Version openjdk 17.0.10 2024-01-18 LTS ### Screenshots <img width="321" alt="image" src="https://github.com/user-attachments/assets/2c7e742f-3c89-4c39-b8f9-7e4ea25edea4";> ### 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]
