回复: Re: Flink SQL ：Unknown or invalid SQL statement.

Tue, 08 Oct 2019 20:20:12 -0700 

你好，可以参考https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/sqlClient.html



[email protected]
 
发件人： 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" <[email protected]> 写道：
>SQL client目前还不支持create table语法，你需要在yaml文件里定义使用的表。
>
>Best,
>Terry Wang
>
>
>
>> 2019年10月9日 上午8:49，Henry <[email protected]> 写道：
>> 
>> 大家好，求助一下。
>>     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.

回复