[feat] add dirty manager and resolve conflict.

AndrewYang9112 · Jan 5, 2021 · 29ff102 · 29ff102
1 parent c145543
commit 29ff102
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseSink.java b/hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseSink.java
@@ -124,14 +124,9 @@ public DataStreamSink<Tuple2<Boolean, Row>> consumeDataStream(DataStream<Tuple2<
                 .setClientKeytabFile(clientKeytabFile)
                 .setBatchSize(Integer.parseInt(batchSize))
                 .setBatchWaitInterval(Long.parseLong(batchWaitInterval))
+                .setDirtyManager(DirtyDataManager.newInstance(dirtyProperties))
                 .finish();
 
-        builder.setClientPrincipal(clientPrincipal);
-        builder.setClientKeytabFile(clientKeytabFile);
-
-        builder.setDirtyManager(DirtyDataManager.newInstance(dirtyProperties));
-
-        HbaseOutputFormat outputFormat = builder.finish();
         RichSinkFunction richSinkFunction = new OutputFormatSinkFunction(outputFormat);
         DataStreamSink dataStreamSink = dataStream.addSink(richSinkFunction).name(registerTabName);