flink cdc 数据同步作业无法提交（standalone）,issues也提交了。报错如下
WARN org.apache.flink.table.client.cli.CliClient [] - Could
not execute SQL statement.
org.apache.flink.table.client.gateway.SqlExecutionException: Could not execute
SQL statement.
at
org.apache.flink.table.client.gateway.local.LocalExecutor.executeModifyOperations(LocalExecutor.java:228)
~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.cli.CliClient.callInserts(CliClient.java:518)
~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.cli.CliClient.callInsert(CliClient.java:507)
~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:409)
~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.cli.CliClient.lambda$executeStatement$0(CliClient.java:327)
[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at java.util.Optional.ifPresent(Optional.java:159) ~[?:1.8.0_211]
at
org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:327)
[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.cli.CliClient.executeFile(CliClient.java:316)
[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.cli.CliClient.executeInNonInteractiveMode(CliClient.java:230)
[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:153)
[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95)
[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187)
[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)
[flink-sql-client_2.12-1.13.3.jar:1.13.3]
Caused by: org.apache.flink.table.api.TableException: Failed to execute sql
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:777)
~[flink-table_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:742)
~[flink-table_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeModifyOperations$4(LocalExecutor.java:226)
~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:90)
~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.executeModifyOperations(LocalExecutor.java:226)
~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
... 12 more
Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'orders'.
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1970)
~[flink-dist_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.planner.delegation.ExecutorBase.executeAsync(ExecutorBase.java:55)
~[flink-table-blink_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:759)
~[flink-table_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:742)
~[flink-table_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeModifyOperations$4(LocalExecutor.java:226)
~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:90)
~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.executeModifyOperations(LocalExecutor.java:226)
~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
... 12 more
Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed to
submit JobGraph.
at
org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$9(RestClusterClient.java:405)
~[flink-dist_2.12-1.13.3.jar:1.13.3]
at
java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870)
~[?:1.8.0_211]
at
java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:852)
~[?:1.8.0_211]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
~[?:1.8.0_211]
at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
~[?:1.8.0_211]
at
org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:364)
~[flink-dist_2.12-1.13.3.jar:1.13.3]
at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
~[?:1.8.0_211]
at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
~[?:1.8.0_211]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
~[?:1.8.0_211]
at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
~[?:1.8.0_211]
at
org.apache.flink.runtime.concurrent.FutureUtils$Timeout.run(FutureUtils.java:1255)
~[flink-dist_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.concurrent.DirectExecutorService.execute(DirectExecutorService.java:217)
~[flink-dist_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.concurrent.FutureUtils.lambda$orTimeout$15(FutureUtils.java:582)
~[flink-dist_2.12-1.13.3.jar:1.13.3]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_211]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_211]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
~[?:1.8.0_211]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
~[?:1.8.0_211]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_211]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_211]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_211]
Caused by: java.util.concurrent.TimeoutException
at
org.apache.flink.runtime.concurrent.FutureUtils$Timeout.run(FutureUtils.java:1255)
~[flink-dist_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.concurrent.DirectExecutorService.execute(DirectExecutorService.java:217)
~[flink-dist_2.12-1.13.3.jar:1.13.3]
at
org.apache.flink.runtime.concurrent.FutureUtils.lambda$orTimeout$15(FutureUtils.java:582)
~[flink-dist_2.12-1.13.3.jar:1.13.3]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_211]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_211]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
~[?:1.8.0_211]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
~[?:1.8.0_211]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_211]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_211]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_211]
------------------------------------------------------------------
发件人：Jark Wu <[email protected]>
发送时间：2022年1月6日(星期四) 16:51
收件人：user-zh <[email protected]>
主 题：Re: flinkCDC2.1.1
Flink CDC 的问题可以 report 到
https://github.com/ververica/flink-cdc-connectors/issues到
On Thu, 30 Dec 2021 at 14:08, Liu Join <[email protected]> wrote:
> 使用flinkCDC2.1.1读取MySQL数据，一段时间后报错
> 图床链接：报错图片 <https://imgtu.com/i/TRZPPO>
>
>
>
> 从 Windows 版邮件 <https://go.microsoft.com/fwlink/?LinkId=550986>发送
>
>
>
