all those are verified.
the issue is fixed by adding
org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableFactory
to org.apache.flink.table.factories.Factory.
Thanks,
Fanbin
On Tue, Nov 17, 2020 at 7:29 AM Khachatryan Roman <
khachatryan.ro...@gmail.com> wrote:
> Hi,
>
> Please
Hi,
Please verify that:
1. kafka-connector is indeed in the fat jar (e.g. by "jar vtf
your-program.jar | grep KafkaDynamicTableFactory")
2. kafka-connector version matches the version of Flink distribution on EMR.
Regards,
Roman
On Tue, Nov 17, 2020 at 6:47 AM Fanbin Bu wrote:
> Hi,
>
> I cou
Hi,
I could not launch my flink 1.11.2 application on EMR with exception
Caused by: org.apache.flink.table.api.ValidationException:
Could not find any factory for identifier 'kafka' that implements
'org.apache.flink.table.factories.DynamicTableSourceFactory' in the
classpath.
I attached the full
