commit 70546b564dd1564d3ee6e64362d1c64675bfac7c
author kchilton2 <kevin.e.chilton@gmail.com> Tue May 22 18:02:49 2018 -0400
committer Valiyil <Puja.Valiyil@parsons.com> Mon Jun 04 12:55:50 2018 -0400
tree 847bd55251ac1dfa9231d18095aee6c47cf17de1
parent af736749a375c54fc09efddbc749395f3e743937

RYA-497 Closes #298, Make the Rya Accumulo Kafka Connect Sink batch write instead of flushing after every Statement.

extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java

diff --git a/extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java b/extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
index 7d19f29..a21a41c 100644
--- a/extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
+++ b/extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
@@ -101,6 +101,7 @@
         ryaConfig.setAccumuloInstance( config.getClusterName() );
         ryaConfig.setAccumuloUser( config.getUsername() );
         ryaConfig.setAccumuloPassword( config.getPassword() );
+        ryaConfig.setFlush(false);
 
         // Create the Sail object.
         try {