misszhangss commented on issue #11043: URL: https://github.com/apache/dolphinscheduler/issues/11043#issuecomment-1719093312
@Dannila @ShawshankLin 您好，我尝试在dolphinscheduler 3.17上运行一个flink Streaming任务  任务跑起来了 我点击停止按钮没有任何反应  运行一会后就自动停止了，即使我不点停止按钮，他也会在数据同步后自动停止  查询hadoop发现对应的application并没有停止  上图中的kill都是我自己手动kill的 点击stop 并不会真正的停止application 主要存在两个问题： 1、为什么flink stream任务在同步完数据的时候会停止，且停止的时候对应的application并没有停止 2、为什么stop按钮并没有真正的停下任务 期待您的回复，感谢! 这是我任务的一些参数   sql脚本： CREATE TABLE ddd_code_detail_history ( id bigint NOT NULL , code_detail_id bigint , content string, funNames varchar(255) , properties string, version varchar(255) , updater varchar(255) , comments varchar(255), PRIMARY KEY (id) NOT ENFORCED ) with ( 'connector' = 'mysql-cdc', 'hostname' = '172.16.198.248', 'port' = '3306', 'username' = 'root', 'password' = 'DataBlau@1', 'database-name' = 'ddd_db_dev', 'table-name' = 'ddd_code_detail_history' ); CREATE TABLE ddd_code_detail_history_demo ( id bigint NOT NULL , code_detail_id bigint , content string, funNames varchar(255) , properties string, version varchar(255) , updater varchar(255) , comments varchar(255), PRIMARY KEY (id) NOT ENFORCED ) with ( 'connector' = 'upsert-kafka', 'topic' = 'flink-cdc-kafka','properties.bootstrap.servers' = '172.16.198.248:9092','properties.group.id' = 'flink-cdc-kafka-group', 'key.format' = 'json', 'value.format' = 'json' ); insert into ddd_code_detail_history_demo select * from ddd_code_detail_history; -- 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]
