Could not find any factory for identifier ‘kinesis’ that implements ‘org.apache.flink.table.f actories.DynamicTableFactory’ in the classpath
I am trying to run a pyhon job using apache flink 1.15.2 as per the repo https://github.com/aws-samples/pyflink-getting-started.git