Flink-Hudi版本是啥？ Flink集群版本是啥？ 精确到第三位版本号
On Thu, Jul 15, 2021 at 11:39 PM Page <lj879933...@163.com> wrote: > 能不能把依赖和相关代码贴一下 > > > | | > Page > | > | > lj879933...@163.com > | > 签名由网易邮箱大师定制 > 在2021年7月13日 18:36，沉黙ｄē羔羊<736036...@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
