Re: Flink SQL ：Unknown or invalid SQL statement.

[Terry Wang]

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

Best,
Terry Wang



> 2019年10月9日 上午8:49，Henry <henryba...@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.