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 Page <lj...@163.com> on 2021/07/15 15:39:16 UTC
回复：参与开发社区
能不能把依赖和相关代码贴一下
| |
Page
|
|
lj879933274@163.com
|
签名由网易邮箱大师定制
在2021年7月13日 18:36，沉黙ｄē羔羊<73...@qq.com.INVALID> 写道：
大家好，请教下，用了flink hudi 写入数据报错，如下：
Caused by: org.apache.flink.util.FlinkException: Error from OperatorCoordinator
... 41 more
Caused by: java.lang.AbstractMethodError: Method org/apache/hudi/sink/StreamWriteOperatorCoordinator.subtaskReady(ILorg/apache/flink/runtime/operators/coordination/OperatorCoordinator$SubtaskGateway;)V is abstract
at org.apache.hudi.sink.StreamWriteOperatorCoordinator.subtaskReady(StreamWriteOperatorCoordinator.java)
at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.notifySubtaskReady(OperatorCoordinatorHolder.java:416)
... 40 more
Re: 参与开发社区
Posted by Jingsong Li <ji...@gmail.com>.
Flink-Hudi版本是啥？
Flink集群版本是啥？
精确到第三位版本号
On Thu, Jul 15, 2021 at 11:39 PM Page <lj...@163.com> wrote:
> 能不能把依赖和相关代码贴一下
>
>
> | |
> Page
> |
> |
> lj879933274@163.com
> |
> 签名由网易邮箱大师定制
> 在2021年7月13日 18:36，沉黙ｄē羔羊<73...@qq.com.INVALID> 写道：
> 大家好，请教下，用了flink hudi 写入数据报错，如下：
> Caused by: org.apache.flink.util.FlinkException: Error from
> OperatorCoordinator
> ... 41 more
> Caused by: java.lang.AbstractMethodError: Method
> org/apache/hudi/sink/StreamWriteOperatorCoordinator.subtaskReady(ILorg/apache/flink/runtime/operators/coordination/OperatorCoordinator$SubtaskGateway;)V
> is abstract
> at
> org.apache.hudi.sink.StreamWriteOperatorCoordinator.subtaskReady(StreamWriteOperatorCoordinator.java)
> at
> org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.notifySubtaskReady(OperatorCoordinatorHolder.java:416)
> ... 40 more
--
Best, Jingsong Lee