cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject [10/13] git commit: add one more compactedRow.close on empty (#4492)
Date Wed, 19 Dec 2012 02:48:06 GMT
add one more compactedRow.close on empty (#4492)


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/e792187b
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e792187b
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e792187b

Branch: refs/heads/cassandra-1.2.0
Commit: e792187bce376756284f784ef6c66e8d4331cef1
Parents: 82db566
Author: Jonathan Ellis <jbellis@apache.org>
Authored: Tue Dec 18 20:47:36 2012 -0600
Committer: Jonathan Ellis <jbellis@apache.org>
Committed: Tue Dec 18 20:47:36 2012 -0600

----------------------------------------------------------------------
 .../db/compaction/ParallelCompactionIterable.java  |    8 ++++++++
 1 files changed, 8 insertions(+), 0 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/e792187b/src/java/org/apache/cassandra/db/compaction/ParallelCompactionIterable.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/compaction/ParallelCompactionIterable.java b/src/java/org/apache/cassandra/db/compaction/ParallelCompactionIterable.java
index fc52393..933b44c 100644
--- a/src/java/org/apache/cassandra/db/compaction/ParallelCompactionIterable.java
+++ b/src/java/org/apache/cassandra/db/compaction/ParallelCompactionIterable.java
@@ -115,6 +115,14 @@ public class ParallelCompactionIterable extends AbstractCompactionIterable
             if (compactedRow.isEmpty())
             {
                 controller.invalidateCachedRow(compactedRow.key);
+                try
+                {
+                    compactedRow.close();
+                }
+                catch (IOException e)
+                {
+                    throw new RuntimeException(e);
+                }
                 return null;
             }
             else


Mime
View raw message