Hi
You can use like this:
```java
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()
}
```
> On Oct 29, 2021, at 18:50, wx liao <liaowx8...@gmail.com> wrote:
>
> Hi:
> I use flink sql,and run a script that has one souce an two sink,I can
> see 2 jobs runing through webUI,is that normal?
> Can some way to ensure only run on job that has one source and two sink?
> Thank you
