------------------------------------------------------------

 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包,但是我使用反编译软件打开时发现依赖存在,那这是什么问题呢,我应该如何去解决?

回复