Flink 两阶段提交这里构造方法能不能用其他的序列化工具呢？ kryo 各种兼容性报错！
liuhouer · 2020-04-01 11:39:22 +08:00 via iPhone · 848 次点击这是一个创建于 1494 天前的主题，其中的信息可能已经有所发展或是发生改变。
Flink 两阶段提交这里构造方法能不能用其他的序列化工具呢？ kryo 各种兼容性报错！
public class OracleTwoPhaseCommitSink extends TwoPhaseCommitSinkFunction<Tuple3<String, String, String>, Connection, Void> {
public OracleTwoPhaseCommitSink() {
super(new KryoSerializer<>(Connection.class, new ExecutionConfig()), VoidSerializer.INSTANCE);
}
public class OracleTwoPhaseCommitSink extends TwoPhaseCommitSinkFunction<Tuple3<String, String, String>, Connection, Void> {
public OracleTwoPhaseCommitSink() {
super(new KryoSerializer<>(Connection.class, new ExecutionConfig()), VoidSerializer.INSTANCE);
}
目前尚无回复
Select Language