谢谢啦
在 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.
