Author: jbellis
Date: Thu Aug 4 04:33:24 2011
New Revision: 1153750
URL: http://svn.apache.org/viewvc?rev=1153750&view=rev
Log:
improve test logging
patch by jbellis
Modified:
cassandra/trunk/src/java/org/apache/cassandra/io/sstable/SSTableWriter.java
cassandra/trunk/test/unit/org/apache/cassandra/SchemaLoader.java
Modified:
cassandra/trunk/src/java/org/apache/cassandra/io/sstable/SSTableWriter.java
URL:
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/io/sstable/SSTableWriter.java?rev=1153750&r1=1153749&r2=1153750&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/io/sstable/SSTableWriter.java
(original)
+++ cassandra/trunk/src/java/org/apache/cassandra/io/sstable/SSTableWriter.java
Thu Aug 4 04:33:24 2011
@@ -148,7 +148,8 @@ public class SSTableWriter extends SSTab
ByteBufferUtil.writeWithShortLength(row.key.key, dataFile.stream);
long dataStart = dataFile.getFilePointer();
long dataSize = row.write(dataFile.stream);
- assert dataSize == dataFile.getFilePointer() - (dataStart + 8):
"incorrect row size written to " + dataFile.getPath();
+ assert dataSize == dataFile.getFilePointer() - (dataStart + 8)
+ : "incorrect row data size " + dataSize + " written to " +
dataFile.getPath() + "; correct is " + (dataFile.getFilePointer() - (dataStart
+ 8));
// max timestamp is not collected here, because we want to avoid
deserializing an EchoedRow
// instead, it is collected when calling
ColumnFamilyStore.createCompactionWriter
sstableMetadataCollector.addRowSize(dataFile.getFilePointer() -
currentPosition);
Modified: cassandra/trunk/test/unit/org/apache/cassandra/SchemaLoader.java
URL:
http://svn.apache.org/viewvc/cassandra/trunk/test/unit/org/apache/cassandra/SchemaLoader.java?rev=1153750&r1=1153749&r2=1153750&view=diff
==============================================================================
--- cassandra/trunk/test/unit/org/apache/cassandra/SchemaLoader.java (original)
+++ cassandra/trunk/test/unit/org/apache/cassandra/SchemaLoader.java Thu Aug 4
04:33:24 2011
@@ -34,12 +34,24 @@ import org.apache.cassandra.locator.Simp
import org.apache.cassandra.thrift.IndexType;
import org.junit.BeforeClass;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class SchemaLoader
{
+ private static Logger logger = LoggerFactory.getLogger(SchemaLoader.class);
+
@BeforeClass
public static void loadSchema()
{
+ Thread.setDefaultUncaughtExceptionHandler(new
Thread.UncaughtExceptionHandler()
+ {
+ public void uncaughtException(Thread t, Throwable e)
+ {
+ logger.error("Fatal exception in thread " + t, e);
+ }
+ });
+
try
{
for (KSMetaData ksm : schemaDefinition())
