David Bryson
10/26/2023, 1:38 AMenv = StreamExecutionEnvironment.get_execution_environment()
table_env = StreamTableEnvironment.create(env)
Instead of using Table only:
env_settings = EnvironmentSettings.in_streaming_mode()
table_env = TableEnvironment.create(env_settings)
It fails to load the JDBC driver, which is definitely in my shaded pom:
Could not find any factory for identifier 'jdbc' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.