Re: Flink 1.7 doesn't work with Kafka Table Source Descriptors

Hi dhanuka, I failed to reproduce your error with release-1.7.0. It seems Kafka.toConnectorProperties() should be called instead of ConnectorDescriptor.toConnectorProperties(), the latter one is an abstract class, which lead to the AbstractMethodError. >From the picture uploaded, it is strange th

Re: Flink 1.7 doesn't work with Kafka Table Source Descriptors

Hi Cheng, Thanks for your reply will try out and update you on this. Cheers, Dhanuka On Sat, 22 Dec 2018, 20:41 Hequn Cheng Hi dhanuka, > > I failed to reproduce your error with release-1.7.0. It > seems Kafka.toConnectorProperties() should be called instead > of ConnectorDescriptor.toConnecto

[ANNOUNCE] Apache Flink 1.7.1 released

The Apache Flink community is very happy to announce the release of Apache Flink 1.7.1, which is the first bugfix release for the Apache Flink 1.7 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streamin