Hi Cheng,
Thanks for your prompt reply. I was able to figured out the problem. What I
got wrong was not properly configuring
org.apache.flink.streaming.connectors.kafka.Kafka010TableSourceSinkFactory
as as TableSourceFactory in META-INF/services.
Cheers,
Dhanuka
On Mon, Dec 24, 2018 at 10:15 AM
Hi Dhanuka,
>From the exceptions, it seems you have changed the Kafka version to
'universal'. You can solve your problem in any of the following ways:
- Change Kafka version to 0.11. You only have a jar of 0.11 version in your
lib folder.
- Add flink-connector-kafka_2.11-1.7.0.jar to your lib
Thanks for being the release manager Gordon. And glad to see Flink 1.6.3
released.
Best,
Vino
Tzu-Li (Gordon) Tai 于2018年12月23日周日 下午9:35写道：
> Hi,
>
> The Apache Flink community is very happy to announce the release of
> Apache Flink 1.6.3, which is the third bugfix release for the Apache
>
Thanks for being the release manager Chesnay. And glad to see Flink 1.7.1
released.
Best,
Vino
Till Rohrmann 于2018年12月23日周日 下午9:37写道：
> Thanks for being the release manager Chesnay and to the community for all
> the hard work which made this release possible.
>
> Cheers,
> Till
>
> On Sat, Dec
Thanks for being the release manager Chesnay and to the community for all
the hard work which made this release possible.
Cheers,
Till
On Sat, Dec 22, 2018 at 8:35 PM Chesnay Schepler wrote:
> The Apache Flink community is very happy to announce the release of
> Apache Flink 1.7.1, which is
Hi,
The Apache Flink community is very happy to announce the release of
Apache Flink 1.6.3, which is the third bugfix release for the Apache
Flink 1.6 series.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data
Hi Cheng,
I have removed 1.6.1 jars and then I got below error
Starting execution of program
The program finished with the following exception:
org.apache.flink.client.program.ProgramInvocationException: The main method
caused an
