Hi!
Executing a set of statements with SQL client is supported since Flink 1.13
[1]. Please consider upgrading your Flink version.
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sqlclient/#execute-a-set-of-sql-statements
方汉云 于2021年11月1日周一 下午8:31写道:
> Hi,
>
>
>
Hi,
I used offical flink-1.12.5 package,configuration sql-client-defaults.yaml,run
bin/sql-client.sh embedded
cat conf/sql-client-defaults.yaml
catalogs:
# A typical catalog definition looks like:
- name: myhive
type: hive
hive-conf-dir: /apps/conf/hive
default-database: de
Hi,
If you are using sql-client, you can try:
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sqlclient/#execute-a-set-of-sql-statements
If you are using TableEnvironment, you can try statement set too:
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/common/
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 => {
Hi, Roc
> Does Flink-SQL support fetching Mysql meta information automaticly in the
> latest version, ? If not, could the you adding this feature ?
You can obtain the latest meta information(table schema) by using Flink
JdbcCalatag[1], only PostgresCatalog is implemented, user can implemented