Re: 【Flink SQL】无法启动 env.yaml

2020-12-01 文章 李轲
谢谢,了解了 发自我的iPhone > 在 2020年12月1日,23:31,Leonard Xu 写道: > > Hi, 李轲 > > 这是因为yml只支持1.10之前老的connector,写法是connector.type=‘filesystem’, > 1.11之后的新connector都是 connetor=‘filesystem’, 除了简化了写法外,前者的工厂方法和后者的也不一样, > 所以通过yml定义的新的connector是不能被老的工厂 SPI > 发现的。而在yml中定义表从1.11开始就是不推荐了,因为已经支持了用DDL这种纯SQL的方式定义表。

Re: 【Flink SQL】无法启动 env.yaml

2020-12-01 文章 Leonard Xu
Hi, 李轲 这是因为yml只支持1.10之前老的connector,写法是connector.type=‘filesystem’, 1.11之后的新connector都是 connetor=‘filesystem’, 除了简化了写法外,前者的工厂方法和后者的也不一样, 所以通过yml定义的新的connector是不能被老的工厂 SPI 发现的。而在yml中定义表从1.11开始就是不推荐了,因为已经支持了用DDL这种纯SQL的方式定义表。 推荐你可以拉起sql-client后,用DDL的方式建表 祝好 Leonard > 在 2020年12月1日,21:43,李轲 写道:

【Flink SQL】无法启动 env.yaml

2020-12-01 文章 李轲
在服务器上试用sql-client时,启动指令如下: ./sql-client.sh embedded -l /root/flink-sql-client/libs/ -d /data_gas/flink/flink-1.11.2/conf/sql-client-defaults.yaml -e /root/flink-sql-client/sql-client-demo.yml 配置如下: # 定义表 tables: - name: SourceTable type: source-table update-mode: append

Re: 【Flink SQL】无法启动env.yaml

2019-04-01 文章 Zhenghua Gao
m (1 by default) > periodic-watermarks-interval: 200 > # optional: interval for periodic watermarks(200 ms by default) > max-parallelism: 16 > # optional: Flink's maximum parallelism (128by default) > min-idle-state-retention: 0 > # optional: table program's minimum idle s

Re: 【Flink SQL】无法启动env.yaml

2019-04-01 文章 Zhenghua Gao
yaml格式不对,看起来是缩进导致的。 你可以找个在线yaml编辑器验证一下, 比如 [1] 更多yaml格式的说明,参考 [2][3] [1] http://nodeca.github.io/js-yaml/ [2] http://www.ruanyifeng.com/blog/2016/07/yaml.html [3] https://en.wikipedia.org/wiki/YAML *Best Regards,* *Zhenghua Gao* On Mon, Apr 1, 2019 at 11:51 AM 曾晓勇 <469663...@qq.com> wrote: >