------------------------------------------------------------ The program finished with the following exception:
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Unable to create a sink for writing table 'default_catalog.default_database.test_wide_performance_ceres_can_renewal'. Table options are: 'connector'='jdbc' 'password'='123456' 'sink.buffer-flush.interval'='2s' 'sink.buffer-flush.max-rows'='1000' 'table-name'='test_wide_performance_ceres_can_renewal' 'url'='jdbc:mysql://localhost:3306/stat' 'username'='root' at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:302) at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198) at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:149) at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:699) at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:232) at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:916) at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:992) at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:992) Caused by: org.apache.flink.table.api.ValidationException: Unable to create a sink for writing table 'default_catalog.default_database.test_wide_performance_ceres_can 以上是堆栈信息。 在 2020-11-03 11:00:44,"flink小猪" <18579099...@163.com> 写道: > > > > > > >我明明上传了图片呀 > > > > > >在 2020-11-03 10:41:57,"flink小猪" <18579099...@163.com> 写道: >>当我提交flink sql任务到集群上时,报以下错误。 >>首先感觉像是缺少依赖jar包,但是我使用反编译软件打开时发现依赖存在,那这是什么问题呢,我应该如何去解决?