PHOENIX-2367 : Change Phoenix Record Writer to use excecute instead of executeBatch()
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/785f4875 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/785f4875 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/785f4875 Branch: refs/heads/4.x-HBase-1.0 Commit: 785f487532169d1e66f4f4f6b03a97ce44c4432d Parents: 9dce7c1 Author: Siddhi <[email protected]> Authored: Tue Dec 15 16:05:11 2015 -0800 Committer: Jan <[email protected]> Committed: Sun Dec 20 15:04:41 2015 -0800 ---------------------------------------------------------------------- .../java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/785f4875/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java index 5843076..70ee3f5 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java @@ -55,7 +55,6 @@ public class PhoenixRecordWriter<T extends DBWritable> extends RecordWriter<Nul @Override public void close(TaskAttemptContext context) throws IOException, InterruptedException { try { - statement.executeBatch(); conn.commit(); } catch (SQLException e) { LOG.error("SQLException while performing the commit for the task."); @@ -77,10 +76,9 @@ public class PhoenixRecordWriter<T extends DBWritable> extends RecordWriter<Nul try { record.write(statement); numRecords++; - statement.addBatch(); + statement.execute(); if (numRecords % batchSize == 0) { LOG.debug("commit called on a batch of size : " + batchSize); - statement.executeBatch(); conn.commit(); } } catch (SQLException e) {
