Hi there
This was exactly the problem.
Dian figured out the reason: I needed to rename file
org.apache.flink.table.factories.DynamicTableFactory to
org.apache.flink.table.factories.Factory
And then needed to added the format tag for the flink sql.
Blog will drop in 1 hour on medium and Link
Hi all
Hope someone can help.
1. want to confirm personally written connectors can be placed in
$FLINK_HOME/lib or a subdirectory. i got my prometheus connector in
...HOME/lib/flink/
I have other connectors/jars in HOME/lib/fluss and HOME/lib/hive
i can see the relevant jar loaded in the echo
