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

回复