cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject [02/11] git commit: close CqlRecordWriter clients when finished patch by Peter Williams; reviewed by jbellis for CASSANDRA-7459
Date Fri, 27 Jun 2014 15:27:34 GMT
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 <jbellis@apache.org>
Authored: Fri Jun 27 10:26:29 2014 -0500
Committer: Jonathan Ellis <jbellis@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*/


Mime
View raw message