flink sql cdc任务提交报错

[丁浩浩]

当我提交flink sql任务到集群上时，报以下错误。
首先感觉像是缺少依赖jar包，但是我使用反编译软件打开时发现依赖存在，那这是什么问题呢，我应该如何去解决？

[丁浩浩]

我明明上传了图片呀





在 2020-11-03 10:41:57，"flink小猪" <[hidden email]> 写道：
>当我提交flink sql任务到集群上时，报以下错误。
>首先感觉像是缺少依赖jar包，但是我使用反编译软件打开时发现依赖存在，那这是什么问题呢，我应该如何去解决？

[丁浩浩]

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

 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小猪" <[hidden email]> 写道：
>
>
>
>
>
>
>我明明上传了图片呀
>
>
>
>
>
>在 2020-11-03 10:41:57，"flink小猪" <[hidden email]> 写道：
>>当我提交flink sql任务到集群上时，报以下错误。
>>首先感觉像是缺少依赖jar包，但是我使用反编译软件打开时发现依赖存在，那这是什么问题呢，我应该如何去解决？

 

[Jark]

好像堆栈不完整，真正的 root cause 没有截出来。
另外图片还是看不到，还是粘贴文字吧。

On Tue, 3 Nov 2020 at 11:06, flink小猪 <[hidden email]> wrote:

> ------------------------------------------------------------
>
>  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小猪" <[hidden email]> 写道：
> >
> >
> >
> >
> >
> >
> >我明明上传了图片呀
> >
> >
> >
> >
> >
> >在 2020-11-03 10:41:57，"flink小猪" <[hidden email]> 写道：
> >>当我提交flink sql任务到集群上时，报以下错误。
> >>首先感觉像是缺少依赖jar包，但是我使用反编译软件打开时发现依赖存在，那这是什么问题呢，我应该如何去解决？
>
>
>
>
>
>