WeBankFinTech / Streamis

Streaming application development and management system, based on Linkis and DSS, planning to provide the workflow-like graphical drag-and-drop development capability.
Apache License 2.0
101 stars 42 forks source link

[Bug] 任务运行失败 #51

Open cydenghua opened 1 year ago

cydenghua commented 1 year ago

Search before asking

Streamis Component

streamis-job-manager

What happened + What you expected to happen

运行从一个mysql表读数据写到另外一个mysql表,如: CREATE TABLE IF NOT EXISTS cold_45a_mod_x7(column_lgbm String, column_yyzzbh String, column_dwmc String) WITH ('connector' = 'jdbc','url' = 'jdbc:mysql://101.30.9.14:3306/dmp','table-name' = 'tb_modeltest','username' = 'pieeco','password' = 'pi-7988100');

CREATE TABLE IF NOT EXISTS cold_45t_mod_x7(column_lgbm String, column_yyzzbh String, column_dwmc String) WITH ('connector' = 'jdbc','url' = 'jdbc:mysql://101.30.9.14:3306/dmp','table-name' = 'tb_dh','username' = 'pieeco','password' = 'pi-7988100');

INSERT INTO cold_45t_mod_x7 SELECT column_lgbm,column_yyzzbh,column_dwmc FROM cold_45b_mod_x7;

任务运行成功,但是最后任务显示失败。

Relevent platform

linux

Reproduction script

CREATE TABLE IF NOT EXISTS cold_45a_mod_x7(column_lgbm String, column_yyzzbh String, column_dwmc String) WITH ('connector' = 'jdbc','url' = 'jdbc:mysql://101.30.9.14:3306/dmp','table-name' = 'tb_modeltest','username' = 'pieeco','password' = 'pi-7988100');

CREATE TABLE IF NOT EXISTS cold_45t_mod_x7(column_lgbm String, column_yyzzbh String, column_dwmc String) WITH ('connector' = 'jdbc','url' = 'jdbc:mysql://101.30.9.14:3306/dmp','table-name' = 'tb_dh','username' = 'pieeco','password' = 'pi-7988100');

INSERT INTO cold_45t_mod_x7 SELECT column_lgbm,column_yyzzbh,column_dwmc FROM cold_45b_mod_x7;

Anything else

No response

Are you willing to submit a PR?

fengsen198698 commented 1 year ago

同样的问题,请问有解决吗?

Zdddddddddddd commented 1 year ago

I use flink have no problem

Zdddddddddddd commented 1 year ago

I use flink CDC