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:33 UTC
[01/11] git commit: Properly handle unrecognized opcodes and flags
Repository: cassandra
Updated Branches:
refs/heads/cassandra-2.0 e32423159 -> 536ae7ae9
refs/heads/cassandra-2.1 12c694edb -> c148e2ada
refs/heads/cassandra-2.1.0 8aa2b791d -> bd6a766f9
refs/heads/trunk da1981cc4 -> 0494e8f27
Properly handle unrecognized opcodes and flags
Patch by Tyler Hobbs; reviewed by Sylvain Lebresne for CASSANDRA-7440
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/e3242315
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e3242315
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e3242315
Branch: refs/heads/cassandra-2.1.0
Commit: e32423159d9b31131cc95bccfcfa6b5dabbc070a
Parents: 2b973b9
Author: Tyler Hobbs <ty...@datastax.com>
Authored: Fri Jun 27 09:28:18 2014 -0500
Committer: Tyler Hobbs <ty...@datastax.com>
Committed: Fri Jun 27 09:28:18 2014 -0500
----------------------------------------------------------------------
CHANGES.txt | 1 +
src/java/org/apache/cassandra/transport/Frame.java | 7 ++++---
src/java/org/apache/cassandra/transport/Message.java | 2 ++
3 files changed, 7 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/e3242315/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 365722f..d587a94 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -2,6 +2,7 @@
* Fix race in FileCacheService RemovalListener (CASSANDRA-7278)
* 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)
2.0.9
http://git-wip-us.apache.org/repos/asf/cassandra/blob/e3242315/src/java/org/apache/cassandra/transport/Frame.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/transport/Frame.java b/src/java/org/apache/cassandra/transport/Frame.java
index 6472b39..89755df 100644
--- a/src/java/org/apache/cassandra/transport/Frame.java
+++ b/src/java/org/apache/cassandra/transport/Frame.java
@@ -92,14 +92,15 @@ public class Frame
COMPRESSED,
TRACING;
+ private static final Flag[] ALL_VALUES = values();
+
public static EnumSet<Flag> deserialize(int flags)
{
EnumSet<Flag> set = EnumSet.noneOf(Flag.class);
- Flag[] values = Flag.values();
- for (int n = 0; n < 8; n++)
+ for (int n = 0; n < ALL_VALUES.length; n++)
{
if ((flags & (1 << n)) != 0)
- set.add(values[n]);
+ set.add(ALL_VALUES[n]);
}
return set;
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/e3242315/src/java/org/apache/cassandra/transport/Message.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/transport/Message.java b/src/java/org/apache/cassandra/transport/Message.java
index 0731081..eea3b48 100644
--- a/src/java/org/apache/cassandra/transport/Message.java
+++ b/src/java/org/apache/cassandra/transport/Message.java
@@ -103,6 +103,8 @@ public abstract class Message
public static Type fromOpcode(int opcode, Direction direction)
{
+ if (opcode >= opcodeIdx.length)
+ throw new ProtocolException(String.format("Unknown opcode %d", opcode));
Type t = opcodeIdx[opcode];
if (t == null)
throw new ProtocolException(String.format("Unknown opcode %d", opcode));
[03/11] git commit: close CqlRecordWriter clients when finished patch
by Peter Williams; reviewed by jbellis for CASSANDRA-7459
Posted by jb...@apache.org.
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*/
[11/11] git commit: Merge branch 'cassandra-2.1' into trunk
Posted by jb...@apache.org.
Merge branch 'cassandra-2.1' into trunk
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/0494e8f2
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/0494e8f2
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/0494e8f2
Branch: refs/heads/trunk
Commit: 0494e8f279409050b7be87da2a011bdf05ab6a66
Parents: da1981c c148e2a
Author: Jonathan Ellis <jb...@apache.org>
Authored: Fri Jun 27 10:27:27 2014 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Fri Jun 27 10:27:27 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/0494e8f2/CHANGES.txt
----------------------------------------------------------------------
[06/11] git commit: Merge branch 'cassandra-2.0' into cassandra-2.1.0
Posted by jb...@apache.org.
Merge branch 'cassandra-2.0' into cassandra-2.1.0
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/bd6a766f
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/bd6a766f
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/bd6a766f
Branch: refs/heads/cassandra-2.1.0
Commit: bd6a766f983789ca315b218781d2b347c2e09248
Parents: 8aa2b79 536ae7a
Author: Jonathan Ellis <jb...@apache.org>
Authored: Fri Jun 27 10:27:03 2014 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Fri Jun 27 10:27:03 2014 -0500
----------------------------------------------------------------------
CHANGES.txt | 2 ++
.../org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java | 3 +++
src/java/org/apache/cassandra/transport/Frame.java | 7 ++++---
src/java/org/apache/cassandra/transport/Message.java | 2 ++
4 files changed, 11 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/CHANGES.txt
----------------------------------------------------------------------
diff --cc CHANGES.txt
index 95921ff,e722392..47a5992
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@@ -6,36 -2,30 +6,38 @@@ Merged from 2.0
* Fix race in FileCacheService RemovalListener (CASSANDRA-7278)
* 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
- * Fix CC#collectTimeOrderedData() tombstone optimisations (CASSANDRA-7394)
- * Fix assertion error in CL.ANY timeout handling (CASSANDRA-7364)
- * Handle empty CFs in Memtable#maybeUpdateLiveRatio() (CASSANDRA-7401)
+2.1.0-rc2
+ * Fix heap size calculation for CompoundSparseCellName and
+ CompoundSparseCellName.WithCollection (CASSANDRA-7421)
+ * Allow counter mutations in UNLOGGED batches (CASSANDRA-7351)
+ * Modify reconcile logic to always pick a tombstone over a counter cell
+ (CASSANDRA-7346)
+ * Avoid incremental compaction on Windows (CASSANDRA-7365)
+ * Fix exception when querying a composite-keyed table with a collection index
+ (CASSANDRA-7372)
+ * Use node's host id in place of counter ids (CASSANDRA-7366)
* Fix native protocol CAS batches (CASSANDRA-7337)
+ * Reduce likelihood of contention on local paxos locking (CASSANDRA-7359)
+ * Upgrade to Pig 0.12.1 (CASSANDRA-6556)
+ * Make sure we clear out repair sessions from netstats (CASSANDRA-7329)
+ * Don't fail streams on failure detector downs (CASSANDRA-3569)
+ * Add optional keyspace to DROP INDEX statement (CASSANDRA-7314)
+ * Reduce run time for CQL tests (CASSANDRA-7327)
+ * Fix heap size calculation on Windows (CASSANDRA-7352, 7353)
+ * RefCount native frames from netty (CASSANDRA-7245)
+ * Use tarball dir instead of /var for default paths (CASSANDRA-7136)
+ * Remove rows_per_partition_to_cache keyword (CASSANDRA-7193)
+ * Fix schema change response in native protocol v3 (CASSANDRA-7413)
+Merged from 2.0:
+ * Fix assertion error in CL.ANY timeout handling (CASSANDRA-7364)
* Add per-CF range read request latency metrics (CASSANDRA-7338)
* Fix NPE in StreamTransferTask.createMessageForRetry() (CASSANDRA-7323)
- * Add conditional CREATE/DROP USER support (CASSANDRA-7264)
- * Swap local and global default read repair chances (CASSANDRA-7320)
- * Add missing iso8601 patterns for date strings (CASSANDRA-6973)
- * Support selecting multiple rows in a partition using IN (CASSANDRA-6875)
- * cqlsh: always emphasize the partition key in DESC output (CASSANDRA-7274)
- * Copy compaction options to make sure they are reloaded (CASSANDRA-7290)
- * Add option to do more aggressive tombstone compactions (CASSANDRA-6563)
- * Don't try to compact already-compacting files in HHOM (CASSANDRA-7288)
- * Add authentication support to shuffle (CASSANDRA-6484)
- * Cqlsh counts non-empty lines for "Blank lines" warning (CASSANDRA-7325)
* Make StreamSession#closeSession() idempotent (CASSANDRA-7262)
* Fix infinite loop on exception while streaming (CASSANDRA-7330)
- * Reference sstables before populating key cache (CASSANDRA-7234)
* Account for range tombstones in min/max column names (CASSANDRA-7235)
* Improve sub range repair validation (CASSANDRA-7317)
* Accept subtypes for function results, type casts (CASSANDRA-6766)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/src/java/org/apache/cassandra/transport/Frame.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/src/java/org/apache/cassandra/transport/Message.java
----------------------------------------------------------------------
[07/11] git commit: Merge branch 'cassandra-2.0' into cassandra-2.1.0
Posted by jb...@apache.org.
Merge branch 'cassandra-2.0' into cassandra-2.1.0
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/bd6a766f
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/bd6a766f
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/bd6a766f
Branch: refs/heads/cassandra-2.1
Commit: bd6a766f983789ca315b218781d2b347c2e09248
Parents: 8aa2b79 536ae7a
Author: Jonathan Ellis <jb...@apache.org>
Authored: Fri Jun 27 10:27:03 2014 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Fri Jun 27 10:27:03 2014 -0500
----------------------------------------------------------------------
CHANGES.txt | 2 ++
.../org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java | 3 +++
src/java/org/apache/cassandra/transport/Frame.java | 7 ++++---
src/java/org/apache/cassandra/transport/Message.java | 2 ++
4 files changed, 11 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/CHANGES.txt
----------------------------------------------------------------------
diff --cc CHANGES.txt
index 95921ff,e722392..47a5992
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@@ -6,36 -2,30 +6,38 @@@ Merged from 2.0
* Fix race in FileCacheService RemovalListener (CASSANDRA-7278)
* 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
- * Fix CC#collectTimeOrderedData() tombstone optimisations (CASSANDRA-7394)
- * Fix assertion error in CL.ANY timeout handling (CASSANDRA-7364)
- * Handle empty CFs in Memtable#maybeUpdateLiveRatio() (CASSANDRA-7401)
+2.1.0-rc2
+ * Fix heap size calculation for CompoundSparseCellName and
+ CompoundSparseCellName.WithCollection (CASSANDRA-7421)
+ * Allow counter mutations in UNLOGGED batches (CASSANDRA-7351)
+ * Modify reconcile logic to always pick a tombstone over a counter cell
+ (CASSANDRA-7346)
+ * Avoid incremental compaction on Windows (CASSANDRA-7365)
+ * Fix exception when querying a composite-keyed table with a collection index
+ (CASSANDRA-7372)
+ * Use node's host id in place of counter ids (CASSANDRA-7366)
* Fix native protocol CAS batches (CASSANDRA-7337)
+ * Reduce likelihood of contention on local paxos locking (CASSANDRA-7359)
+ * Upgrade to Pig 0.12.1 (CASSANDRA-6556)
+ * Make sure we clear out repair sessions from netstats (CASSANDRA-7329)
+ * Don't fail streams on failure detector downs (CASSANDRA-3569)
+ * Add optional keyspace to DROP INDEX statement (CASSANDRA-7314)
+ * Reduce run time for CQL tests (CASSANDRA-7327)
+ * Fix heap size calculation on Windows (CASSANDRA-7352, 7353)
+ * RefCount native frames from netty (CASSANDRA-7245)
+ * Use tarball dir instead of /var for default paths (CASSANDRA-7136)
+ * Remove rows_per_partition_to_cache keyword (CASSANDRA-7193)
+ * Fix schema change response in native protocol v3 (CASSANDRA-7413)
+Merged from 2.0:
+ * Fix assertion error in CL.ANY timeout handling (CASSANDRA-7364)
* Add per-CF range read request latency metrics (CASSANDRA-7338)
* Fix NPE in StreamTransferTask.createMessageForRetry() (CASSANDRA-7323)
- * Add conditional CREATE/DROP USER support (CASSANDRA-7264)
- * Swap local and global default read repair chances (CASSANDRA-7320)
- * Add missing iso8601 patterns for date strings (CASSANDRA-6973)
- * Support selecting multiple rows in a partition using IN (CASSANDRA-6875)
- * cqlsh: always emphasize the partition key in DESC output (CASSANDRA-7274)
- * Copy compaction options to make sure they are reloaded (CASSANDRA-7290)
- * Add option to do more aggressive tombstone compactions (CASSANDRA-6563)
- * Don't try to compact already-compacting files in HHOM (CASSANDRA-7288)
- * Add authentication support to shuffle (CASSANDRA-6484)
- * Cqlsh counts non-empty lines for "Blank lines" warning (CASSANDRA-7325)
* Make StreamSession#closeSession() idempotent (CASSANDRA-7262)
* Fix infinite loop on exception while streaming (CASSANDRA-7330)
- * Reference sstables before populating key cache (CASSANDRA-7234)
* Account for range tombstones in min/max column names (CASSANDRA-7235)
* Improve sub range repair validation (CASSANDRA-7317)
* Accept subtypes for function results, type casts (CASSANDRA-6766)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/src/java/org/apache/cassandra/transport/Frame.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/src/java/org/apache/cassandra/transport/Message.java
----------------------------------------------------------------------
[09/11] git commit: Merge branch 'cassandra-2.1.0' into cassandra-2.1
Posted by jb...@apache.org.
Merge branch 'cassandra-2.1.0' into cassandra-2.1
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/c148e2ad
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/c148e2ad
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/c148e2ad
Branch: refs/heads/trunk
Commit: c148e2ada997a0ee8fb5b43a795a808923d139c3
Parents: 12c694e bd6a766
Author: Jonathan Ellis <jb...@apache.org>
Authored: Fri Jun 27 10:27:16 2014 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Fri Jun 27 10:27:16 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/c148e2ad/CHANGES.txt
----------------------------------------------------------------------
[02/11] git commit: close CqlRecordWriter clients when finished patch
by Peter Williams; reviewed by jbellis for CASSANDRA-7459
Posted by jb...@apache.org.
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 <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*/
[05/11] git commit: close CqlRecordWriter clients when finished patch
by Peter Williams; reviewed by jbellis for CASSANDRA-7459
Posted by jb...@apache.org.
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/trunk
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*/
[08/11] git commit: Merge branch 'cassandra-2.0' into cassandra-2.1.0
Posted by jb...@apache.org.
Merge branch 'cassandra-2.0' into cassandra-2.1.0
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/bd6a766f
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/bd6a766f
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/bd6a766f
Branch: refs/heads/trunk
Commit: bd6a766f983789ca315b218781d2b347c2e09248
Parents: 8aa2b79 536ae7a
Author: Jonathan Ellis <jb...@apache.org>
Authored: Fri Jun 27 10:27:03 2014 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Fri Jun 27 10:27:03 2014 -0500
----------------------------------------------------------------------
CHANGES.txt | 2 ++
.../org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java | 3 +++
src/java/org/apache/cassandra/transport/Frame.java | 7 ++++---
src/java/org/apache/cassandra/transport/Message.java | 2 ++
4 files changed, 11 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/CHANGES.txt
----------------------------------------------------------------------
diff --cc CHANGES.txt
index 95921ff,e722392..47a5992
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@@ -6,36 -2,30 +6,38 @@@ Merged from 2.0
* Fix race in FileCacheService RemovalListener (CASSANDRA-7278)
* 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
- * Fix CC#collectTimeOrderedData() tombstone optimisations (CASSANDRA-7394)
- * Fix assertion error in CL.ANY timeout handling (CASSANDRA-7364)
- * Handle empty CFs in Memtable#maybeUpdateLiveRatio() (CASSANDRA-7401)
+2.1.0-rc2
+ * Fix heap size calculation for CompoundSparseCellName and
+ CompoundSparseCellName.WithCollection (CASSANDRA-7421)
+ * Allow counter mutations in UNLOGGED batches (CASSANDRA-7351)
+ * Modify reconcile logic to always pick a tombstone over a counter cell
+ (CASSANDRA-7346)
+ * Avoid incremental compaction on Windows (CASSANDRA-7365)
+ * Fix exception when querying a composite-keyed table with a collection index
+ (CASSANDRA-7372)
+ * Use node's host id in place of counter ids (CASSANDRA-7366)
* Fix native protocol CAS batches (CASSANDRA-7337)
+ * Reduce likelihood of contention on local paxos locking (CASSANDRA-7359)
+ * Upgrade to Pig 0.12.1 (CASSANDRA-6556)
+ * Make sure we clear out repair sessions from netstats (CASSANDRA-7329)
+ * Don't fail streams on failure detector downs (CASSANDRA-3569)
+ * Add optional keyspace to DROP INDEX statement (CASSANDRA-7314)
+ * Reduce run time for CQL tests (CASSANDRA-7327)
+ * Fix heap size calculation on Windows (CASSANDRA-7352, 7353)
+ * RefCount native frames from netty (CASSANDRA-7245)
+ * Use tarball dir instead of /var for default paths (CASSANDRA-7136)
+ * Remove rows_per_partition_to_cache keyword (CASSANDRA-7193)
+ * Fix schema change response in native protocol v3 (CASSANDRA-7413)
+Merged from 2.0:
+ * Fix assertion error in CL.ANY timeout handling (CASSANDRA-7364)
* Add per-CF range read request latency metrics (CASSANDRA-7338)
* Fix NPE in StreamTransferTask.createMessageForRetry() (CASSANDRA-7323)
- * Add conditional CREATE/DROP USER support (CASSANDRA-7264)
- * Swap local and global default read repair chances (CASSANDRA-7320)
- * Add missing iso8601 patterns for date strings (CASSANDRA-6973)
- * Support selecting multiple rows in a partition using IN (CASSANDRA-6875)
- * cqlsh: always emphasize the partition key in DESC output (CASSANDRA-7274)
- * Copy compaction options to make sure they are reloaded (CASSANDRA-7290)
- * Add option to do more aggressive tombstone compactions (CASSANDRA-6563)
- * Don't try to compact already-compacting files in HHOM (CASSANDRA-7288)
- * Add authentication support to shuffle (CASSANDRA-6484)
- * Cqlsh counts non-empty lines for "Blank lines" warning (CASSANDRA-7325)
* Make StreamSession#closeSession() idempotent (CASSANDRA-7262)
* Fix infinite loop on exception while streaming (CASSANDRA-7330)
- * Reference sstables before populating key cache (CASSANDRA-7234)
* Account for range tombstones in min/max column names (CASSANDRA-7235)
* Improve sub range repair validation (CASSANDRA-7317)
* Accept subtypes for function results, type casts (CASSANDRA-6766)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/src/java/org/apache/cassandra/transport/Frame.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/bd6a766f/src/java/org/apache/cassandra/transport/Message.java
----------------------------------------------------------------------
[04/11] git commit: close CqlRecordWriter clients when finished patch
by Peter Williams; reviewed by jbellis for CASSANDRA-7459
Posted by jb...@apache.org.
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
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*/
[10/11] git commit: Merge branch 'cassandra-2.1.0' into cassandra-2.1
Posted by jb...@apache.org.
Merge branch 'cassandra-2.1.0' into cassandra-2.1
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/c148e2ad
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/c148e2ad
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/c148e2ad
Branch: refs/heads/cassandra-2.1
Commit: c148e2ada997a0ee8fb5b43a795a808923d139c3
Parents: 12c694e bd6a766
Author: Jonathan Ellis <jb...@apache.org>
Authored: Fri Jun 27 10:27:16 2014 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Fri Jun 27 10:27:16 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/c148e2ad/CHANGES.txt
----------------------------------------------------------------------