How to execute multi SQL in one job

Hi, you can do like this:

val statementSet = tableEnv.createStatementSet()
val insertSqlBuffer = ListBuffer.empty[String]

val calciteParser = new CalciteParser(SqlUtil.getSqlParserConfig(tableEnv.getConfig))
sqlArr
.foreach(item => {
println(item)
val itemNode = calciteParser.parse(item)

itemNode match {
case sqlSet: SqlSet => {
configuration.setString(sqlSet.getKeyString, sqlSet.getValueString)
}
case _: RichSqlInsert => insertSqlBuffer += item
case _ => {
println(item)
val itemResult = tableEnv.executeSql(item)
itemResult.print()
}
}
})

// execute batch inserts
if (insertSqlBuffer.size > 0) {
insertSqlBuffer.foreach(item => {
println("insert sql: " + item)
statementSet.addInsertSql(item)
})
val explain = statementSet.explain()
println(explain)
statementSet.execute()
}

```*来自志愿者整理的FLINK邮件归档