谢谢啦
在 2019-10-09 11:19:17,"pengchengl...@163.com" <pengchengl...@163.com> 写道: >你好,可以参考https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/sqlClient.html > > > >pengchengl...@163.com > >发件人: Henry >发送时间: 2019-10-09 10:44 >收件人: user-zh >主题: Re:Re: Flink SQL :Unknown or invalid SQL statement. > > > >哈,非常非常感谢啦。 在 yaml 里定义使用表的哪些内容呢?有木有相关资料呢? 木有搜到呢。谢谢了。 > > > > > >在 2019-10-09 10:16:20,"Terry Wang" <zjuwa...@gmail.com> 写道: >>SQL client目前还不支持create table语法,你需要在yaml文件里定义使用的表。 >> >>Best, >>Terry Wang >> >> >> >>> 2019年10月9日 上午8:49,Henry <henryba...@163.com> 写道: >>> >>> 大家好,求助一下。 >>> FIink SQL> create table kafka_source( >>>> messageKey varbinary, >>>> message varbinary, >>>> topic varchar, >>> >'partition' int, >>>> 'offset' bigint >>>> ) with ( >>>> type='kafka011', >>>> topic='test', >>>> bootstrap. servers='thcathost:9092', >>>> 'group. id'='chf' >>>> ); >>> >>> >>> [ERROR] Unknown or invalid SQL statement.