From 721c4a5ecccd45b2d9ca046d86c350e2fa6a76e1 Mon Sep 17 00:00:00 2001 From: Aleksey Yeschenko Date: Wed, 23 Oct 2013 23:59:50 +0800 Subject: [PATCH] Replace fragile-ish ABSC w/ TMBSC in TraceState --- src/java/org/apache/cassandra/tracing/TraceState.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/java/org/apache/cassandra/tracing/TraceState.java b/src/java/org/apache/cassandra/tracing/TraceState.java index b7d67a4944..5fec633e98 100644 --- a/src/java/org/apache/cassandra/tracing/TraceState.java +++ b/src/java/org/apache/cassandra/tracing/TraceState.java @@ -28,11 +28,9 @@ import org.slf4j.helpers.MessageFormatter; import org.apache.cassandra.concurrent.Stage; import org.apache.cassandra.concurrent.StageManager; import org.apache.cassandra.config.CFMetaData; -import org.apache.cassandra.db.ArrayBackedSortedColumns; import org.apache.cassandra.db.ColumnFamily; -import org.apache.cassandra.db.ConsistencyLevel; import org.apache.cassandra.db.RowMutation; -import org.apache.cassandra.service.StorageProxy; +import org.apache.cassandra.db.TreeMapBackedSortedColumns; import org.apache.cassandra.utils.ByteBufferUtil; import org.apache.cassandra.utils.FBUtilities; import org.apache.cassandra.utils.UUIDGen; @@ -97,7 +95,7 @@ public class TraceState public void runMayThrow() { CFMetaData cfMeta = CFMetaData.TraceEventsCf; - ColumnFamily cf = ArrayBackedSortedColumns.factory.create(cfMeta); + ColumnFamily cf = TreeMapBackedSortedColumns.factory.create(cfMeta); Tracing.addColumn(cf, Tracing.buildName(cfMeta, eventId, ByteBufferUtil.bytes("activity")), message); Tracing.addColumn(cf, Tracing.buildName(cfMeta, eventId, ByteBufferUtil.bytes("source")), FBUtilities.getBroadcastAddress()); if (elapsed >= 0)