Flink SQL ：Unknown or invalid SQL statement.

[Henry]

大家好，求助一下。
     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.

[Terry Wang]

SQL client目前还不支持create table语法，你需要在yaml文件里定义使用的表。

Best,
Terry Wang

> 2019年10月9日 上午8:49，Henry <[hidden email]> 写道：
>
> 大家好，求助一下。
>     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.

[Henry]

哈，非常非常感谢啦。 在 yaml 里定义使用表的哪些内容呢？有木有相关资料呢？ 木有搜到呢。谢谢了。





在 2019-10-09 10:16:20，"Terry Wang" <[hidden email]> 写道：

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

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



[hidden email]
 
发件人： 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" <[hidden email]> 写道：

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

[Henry]

谢谢啦






在 2019-10-09 11:19:17，"[hidden email]" <[hidden email]> 写道：

>你好，可以参考https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/sqlClient.html
>
>
>
>[hidden email]
>
>发件人： 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" <[hidden email]> 写道：
>>SQL client目前还不支持create table语法，你需要在yaml文件里定义使用的表。
>>
>>Best,
>>Terry Wang
>>
>>
>>
>>> 2019年10月9日 上午8:49，Henry <[hidden email]> 写道：
>>>
>>> 大家好，求助一下。
>>>     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.