13813586515 opened a new issue, #7449:
URL: https://github.com/apache/seatunnel/issues/7449

   ### 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
   
   使用ds来调度st,任务会卡住,导致定时跑的任务无法继续
   
   ### SeaTunnel Version
   
   2.3.6
   
   ### SeaTunnel Config
   
   ```conf
   env {
     parallelism = 10
     job.mode = "BATCH"
   }
   
   source {
       Jdbc {
           driver = com.microsoft.sqlserver.jdbc.SQLServerDriver
           url = "jdbc:sqlserver://192.168.0.123:1433;databaseName=BSERP3_LP"
           user = sa
           password = "123"
           # Define query logic as required
         table_list = [
           {
             table_path = "BSERP3_LP.dbo.fjsx9"
             # Use query filetr rows & columns
             query = "select * from BSERP3_LP.dbo.fjsx9 "
           }
           
       ]
   
       }
   }
   
    
   
   sink {
     Doris {
       fenodes = "192.168.0.168:8030,192.168.0.169:8030,192.168.0.170:8030"
       username = root
       password = "123"
       database = "ods_bs"
       table = "ods_${table_name}"
       # 保证每个文件唯一,拷贝之后文件需要修改此处
       sink.label-prefix = "bs-product-${table_name}-jdbc"
       sink.enable-2pc = "true"
       # sink.enable-delete = "true"
       save_mode_create_template="CREATE TABLE IF NOT EXISTS 
`${database}`.`${table_name}` (${rowtype_fields},dt datetime(0) default 
current_timestamp(0) on update current_timestamp(0)) ENGINE=OLAP UNIQUE KEY 
(SXDM) DISTRIBUTED BY HASH (SXDM) BUCKETS 3 PROPERTIES ( 
\"replication_allocation\" = \"tag.location.default: 1\",\"in_memory\" = 
\"false\",\"storage_format\" = \"V2\", \"disable_auto_compaction\" = \"false\")"
       doris.config {
         format = "json"
         read_json_by_line = "true"
       }
     }
   }
   ```
   
   
   ### Running Command
   
   ```shell
   集群
   ```
   
   
   ### Error Exception
   
   ```log
   任务卡主不动
   ```
   
   
   ### Zeta or Flink or Spark Version
   
   _No response_
   
   ### Java or Scala Version
   
   _No response_
   
   ### Screenshots
   
   
![image](https://github.com/user-attachments/assets/97678874-4a7c-460a-a89b-f82e03f19acd)
   
![image](https://github.com/user-attachments/assets/bfe96013-87dc-430b-9997-625a763770ff)
   
![image](https://github.com/user-attachments/assets/faa6068a-e002-4ad0-80a2-57693e70d57b)
   
   
   ### 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]

Reply via email to