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.0 Commit: 536ae7ae98a5901cf1aa6ae6ac60a17e2518fcb7 Parents: e324231 Author: Jonathan Ellis <jbel...@apache.org> Authored: Fri Jun 27 10:26:29 2014 -0500 Committer: Jonathan Ellis <jbel...@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*/