cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbros...@apache.org
Subject git commit: fix shuffle clear to use new blob literal format patch by dbrosius reviewed by jbellis for CASSANDRA-5755
Date Sat, 13 Jul 2013 18:16:24 GMT
Updated Branches:
  refs/heads/trunk c5bca30a0 -> 0ed859a5d


fix shuffle clear to use new blob literal format
patch by dbrosius reviewed by jbellis for CASSANDRA-5755


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

Branch: refs/heads/trunk
Commit: 0ed859a5d0ece694f240b64e3212af37e0def1ac
Parents: c5bca30
Author: Dave Brosius <dbrosius@apache.org>
Authored: Sat Jul 13 14:14:10 2013 -0400
Committer: Dave Brosius <dbrosius@apache.org>
Committed: Sat Jul 13 14:14:10 2013 -0400

----------------------------------------------------------------------
 src/java/org/apache/cassandra/tools/Shuffle.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/0ed859a5/src/java/org/apache/cassandra/tools/Shuffle.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/tools/Shuffle.java b/src/java/org/apache/cassandra/tools/Shuffle.java
index ac36e3b..b189ccb 100644
--- a/src/java/org/apache/cassandra/tools/Shuffle.java
+++ b/src/java/org/apache/cassandra/tools/Shuffle.java
@@ -434,7 +434,7 @@ public class Shuffle extends AbstractJmxClient
                 assert row.getColumns().size() == 2;
 
                 ByteBuffer tokenBytes = ByteBuffer.wrap(row.getColumns().get(0).getValue());
-                String query = String.format("DELETE FROM system.range_xfers WHERE token_bytes
= '%s'",
+                String query = String.format("DELETE FROM system.range_xfers WHERE token_bytes
= 0x%s",
                         ByteBufferUtil.bytesToHex(tokenBytes));
                 executeCqlQuery(host, thriftPort, thriftFramed, query);
             }


Mime
View raw message