WeBankFinTech
[Bug] 任务运行失败
Search before asking
- [X] I searched the issues and found no similar issues.
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?
- [ ] Yes I am willing to submit a PR!
