if (jobID != null) {
sql_array.add(insert_sql)
drop_sql = drop_sql.replaceAll("tablename",
targetTableName).replaceAll("etlTaskId",etlTaskId)
sql_array.add(drop_sql)
//执行sql
SQLUtils.execSql(sql_array)
}
原始邮件
发件人: Chesnay Schepler
收件人: dev; 魏烽
发送时间: 2020年5月18日(周一) 14:5
Image attachments do not work on this mailing list; please re-send the
question with the code as text.
On 18/05/2020 06:51, 魏烽 wrote:
Hello：
I have a question and I really want to ask everyone。
I submitted a flink batch processing task in DolphinShceduler. After
the flink task, the sql opera
Hello：
I have a question and I really want to ask everyone。
I submitted a flink batch processing task in DolphinShceduler. After the flink
task, the sql operation was performed. The sql operation failed, but the flink
task was successful. How can I solve this problem?
The code is roughly as foll
