在idea中运行flink程序报错,详细报错信息如下:
Exception in thread "main" org.apache.flink.table.api.TableException: Failed to execute sql
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:828)
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1274)
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:742)
at com.shfw.postgres2postgres.main(postgres2postgres.java:52)
Caused by: java.lang.IllegalStateExceptio