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
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
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
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
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