Flink 两阶段提交这里构造方法能不能用其他的序列化工具呢？ kryo 各种兼容性报错！
public class OracleTwoPhaseCommitSink extends TwoPhaseCommitSinkFunction<Tuple3<String, String, String>, Connection, Void> {
public OracleTwoPhaseCommitSink() {

super(new KryoSerializer<>(Connection.class, new ExecutionConfig()), VoidSerializer.INSTANCE);

}

大佬有話說 (0)