[I] [Bug] [Flink] 使用flink引擎执行Seatunnel cdc任务时，source端一直处于busy状态，这个是极不正常的 [seatunnel]

[via GitHub]

Fengt-en opened a new issue, #8213:
URL: https://github.com/apache/seatunnel/issues/8213

   ### 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
   
   使用flink引擎执行Seatunnel cdc任务时，source端一直处于busy状态
   以下是我的配置文件：
   env{
     job.mode="STREAMING"
     parallelism = 1
     job.name= "ft_MysqlToDoris"
     #flink.state.checkpoint-storage="filesystem"
     #flink.state.checkpoints.dir="file:///D:/tmp/seatunnel/linux/"
   
   }
   source{
    MySQL-CDC {
        base-url ="jdbc:mysql://localhost:3306/test"
        username = "root"
        password = "123456"
        table-names = ["test.test"]
        table-names-config = [{"table": "test.test", "primaryKeys": ["id"]}]
   }
   
   }
   transform{
   
   }
   sink{
   
    Console {
      parallelism = 2
    }
   }
   数据源端只有两条数据，从提交任务开始，算子状态即为busy。
   
   ![Uploading 1.jpg…]()
   
   
   
   ### SeaTunnel Version
   
   2.3.8
   
   ### SeaTunnel Config
   
   ```conf
   env{
     job.mode="STREAMING"
     parallelism = 1
     job.name= "ft_MysqlToDoris"
     #flink.state.checkpoint-storage="filesystem"
     #flink.state.checkpoints.dir="file:///D:/tmp/seatunnel/linux/"
   
   }
   source{
    MySQL-CDC {
        base-url ="jdbc:mysql://localhost:3306/test"
        username = "root"
        password = "123456"
        table-names = ["test.test"]
        table-names-config = [{"table": "test.test", "primaryKeys": ["id"]}]
   }
   
   }
   transform{
   
   }
   sink{
   
    Console {
      parallelism = 2
    }
   }
   ```
   
   
   ### Running Command
   
   ```shell
   我使用源码编译的方式启动程序
   org.apache.seatunnel.example.flink.v2.SeaTunnelApiExample
   ```
   
   
   ### Error Exception
   
   ```log
   无明显日志报错，程序执行正常，但source算子长期处于busy 100%状态，并且状态不会更新
   ```
   
   
   ### Zeta or Flink or Spark Version
   
   _No response_
   
   ### Java or Scala Version
   
   _No response_
   
   ### 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: commits-unsubscr...@seatunnel.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org