谢谢,了解了
发自我的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的方式定义表。
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,李轲 写道:
在服务器上试用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
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
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:
>