Re: foreach exec sql

[Timo Walther]

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) =>
   val result = tableEnv.executeSql(sql)
   if (idx == 7) {
     result.print()
   }
}

igyu <i...@21cn.com <mailto:i...@21cn.com>> 于2021年7月27日周二 下午4:38 
写道：

          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

           sql.foreach(s=>{
             tableEnv.executeSql(s)
           })

    ------------------------------------------------------------------------
    igyu