?????? flink-1.13.1 sql error

[guoyb]

??






----
??: 
   "user-zh"

http://apache-flink.147419.n8.nabble.com/

Re: flink-1.13.1 sql error

[Jingsong Li]

你这个报错信息，意思是有个字段，你在DDL里声明是ROW，但是真实数据的这列却不是一个ROW。

你应该排查下是否声明对了，如果在期望中，可以通过ignoreParseErrors来跳过这行

Best,
Jingsong

On Mon, Jun 21, 2021 at 11:46 AM zhuxiaoshang 
wrote:

> Json反序列化失败了，像是数据问题
> {\n  \"app_time\": \"2021-06-14 10:00:00\",\n 
> \"category_id\": 1,\n  \"item_id\": 1,\n 
> \"user_id\": 1,\n  \"behavior\": \"pv\"\n}
>
> > 2021年6月20日 下午9:08，kcz <573693...@qq.com.INVALID> 写道：
> >
> > 大佬们 帮看下这个是为什么提示那个错误
> >
> >
> >
> > --
> > Sent from: http://apache-flink.147419.n8.nabble.com/
>
>

-- 
Best, Jingsong Lee

Re: flink-1.13.1 sql error

[zhuxiaoshang]

Json反序列化失败了，像是数据问题
{\n  \"app_time\": \"2021-06-14 10:00:00\",\n  
\"category_id\": 1,\n  \"item_id\": 1,\n  \"user_id\": 
1,\n  \"behavior\": \"pv\"\n}

> 2021年6月20日 下午9:08，kcz <573693...@qq.com.INVALID> 写道：
> 
> 大佬们 帮看下这个是为什么提示那个错误
> 
> 
> 
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink-1.13.1 sql error

[kcz]

大佬们 帮看下这个是为什么提示那个错误



--
Sent from: http://apache-flink.147419.n8.nabble.com/

flink-1.13.1 sql error

[kcz]

sql??
CREATE TABLE user_behavior (
  user_id BIGINT,
  item_id BIGINT,
  category_id BIGINT,
  behavior STRING,
  ts STRING
) WITH (
  'connector' = 'kafka',
  'topic' = 'user_behavior',
  'scan.startup.mode' = 'latest-offset',
  'properties.bootstrap.servers' = 'localhost:9092',
  'format' = 'json'
);


select * from user_behavior;



pom.xml??
flink.version=1.13.1