Re: blink planner的org.apache.flink.table.api.ValidationException报错

2020-01-19 文章 Kevin Liao
>> Jingsong Lee >> >> -- >> From:Kevin Liao >> Send Time:2020年1月14日(星期二) 11:38 >> To:user-zh ; JingsongLee < >> lzljs3620...@aliyun.com> >> Subject:Re: blink planner的org.apache.fli

Re: blink planner的org.apache.flink.table.api.ValidationException报错

2020-01-13 文章 Kevin Liao
t; Jingsong Lee > > -- > From:Kevin Liao > Send Time:2020年1月14日(星期二) 11:38 > To:user-zh ; JingsongLee < > lzljs3620...@aliyun.com> > Subject:Re: blink planner的org.apache.flink.table.api.ValidationException报错 > > flink 版本是 1.9.1 release > > Doc >

Re: blink planner的org.apache.flink.table.api.ValidationException报错

2020-01-13 文章 JingsongLee
谢谢, 你可以试下最新的1.9版本或是1.10或是master吗?因为这里修了一些bug,不确定还存在不。 Best, Jingsong Lee -- From:Kevin Liao Send Time:2020年1月14日(星期二) 11:38 To:user-zh ; JingsongLee Subject:Re: blink planner的org.apache.flink.table.api.ValidationException报错

Re: blink planner的org.apache.flink.table.api.ValidationException报错

2020-01-13 文章 Kevin Liao
flink 版本是 1.9.1 release Doc 完整不太好给因为涉及到业务信息了,抱歉,但可以给一个片段,这就是一个普通Pojo,里面只有一层,所有类型都是基础类型(及衍生)+String,大约 30 多个字段,我理解这跟字段数关系不大 ``` import org.apache.commons.lang3.builder.ToStringBuilder; import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonIgnoreProperties; /** * @author

blink planner的org.apache.flink.table.api.ValidationException报错

2020-01-13 文章 Kevin Liao
tEnv.connect(new Kafka() .version("universal") .topic("xxx") .startFromLatest() .property("bootstrap.servers", "") .property("group.id", "")) .withFormat(new Json().failOnMissingField(false).deriveSchema()) .withSchema(new