You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by jf...@apache.org on 2015/12/20 23:52:39 UTC
phoenix git commit: PHOENIX-2367 : Change Phoenix Record Writer to
use excecute instead of executeBatch()
Repository: phoenix
Updated Branches:
refs/heads/master 135b978ae -> b2a066fb3
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/b2a066fb
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/b2a066fb
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/b2a066fb
Branch: refs/heads/master
Commit: b2a066fb3f826de526633b6c0be2f4add98df0b4
Parents: 135b978
Author: Siddhi <sm...@salesforce.com>
Authored: Tue Dec 15 16:05:11 2015 -0800
Committer: Jan <jf...@salesforce.com>
Committed: Sun Dec 20 14:04:44 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/b2a066fb/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) {