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 fold
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 err
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
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
Add Dev Group
On Fri, Dec 21, 2018 at 6:21 PM dhanuka ranasinghe <
dhanuka.priyan...@gmail.com> wrote:
> Hi All,
>
> I have tried to read data from Kafka from Flink using Table API. It's
> working fine with Flink 1.4 but when upgrade to 1.7 given me below error. I
> have attached the libraries ad
