No SchemaValidator When switch to blink table planner.

[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

[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 <[hidden email]>，写道：
> 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

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

Thanks,
Kaka Chen

Danny Chan <[hidden email]> 于2019年7月16日周二 下午4:53写道：

> 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 <[hidden email]>，写道：
> > 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
>

[JingsongLee-2]

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 <[hidden email]>
Send Time:2019年7月16日(星期二) 16:41
To:dev <[hidden email]>
Subject:No SchemaValidator When switch to blink table planner.

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

[kaka chen]

Hi Jingsong:

Thanks very much.

Thanks,
Kaka Chen

JingsongLee <[hidden email]> 于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, JingsongLee
>
>
> ------------------------------------------------------------------
> From:kaka chen <[hidden email]>
> Send Time:2019年7月16日(星期二) 16:41
> To:dev <[hidden email]>
> Subject:No SchemaValidator When switch to blink table planner.
>
> 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
>