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
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
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)