[pulsar] branch master updated: [pulsar-io] hbase sink avoid flushing hbase table (#5629)

[guangning]

This is an automated email from the ASF dual-hosted git repository.

guangning pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 96acc57  [pulsar-io] hbase sink avoid flushing hbase table (#5629)
96acc57 is described below

commit 96acc57a19958ecce22e63d961ac5353a5cbaf64
Author: YeChao Chen <chenyec...@gmail.com>
AuthorDate: Wed Nov 13 09:22:33 2019 +0800

    [pulsar-io] hbase sink avoid flushing hbase table (#5629)
---
 .../main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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 @@ public abstract class HbaseAbstractSink<T> implements 
Sink<T> {
 
         try {
             if (CollectionUtils.isNotEmpty(puts)) {
-                table.put(puts);
-                admin.flush(tableName);
+                table.batch(puts, new Object[puts.size()]);
             }
 
             toFlushList.forEach(tRecord -> tRecord.ack());