大家好,请教下,用了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