Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Revert "HBASE-14361 Investigate unused connection objects" 

This reverts commit 6c16d244bb.
This commit is contained in:
stack 2015-09-10 14:18:03 -07:00
parent 4418f3e025
commit bf26088d7b
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSink.java
View File

@ -72,7 +72,7 @@ public class ReplicationSink {
private static final Log LOG = LogFactory.getLog(ReplicationSink.class);
private final Configuration conf;
private Connection sharedHtableCon;
private final Connection sharedHtableCon;
private final MetricsSink metrics;
private final AtomicLong totalReplicatedEdits = new AtomicLong();
@ -88,6 +88,7 @@ public class ReplicationSink {
this.conf = HBaseConfiguration.create(conf);
decorateConf();
this.metrics = new MetricsSink();
this.sharedHtableCon = ConnectionFactory.createConnection(this.conf);
}
/**
@ -212,9 +213,7 @@ public class ReplicationSink {
*/
public void stopReplicationSinkServices() {
try {
if (this.sharedHtableCon != null) {
this.sharedHtableCon.close();
}
} catch (IOException e) {
LOG.warn("IOException while closing the connection", e); // ignoring as we are closing.
}
@ -233,9 +232,6 @@ public class ReplicationSink {
}
Table table = null;
try {
if (this.sharedHtableCon == null) {
this.sharedHtableCon = ConnectionFactory.createConnection(this.conf);
}
table = this.sharedHtableCon.getTable(tableName);
for (List<Row> rows : allRows) {
table.batch(rows, null);