能不能把依赖和相关代码贴一下

| |
Page
|
|
[email protected]
|
签名由网易邮箱大师定制
在2021年7月13日 18:36,沉黙dē羔羊<[email protected]> 写道:
大家好,请教下,用了flink hudi 写入数据报错,如下:
Caused by: org.apache.flink.util.FlinkException: Error from OperatorCoordinator
&nbsp;... 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
&nbsp;at 
org.apache.hudi.sink.StreamWriteOperatorCoordinator.subtaskReady(StreamWriteOperatorCoordinator.java)
&nbsp;at 
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.notifySubtaskReady(OperatorCoordinatorHolder.java:416)
&nbsp;... 40 more

回复