Hi Phil, ---- if __name__ == "__main__": process_table() error: link_app | Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'kafka' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath. flink_app | flink_app | Available factory identifiers are: flink_app | flink_app | blackhole flink_app | datagen flink_app | filesystem flink_app | print flink_app | python-input-format The '/opt/flink/lib' has the JARs from both the image and the JARs i added in the docker-compose.yml file. ----
Based on the stacktrace it seems your Kafka data is being processed but table creation which by default I believe is 'print' or 'datagen', has an issue with the factory that creates tables dynamically. You try 'blackhole' to atleast confirm Kafka data is infact being processed by flink, except table creation issue. Note: 'blackhole' is not a solution as that is basically '/dev/null' and usually for testing. After that you may have to look into DynamicTableFactory section in the reference documentation as it has more step by step details. Thanks Sohil
