You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2014/06/27 17:27:35 UTC
[03/11] git commit: close CqlRecordWriter clients when finished patch
by Peter Williams; reviewed by jbellis for CASSANDRA-7459
close CqlRecordWriter clients when finished
patch by Peter Williams; reviewed by jbellis for CASSANDRA-7459
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/536ae7ae
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/536ae7ae
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/536ae7ae
Branch: refs/heads/cassandra-2.1.0
Commit: 536ae7ae98a5901cf1aa6ae6ac60a17e2518fcb7
Parents: e324231
Author: Jonathan Ellis <jb...@apache.org>
Authored: Fri Jun 27 10:26:29 2014 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Fri Jun 27 10:26:53 2014 -0500
----------------------------------------------------------------------
CHANGES.txt | 1 +
src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java | 3 +++
2 files changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/536ae7ae/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index d587a94..e722392 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -3,6 +3,7 @@
* Fix inconsistent use of consistencyForCommit that allowed LOCAL_QUORUM
operations to incorrect become full QUORUM (CASSANDRA-7345)
* Properly handle unrecognized opcodes and flags (CASSANDRA-7440)
+ * (Hadoop) close CqlRecordWriter clients when finished (CASSANDRA-7459)
2.0.9
http://git-wip-us.apache.org/repos/asf/cassandra/blob/536ae7ae/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
index ee7aabf..b967494 100644
--- a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
+++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
@@ -279,6 +279,9 @@ final class CqlRecordWriter extends AbstractColumnFamilyRecordWriter<Map<String,
}
}
}
+
+ // close all our connections once we are done.
+ closeInternal();
}
/** get prepared statement id from cache, otherwise prepare it from Cassandra server*/