This is an automated email from the ASF dual-hosted git repository.
karanmehta93 pushed a commit to branch 4.x-HBase-1.2
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/4.x-HBase-1.2 by this push:
new 0aec1e6 PHOENIX-5195 PHERF:- Handle batch failure in
connection.commit() in WriteWorkload#upsertData
0aec1e6 is described below
commit 0aec1e677015dbca33067e07b155e7ca39534940
Author: Monani Mihir <mmon...@salesforce.com>
AuthorDate: Fri Mar 15 13:56:35 2019 +0530
PHOENIX-5195 PHERF:- Handle batch failure in connection.commit() in
WriteWorkload#upsertData
---
.../phoenix/pherf/workload/WriteWorkload.java | 32 ++++++++++++----------
1 file changed, 18 insertions(+), 14 deletions(-)
diff --git
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/WriteWorkload.java
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/WriteWorkload.java
index 205b481..019c326 100644
---
a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/WriteWorkload.java
+++
b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/WriteWorkload.java
@@ -24,7 +24,6 @@ import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.SQLException;
-import java.sql.Timestamp;
import java.sql.Types;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
@@ -35,7 +34,6 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
-import org.apache.hadoop.hbase.util.Bytes;
import org.apache.phoenix.pherf.PherfConstants;
import org.apache.phoenix.pherf.PherfConstants.GeneratePhoenixStats;
import org.apache.phoenix.pherf.configuration.Column;
@@ -292,26 +290,32 @@ public class WriteWorkload implements Workload {
rowsCreated += result;
}
}
- connection.commit();
- duration = System.currentTimeMillis() - last;
- logger.info("Writer (" +
Thread.currentThread().getName()
- + ") committed Batch. Total " +
getBatchSize()
- + " rows for this thread (" +
this.hashCode() + ") in ("
- + duration + ") Ms");
-
- if (i % PherfConstants.LOG_PER_NROWS == 0 && i !=
0) {
- dataLoadThreadTime
- .add(tableName,
Thread.currentThread().getName(), i,
- System.currentTimeMillis() -
logStartTime);
- logStartTime = System.currentTimeMillis();
+ try {
+ connection.commit();
+ duration = System.currentTimeMillis() - last;
+ logger.info("Writer (" +
Thread.currentThread().getName()
+ + ") committed Batch. Total " +
getBatchSize()
+ + " rows for this thread (" +
this.hashCode() + ") in ("
+ + duration + ") Ms");
+
+ if (i % PherfConstants.LOG_PER_NROWS == 0 && i
!= 0) {
+ dataLoadThreadTime.add(tableName,
+ Thread.currentThread().getName(), i,
+ System.currentTimeMillis() -
logStartTime);
+ }
+ } catch (SQLException e) {
+ logger.warn("SQLException in commit
operation", e);
}
+ logStartTime = System.currentTimeMillis();
// Pause for throttling if configured to do so
Thread.sleep(threadSleepDuration);
// Re-compute the start time for the next batch
last = System.currentTimeMillis();
}
}
+ } catch (SQLException e) {
+ throw e;
} finally {
// Need to keep the statement open to send the remaining
batch of updates
if (!useBatchApi && stmt != null) {
