flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Henry <henryba...@163.com>
Subject Re:回复: Re: Flink SQL :Unknown or invalid SQL statement.
Date Wed, 09 Oct 2019 03:30:20 GMT


谢谢啦






在 2019-10-09 11:19:17,"pengchenglins@163.com" <pengchenglins@163.com> 写道:
>你好,可以参考https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/sqlClient.html
>
>
>
>pengchenglins@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" <zjuwangg@gmail.com> 写道:
>>SQL client目前还不支持create table语法,你需要在yaml文件里定义使用的表。
>>
>>Best,
>>Terry Wang
>>
>>
>>
>>> 2019年10月9日 上午8:49,Henry <henrybao91@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.
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message