Repository: incubator-rya Updated Branches: refs/heads/master af736749a -> 70546b564
RYA-497 Closes #298, Make the Rya Accumulo Kafka Connect Sink batch write instead of flushing after every Statement. Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/70546b56 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/70546b56 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/70546b56 Branch: refs/heads/master Commit: 70546b564dd1564d3ee6e64362d1c64675bfac7c Parents: af73674 Author: kchilton2 <[email protected]> Authored: Tue May 22 18:02:49 2018 -0400 Committer: Valiyil <[email protected]> Committed: Mon Jun 4 12:55:50 2018 -0400 ---------------------------------------------------------------------- .../org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/70546b56/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 @@ public class AccumuloRyaSinkTask extends RyaSinkTask { ryaConfig.setAccumuloInstance( config.getClusterName() ); ryaConfig.setAccumuloUser( config.getUsername() ); ryaConfig.setAccumuloPassword( config.getPassword() ); + ryaConfig.setFlush(false); // Create the Sail object. try {
