Re: [外部邮件] Re: Question about flink sql

2021-11-01 Thread Caizhi Weng
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, > > >

回复:[外部邮件] Re: Question about flink sql

2021-11-01 Thread 方汉云
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

Re: Question about flink sql

2021-11-01 Thread Jingsong Li
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/

Re: Question about flink sql

2021-10-29 Thread Jake
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 => {

Re: Question about Flink-SQL

2020-10-20 Thread Leonard Xu
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