commit 6378539d2ac6e2c24f093862d5069c797f83d4bc
author YeChao Chen <chenyechao@gmail.com> Wed Nov 13 09:22:33 2019 +0800
committer tuteng <guangning@apache.org> Wed Nov 13 09:22:33 2019 +0800
tree cf8c351a30928535741cb3a77760a1dd4676848c
parent a4570044b16091c6465eca46844594cce8eaa175

[pulsar-io] hbase sink avoid flushing hbase table (#5629)

pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java

diff --git a/pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java b/pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
index 17ff802..7f4f413 100644
--- a/pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
+++ b/pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java
@@ -154,8 +154,7 @@
 
         try {
             if (CollectionUtils.isNotEmpty(puts)) {
-                table.put(puts);
-                admin.flush(tableName);
+                table.batch(puts, new Object[puts.size()]);
             }
 
             toFlushList.forEach(tRecord -> tRecord.ack());