You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by flink小猪 <18...@163.com> on 2020/11/03 02:41:57 UTC
flink sql cdc任务提交报错
当我提交flink sql任务到集群上时，报以下错误。
首先感觉像是缺少依赖jar包，但是我使用反编译软件打开时发现依赖存在，那这是什么问题呢，我应该如何去解决？
Re: Re:flink sql cdc任务提交报错
Posted by Jark Wu <im...@gmail.com>.
好像堆栈不完整，真正的 root cause 没有截出来。
另外图片还是看不到，还是粘贴文字吧。
On Tue, 3 Nov 2020 at 11:06, flink小猪 <18...@163.com> 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小猪" <18...@163.com> 写道：
> >
> >
> >
> >
> >
> >
> >我明明上传了图片呀
> >
> >
> >
> >
> >
> >在 2020-11-03 10:41:57，"flink小猪" <18...@163.com> 写道：
> >>当我提交flink sql任务到集群上时，报以下错误。
> >>首先感觉像是缺少依赖jar包，但是我使用反编译软件打开时发现依赖存在，那这是什么问题呢，我应该如何去解决？
>
>
>
>
>
>
Re:Re:flink sql cdc任务提交报错
Posted by flink小猪 <18...@163.com>.
------------------------------------------------------------
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小猪" <18...@163.com> 写道：
>
>
>
>
>
>
>我明明上传了图片呀
>
>
>
>
>
>在 2020-11-03 10:41:57，"flink小猪" <18...@163.com> 写道：
>>当我提交flink sql任务到集群上时，报以下错误。
>>首先感觉像是缺少依赖jar包，但是我使用反编译软件打开时发现依赖存在，那这是什么问题呢，我应该如何去解决？
Re:flink sql cdc任务提交报错
Posted by flink小猪 <18...@163.com>.
我明明上传了图片呀
在 2020-11-03 10:41:57，"flink小猪" <18...@163.com> 写道：
>当我提交flink sql任务到集群上时，报以下错误。
>首先感觉像是缺少依赖jar包，但是我使用反编译软件打开时发现依赖存在，那这是什么问题呢，我应该如何去解决？