You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by al...@apache.org on 2014/04/01 03:26:22 UTC
[1/8] git commit: Fix typo in DeletionInfo
Repository: cassandra
Updated Branches:
refs/heads/trunk 93bd9ec25 -> 3b1423945
Fix typo in DeletionInfo
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/91130373
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/91130373
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/91130373
Branch: refs/heads/trunk
Commit: 91130373f474c8a8d8f5100044507553d2a9b872
Parents: 35d4b5d
Author: Sylvain Lebresne <sy...@datastax.com>
Authored: Mon Mar 24 17:06:01 2014 +0100
Committer: Sylvain Lebresne <sy...@datastax.com>
Committed: Mon Mar 24 17:06:01 2014 +0100
----------------------------------------------------------------------
src/java/org/apache/cassandra/db/DeletionInfo.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/91130373/src/java/org/apache/cassandra/db/DeletionInfo.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/DeletionInfo.java b/src/java/org/apache/cassandra/db/DeletionInfo.java
index 91af9fd..ce683d1 100644
--- a/src/java/org/apache/cassandra/db/DeletionInfo.java
+++ b/src/java/org/apache/cassandra/db/DeletionInfo.java
@@ -227,7 +227,7 @@ public class DeletionInfo
public boolean mayModify(DeletionInfo delInfo)
{
return topLevel.markedForDeleteAt > delInfo.topLevel.markedForDeleteAt
- || ranges == null;
+ || ranges != null;
}
@Override
[2/8] git commit: Update versions and NEWS for 1.2.16 release
Posted by al...@apache.org.
Update versions and NEWS for 1.2.16 release
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/05fcfa2b
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/05fcfa2b
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/05fcfa2b
Branch: refs/heads/trunk
Commit: 05fcfa2be4eba2cd6daeee62d943f48c45f42668
Parents: 9113037
Author: Sylvain Lebresne <sy...@datastax.com>
Authored: Mon Mar 24 17:16:15 2014 +0100
Committer: Sylvain Lebresne <sy...@datastax.com>
Committed: Mon Mar 24 17:16:15 2014 +0100
----------------------------------------------------------------------
NEWS.txt | 9 +++++++++
build.xml | 2 +-
debian/changelog | 6 ++++++
3 files changed, 16 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/05fcfa2b/NEWS.txt
----------------------------------------------------------------------
diff --git a/NEWS.txt b/NEWS.txt
index 771536d..f297634 100644
--- a/NEWS.txt
+++ b/NEWS.txt
@@ -14,6 +14,15 @@ restore snapshots created with the previous major version using the
using the provided 'sstableupgrade' tool.
+1.2.16
+======
+
+Upgrading
+---------
+ - Nothing specific to this release, but please see 1.2.15 if you are upgrading
+ from a previous version.
+
+
1.2.15
======
http://git-wip-us.apache.org/repos/asf/cassandra/blob/05fcfa2b/build.xml
----------------------------------------------------------------------
diff --git a/build.xml b/build.xml
index eaf35b5..5db0a6a 100644
--- a/build.xml
+++ b/build.xml
@@ -25,7 +25,7 @@
<property name="debuglevel" value="source,lines,vars"/>
<!-- default version and SCM information -->
- <property name="base.version" value="1.2.15"/>
+ <property name="base.version" value="1.2.16"/>
<property name="scm.connection" value="scm:git://git.apache.org/cassandra.git"/>
<property name="scm.developerConnection" value="scm:git://git.apache.org/cassandra.git"/>
<property name="scm.url" value="http://git-wip-us.apache.org/repos/asf?p=cassandra.git;a=tree"/>
http://git-wip-us.apache.org/repos/asf/cassandra/blob/05fcfa2b/debian/changelog
----------------------------------------------------------------------
diff --git a/debian/changelog b/debian/changelog
index bb8ecf2..50318c8 100644
--- a/debian/changelog
+++ b/debian/changelog
@@ -1,3 +1,9 @@
+cassandra (1.2.16) unstable; urgency=low
+
+ * New release
+
+ -- Sylvain Lebresne <sl...@apache.org> Mon, 24 Mar 2014 17:15:34 +0100
+
cassandra (1.2.15) unstable; urgency=low
* New release
[4/8] git commit: Merge branch 'cassandra-2.0' into cassandra-2.1
Posted by al...@apache.org.
Merge branch 'cassandra-2.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/2bb30af6
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2bb30af6
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2bb30af6
Branch: refs/heads/trunk
Commit: 2bb30af662069aa35ea8e2dd1be4890cd70bf330
Parents: 3632811 07dc6e1
Author: Sylvain Lebresne <sy...@datastax.com>
Authored: Mon Mar 31 17:44:22 2014 +0200
Committer: Sylvain Lebresne <sy...@datastax.com>
Committed: Mon Mar 31 17:44:22 2014 +0200
----------------------------------------------------------------------
doc/native_protocol_v2.spec | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
[5/8] git commit: Fix batchlogManager#deleteBatch() use of
millisecond timsestamps
Posted by al...@apache.org.
Fix batchlogManager#deleteBatch() use of millisecond timsestamps
patch by Aleksey Yeschenko; reviewed by Pavel Yaskevich for
CASSANDRA-6822
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/dc3f22b6
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/dc3f22b6
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/dc3f22b6
Branch: refs/heads/trunk
Commit: dc3f22b61d988d559d0078c557623d07abef8584
Parents: 05fcfa2
Author: Aleksey Yeschenko <al...@apache.org>
Authored: Tue Apr 1 04:16:48 2014 +0300
Committer: Aleksey Yeschenko <al...@apache.org>
Committed: Tue Apr 1 04:16:48 2014 +0300
----------------------------------------------------------------------
CHANGES.txt | 5 +++++
src/java/org/apache/cassandra/db/BatchlogManager.java | 2 +-
test/unit/org/apache/cassandra/db/BatchlogManagerTest.java | 3 +++
3 files changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/dc3f22b6/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index fa46c2e..a9a93a4 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,3 +1,8 @@
+1.2.17
+ * Fix BatchlogManager#deleteBatch() use of millisecond timsestamps
+ (CASSANDRA-6822)
+
+
1.2.16
* Add UNLOGGED, COUNTER options to BATCH documentation (CASSANDRA-6816)
* add extra SSL cipher suites (CASSANDRA-6613)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/dc3f22b6/src/java/org/apache/cassandra/db/BatchlogManager.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/BatchlogManager.java b/src/java/org/apache/cassandra/db/BatchlogManager.java
index 90dfd47..7bfbf0c 100644
--- a/src/java/org/apache/cassandra/db/BatchlogManager.java
+++ b/src/java/org/apache/cassandra/db/BatchlogManager.java
@@ -246,7 +246,7 @@ public class BatchlogManager implements BatchlogManagerMBean
private void deleteBatch(UUID id)
{
RowMutation mutation = new RowMutation(Table.SYSTEM_KS, UUIDType.instance.decompose(id));
- mutation.delete(new QueryPath(SystemTable.BATCHLOG_CF, null, null), System.currentTimeMillis());
+ mutation.delete(new QueryPath(SystemTable.BATCHLOG_CF, null, null), FBUtilities.timestampMicros());
mutation.apply();
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/dc3f22b6/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
----------------------------------------------------------------------
diff --git a/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java b/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
index 08728fc..1d89f4b 100644
--- a/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
+++ b/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
@@ -67,6 +67,9 @@ public class BatchlogManagerTest extends SchemaLoader
BatchlogManager.getBatchlogMutationFor(Collections.singleton(mutation), UUIDGen.getTimeUUID(), timestamp * 1000).apply();
}
+ // Flush the batchlog to disk (see CASSANDRA-6822).
+ Table.open(Table.SYSTEM_KS).getColumnFamilyStore(SystemTable.BATCHLOG_CF).forceFlush();
+
assertEquals(1000, BatchlogManager.instance.countAllBatches());
assertEquals(0, BatchlogManager.instance.getTotalBatchesReplayed());
[6/8] git commit: Merge branch 'cassandra-1.2' into cassandra-2.0
Posted by al...@apache.org.
Merge branch 'cassandra-1.2' into cassandra-2.0
Conflicts:
CHANGES.txt
NEWS.txt
build.xml
debian/changelog
src/java/org/apache/cassandra/db/BatchlogManager.java
src/java/org/apache/cassandra/db/DeletionInfo.java
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/0fce7ace
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/0fce7ace
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/0fce7ace
Branch: refs/heads/trunk
Commit: 0fce7ace02d19a791916b163eec4212579668799
Parents: 07dc6e1 dc3f22b
Author: Aleksey Yeschenko <al...@apache.org>
Authored: Tue Apr 1 04:22:39 2014 +0300
Committer: Aleksey Yeschenko <al...@apache.org>
Committed: Tue Apr 1 04:22:39 2014 +0300
----------------------------------------------------------------------
CHANGES.txt | 2 ++
src/java/org/apache/cassandra/db/BatchlogManager.java | 2 +-
test/unit/org/apache/cassandra/db/BatchlogManagerTest.java | 3 +++
3 files changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/0fce7ace/CHANGES.txt
----------------------------------------------------------------------
diff --cc CHANGES.txt
index e9dca70,a9a93a4..b4f84e4
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@@ -1,89 -1,16 +1,91 @@@
-1.2.17
+2.0.7
+ * Restrict Windows to parallel repairs (CASSANDRA-6907)
+ * (Hadoop) Allow manually specifying start/end tokens in CFIF (CASSANDRA-6436)
+ * Fix NPE in MeteredFlusher (CASSANDRA-6820)
+ * Fix race processing range scan responses (CASSANDRA-6820)
+ * Allow deleting snapshots from dropped keyspaces (CASSANDRA-6821)
+ * Add uuid() function (CASSANDRA-6473)
+ * Omit tombstones from schema digests (CASSANDRA-6862)
+ * Include correct consistencyLevel in LWT timeout (CASSANDRA-6884)
+ * Lower chances for losing new SSTables during nodetool refresh and
+ ColumnFamilyStore.loadNewSSTables (CASSANDRA-6514)
+ * Add support for DELETE ... IF EXISTS to CQL3 (CASSANDRA-5708)
+ * Update hadoop_cql3_word_count example (CASSANDRA-6793)
+ * Fix handling of RejectedExecution in sync Thrift server (CASSANDRA-6788)
+ * Log more information when exceeding tombstone_warn_threshold (CASSANDRA-6865)
+ * Fix truncate to not abort due to unreachable fat clients (CASSANDRA-6864)
+ * Fix schema concurrency exceptions (CASSANDRA-6841)
+ * Fix leaking validator FH in StreamWriter (CASSANDRA-6832)
+ * Fix saving triggers to schema (CASSANDRA-6789)
+ * Fix trigger mutations when base mutation list is immutable (CASSANDRA-6790)
+ * Fix accounting in FileCacheService to allow re-using RAR (CASSANDRA-6838)
+ * Fix static counter columns (CASSANDRA-6827)
+ * Restore expiring->deleted (cell) compaction optimization (CASSANDRA-6844)
+ * Fix CompactionManager.needsCleanup (CASSANDRA-6845)
+ * Correctly compare BooleanType values other than 0 and 1 (CASSANDRA-6779)
+ * Read message id as string from earlier versions (CASSANDRA-6840)
+ * Properly use the Paxos consistency for (non-protocol) batch (CASSANDRA-6837)
+ * Add paranoid disk failure option (CASSANDRA-6646)
+ * Improve PerRowSecondaryIndex performance (CASSANDRA-6876)
+ * Extend triggers to support CAS updates (CASSANDRA-6882)
+ * Static columns with IF NOT EXISTS don't always work as expected (CASSANDRA-6873)
+ * Fix paging with SELECT DISTINCT (CASSANDRA-6857)
+ * Fix UnsupportedOperationException on CAS timeout (CASSANDRA-6923)
+ * Improve MeteredFlusher handling of MF-unaffected column families
+ (CASSANDRA-6867)
+ * Add CqlRecordReader using native pagination (CASSANDRA-6311)
+ * Add QueryHandler interface (CASSANDRA-6659)
+ * Track liveRatio per-memtable, not per-CF (CASSANDRA-6945)
+Merged from 1.2:
+ * Add UNLOGGED, COUNTER options to BATCH documentation (CASSANDRA-6816)
+ * add extra SSL cipher suites (CASSANDRA-6613)
+ * fix nodetool getsstables for blob PK (CASSANDRA-6803)
+ * Fix BatchlogManager#deleteBatch() use of millisecond timsestamps
+ (CASSANDRA-6822)
-1.2.16
- * Add UNLOGGED, COUNTER options to BATCH documentation (CASSANDRA-6816)
- * add extra SSL cipher suites (CASSANDRA-6613)
- * fix nodetool getsstables for blob PK (CASSANDRA-6803)
+2.0.6
+ * Avoid race-prone second "scrub" of system keyspace (CASSANDRA-6797)
+ * Pool CqlRecordWriter clients by inetaddress rather than Range
+ (CASSANDRA-6665)
+ * Fix compaction_history timestamps (CASSANDRA-6784)
+ * Compare scores of full replica ordering in DES (CASSANDRA-6883)
+ * fix CME in SessionInfo updateProgress affecting netstats (CASSANDRA-6577)
+ * Allow repairing between specific replicas (CASSANDRA-6440)
+ * Allow per-dc enabling of hints (CASSANDRA-6157)
+ * Add compatibility for Hadoop 0.2.x (CASSANDRA-5201)
+ * Fix EstimatedHistogram races (CASSANDRA-6682)
+ * Failure detector correctly converts initial value to nanos (CASSANDRA-6658)
+ * Add nodetool taketoken to relocate vnodes (CASSANDRA-4445)
+ * Fix upgradesstables NPE for non-CF-based indexes (CASSANDRA-6645)
+ * Improve nodetool cfhistograms formatting (CASSANDRA-6360)
+ * Expose bulk loading progress over JMX (CASSANDRA-4757)
+ * Correctly handle null with IF conditions and TTL (CASSANDRA-6623)
+ * Account for range/row tombstones in tombstone drop
+ time histogram (CASSANDRA-6522)
+ * Stop CommitLogSegment.close() from calling sync() (CASSANDRA-6652)
+ * Make commitlog failure handling configurable (CASSANDRA-6364)
+ * Avoid overlaps in LCS (CASSANDRA-6688)
+ * Improve support for paginating over composites (CASSANDRA-4851)
+ * Fix count(*) queries in a mixed cluster (CASSANDRA-6707)
+ * Improve repair tasks(snapshot, differencing) concurrency (CASSANDRA-6566)
+ * Fix replaying pre-2.0 commit logs (CASSANDRA-6714)
+ * Add static columns to CQL3 (CASSANDRA-6561)
+ * Optimize single partition batch statements (CASSANDRA-6737)
+ * Disallow post-query re-ordering when paging (CASSANDRA-6722)
+ * Fix potential paging bug with deleted columns (CASSANDRA-6748)
+ * Fix NPE on BulkLoader caused by losing StreamEvent (CASSANDRA-6636)
+ * Fix truncating compression metadata (CASSANDRA-6791)
+ * Fix UPDATE updating PRIMARY KEY columns implicitly (CASSANDRA-6782)
+ * Fix IllegalArgumentException when updating from 1.2 with SuperColumns
+ (CASSANDRA-6733)
+ * FBUtilities.singleton() should use the CF comparator (CASSANDRA-6778)
+ * Fix CQLSStableWriter.addRow(Map<String, Object>) (CASSANDRA-6526)
+ * Fix HSHA server introducing corrupt data (CASSANDRA-6285)
+ * Fix CAS conditions for COMPACT STORAGE tables (CASSANDRA-6813)
+Merged from 1.2:
* Add CMSClassUnloadingEnabled JVM option (CASSANDRA-6541)
* Catch memtable flush exceptions during shutdown (CASSANDRA-6735)
- * Don't attempt cross-dc forwarding in mixed-version cluster with 1.1
- (CASSANDRA-6732)
* Fix broken streams when replacing with same IP (CASSANDRA-6622)
* Fix upgradesstables NPE for non-CF-based indexes (CASSANDRA-6645)
* Fix partition and range deletes not triggering flush (CASSANDRA-6655)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/0fce7ace/src/java/org/apache/cassandra/db/BatchlogManager.java
----------------------------------------------------------------------
diff --cc src/java/org/apache/cassandra/db/BatchlogManager.java
index 2e09285,7bfbf0c..b5e8297
--- a/src/java/org/apache/cassandra/db/BatchlogManager.java
+++ b/src/java/org/apache/cassandra/db/BatchlogManager.java
@@@ -242,8 -245,8 +242,8 @@@ public class BatchlogManager implement
private void deleteBatch(UUID id)
{
- RowMutation mutation = new RowMutation(Table.SYSTEM_KS, UUIDType.instance.decompose(id));
- mutation.delete(new QueryPath(SystemTable.BATCHLOG_CF, null, null), FBUtilities.timestampMicros());
+ RowMutation mutation = new RowMutation(Keyspace.SYSTEM_KS, UUIDType.instance.decompose(id));
- mutation.delete(SystemKeyspace.BATCHLOG_CF, System.currentTimeMillis());
++ mutation.delete(SystemKeyspace.BATCHLOG_CF, FBUtilities.timestampMicros());
mutation.apply();
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/0fce7ace/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
----------------------------------------------------------------------
diff --cc test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
index c664cd3,1d89f4b..537278a
--- a/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
+++ b/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
@@@ -67,6 -67,9 +67,9 @@@ public class BatchlogManagerTest extend
BatchlogManager.getBatchlogMutationFor(Collections.singleton(mutation), UUIDGen.getTimeUUID(), timestamp * 1000).apply();
}
+ // Flush the batchlog to disk (see CASSANDRA-6822).
- Table.open(Table.SYSTEM_KS).getColumnFamilyStore(SystemTable.BATCHLOG_CF).forceFlush();
++ Keyspace.open(Keyspace.SYSTEM_KS).getColumnFamilyStore(SystemKeyspace.BATCHLOG_CF).forceBlockingFlush();
+
assertEquals(1000, BatchlogManager.instance.countAllBatches());
assertEquals(0, BatchlogManager.instance.getTotalBatchesReplayed());
[8/8] git commit: Merge branch 'cassandra-2.1' into trunk
Posted by al...@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/3b142394
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/3b142394
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/3b142394
Branch: refs/heads/trunk
Commit: 3b14239459f2561b49abf2044fd874c939a9b0ff
Parents: 93bd9ec e5639f4
Author: Aleksey Yeschenko <al...@apache.org>
Authored: Tue Apr 1 04:26:04 2014 +0300
Committer: Aleksey Yeschenko <al...@apache.org>
Committed: Tue Apr 1 04:26:04 2014 +0300
----------------------------------------------------------------------
CHANGES.txt | 2 ++
doc/native_protocol_v2.spec | 1 +
src/java/org/apache/cassandra/db/BatchlogManager.java | 2 +-
test/unit/org/apache/cassandra/db/BatchlogManagerTest.java | 3 +++
4 files changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/3b142394/CHANGES.txt
----------------------------------------------------------------------
[3/8] git commit: Add missing entry in protocol spec (#6954)
Posted by al...@apache.org.
Add missing entry in protocol spec (#6954)
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/07dc6e18
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/07dc6e18
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/07dc6e18
Branch: refs/heads/trunk
Commit: 07dc6e189176bca07597e3fdb8d9d9f0e4240cef
Parents: d049017
Author: Sylvain Lebresne <sy...@datastax.com>
Authored: Mon Mar 31 17:43:32 2014 +0200
Committer: Sylvain Lebresne <sy...@datastax.com>
Committed: Mon Mar 31 17:43:41 2014 +0200
----------------------------------------------------------------------
doc/native_protocol_v2.spec | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/07dc6e18/doc/native_protocol_v2.spec
----------------------------------------------------------------------
diff --git a/doc/native_protocol_v2.spec b/doc/native_protocol_v2.spec
index 44061da..11d380f 100644
--- a/doc/native_protocol_v2.spec
+++ b/doc/native_protocol_v2.spec
@@ -523,6 +523,7 @@ Table of Contents
0x0007 Double
0x0008 Float
0x0009 Int
+ 0x000A Text
0x000B Timestamp
0x000C Uuid
0x000D Varchar
[7/8] git commit: Merge branch 'cassandra-2.0' into cassandra-2.1
Posted by al...@apache.org.
Merge branch 'cassandra-2.0' into cassandra-2.1
Conflicts:
src/java/org/apache/cassandra/db/BatchlogManager.java
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/e5639f44
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/e5639f44
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/e5639f44
Branch: refs/heads/trunk
Commit: e5639f44c3e5a345026219eb4e5a242aafa957c3
Parents: 2bb30af 0fce7ac
Author: Aleksey Yeschenko <al...@apache.org>
Authored: Tue Apr 1 04:25:40 2014 +0300
Committer: Aleksey Yeschenko <al...@apache.org>
Committed: Tue Apr 1 04:25:40 2014 +0300
----------------------------------------------------------------------
CHANGES.txt | 2 ++
src/java/org/apache/cassandra/db/BatchlogManager.java | 2 +-
test/unit/org/apache/cassandra/db/BatchlogManagerTest.java | 3 +++
3 files changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/e5639f44/CHANGES.txt
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/e5639f44/src/java/org/apache/cassandra/db/BatchlogManager.java
----------------------------------------------------------------------
diff --cc src/java/org/apache/cassandra/db/BatchlogManager.java
index 47eb77a,b5e8297..75f744c
--- a/src/java/org/apache/cassandra/db/BatchlogManager.java
+++ b/src/java/org/apache/cassandra/db/BatchlogManager.java
@@@ -235,8 -242,8 +235,8 @@@ public class BatchlogManager implement
private void deleteBatch(UUID id)
{
- RowMutation mutation = new RowMutation(Keyspace.SYSTEM_KS, UUIDType.instance.decompose(id));
+ Mutation mutation = new Mutation(Keyspace.SYSTEM_KS, UUIDType.instance.decompose(id));
- mutation.delete(SystemKeyspace.BATCHLOG_CF, System.currentTimeMillis());
+ mutation.delete(SystemKeyspace.BATCHLOG_CF, FBUtilities.timestampMicros());
mutation.apply();
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/e5639f44/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
----------------------------------------------------------------------
diff --cc test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
index 42cd196,537278a..43f96fb
--- a/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
+++ b/test/unit/org/apache/cassandra/db/BatchlogManagerTest.java
@@@ -67,13 -64,12 +67,16 @@@ public class BatchlogManagerTest extend
long timestamp = System.currentTimeMillis();
if (i < 500)
timestamp -= DatabaseDescriptor.getWriteRpcTimeout() * 2;
- BatchlogManager.getBatchlogMutationFor(Collections.singleton(mutation), UUIDGen.getTimeUUID(), timestamp * 1000).apply();
+ BatchlogManager.getBatchlogMutationFor(Collections.singleton(mutation),
+ UUIDGen.getTimeUUID(),
+ MessagingService.current_version,
+ timestamp * 1000)
+ .apply();
}
+ // Flush the batchlog to disk (see CASSANDRA-6822).
+ Keyspace.open(Keyspace.SYSTEM_KS).getColumnFamilyStore(SystemKeyspace.BATCHLOG_CF).forceBlockingFlush();
+
assertEquals(1000, BatchlogManager.instance.countAllBatches());
assertEquals(0, BatchlogManager.instance.getTotalBatchesReplayed());