Re: No SchemaValidator When switch to blink table planner.

2019-07-16 Thread kaka chen
Hi Jingsong: Thanks very much. Thanks, Kaka Chen JingsongLee 于2019年7月16日周二 下午5:03写道: > Hi kaka: > Yeah, there are still some problems, I create a JIRA[1] to trace it, I > think we should solve it before 1.9 release. > > [1] https://issues.apache.org/jira/browse/FLINK-13285 > > Best, JingsongLe

Re: No SchemaValidator When switch to blink table planner.

2019-07-16 Thread JingsongLee
Hi kaka: Yeah, there are still some problems, I create a JIRA[1] to trace it, I think we should solve it before 1.9 release. [1] https://issues.apache.org/jira/browse/FLINK-13285 Best, JingsongLee -- From:kaka chen Send Time:2019

Re: No SchemaValidator When switch to blink table planner.

2019-07-16 Thread kaka chen
Hi Danny, Thanks for quick reply. I replace the flink planner to blink planner deps in the kafka-connector pom file, and run the unit test. It throws errors which I found in class KafkaTableSourceSinkFactoryBase, it use SchemaValidator class which only exists flink-planner, not blink-planner. Tha

Re: No SchemaValidator When switch to blink table planner.

2019-07-16 Thread Danny Chan
How do you use the Kafka connector, through the TableEnvironment#sqlUpdate (the DDL), or through the TableEnvironment#connect() (the table api) ? Best, Danny Chan 在 2019年7月16日 +0800 PM4:41,kaka chen ,写道: > Hi All, > > We are trying to switch to blink table planner in Kafka's connector, but > foun

No SchemaValidator When switch to blink table planner.

2019-07-16 Thread kaka chen
Hi All, We are trying to switch to blink table planner in Kafka's connector, but found there is no SchemaValidator and related classes, how to resolve it? Thanks. Thanks, Kaka Chen