foreach exec sql

tableEnv.executeSql(sql(0)) tableEnv.executeSql(sql(1)) tableEnv.executeSql(sql(2)) tableEnv.executeSql(sql(3)) tableEnv.executeSql(sql(4)) tableEnv.executeSql(sql(5)) tableEnv.executeSql(sql(6)) tableEnv.executeSql(sql(7)).print() that is OK but I hope

Re: foreach exec sql

Hi! Try this: sql.zipWithIndex.foreach { case (sql, idx) => val result = tableEnv.executeSql(sql) if (idx == 7) { result.print() } } igyu 于2021年7月27日周二 下午4:38写道： > tableEnv.executeSql(sql(0)) > tableEnv.executeSql(sql(1)) > tableEnv.executeSql(sql(2)) > tableEnv.ex

Re: foreach exec sql

Btw you are executing a lot of Flink jobs in parallel with this because the submission is async. Maybe the concept of a StatementSet via TableEnvironment.createStatementSet() helps. Regards, Timo On 27.07.21 10:56, Caizhi Weng wrote: Hi! Try this: sql.zipWithIndex.foreach { case (sql, idx)