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

Tue, 08 Oct 2019 20:31:17 -0700 


谢谢啦






在 2019-10-09 11:19:17，"[email protected]" <[email protected]> 写道：
>你好，可以参考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.

回复