flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "pengchenglins@163.com" <pengchengl...@163.com>
Subject 回复: Re: Flink SQL :Unknown or invalid SQL statement.
Date Wed, 09 Oct 2019 03:19:17 GMT
你好,可以参考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