[incubator-fluo] branch master updated: re #585 print debug info when CollisionIT fails (#877)

[mw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mwalch pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-fluo.git


The following commit(s) were added to refs/heads/master by this push:
     new 9002216  re #585 print debug info when CollisionIT fails (#877)
9002216 is described below

commit 90022166cb9cb020ceeb7f65d1fb045202568773
Author: Keith Turner <ke...@deenlo.com>
AuthorDate: Tue Jun 27 16:03:13 2017 -0400

    re #585 print debug info when CollisionIT fails (#877)
---
 .../test/java/org/apache/fluo/integration/impl/CollisionIT.java    | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/modules/integration/src/test/java/org/apache/fluo/integration/impl/CollisionIT.java b/modules/integration/src/test/java/org/apache/fluo/integration/impl/CollisionIT.java
index e8e7aac..7fc39e3 100644
--- a/modules/integration/src/test/java/org/apache/fluo/integration/impl/CollisionIT.java
+++ b/modules/integration/src/test/java/org/apache/fluo/integration/impl/CollisionIT.java
@@ -19,10 +19,12 @@ import java.util.HashSet;
 import java.util.Map.Entry;
 import java.util.Random;
 
+import com.google.common.collect.Iterables;
 import org.apache.accumulo.core.client.Scanner;
 import org.apache.accumulo.core.data.Key;
 import org.apache.accumulo.core.data.Value;
 import org.apache.accumulo.core.security.Authorizations;
+import org.apache.fluo.accumulo.format.FluoFormatter;
 import org.apache.fluo.accumulo.util.ColumnConstants;
 import org.apache.fluo.accumulo.util.ZookeeperUtil;
 import org.apache.fluo.api.client.Loader;
@@ -164,6 +166,11 @@ public class CollisionIT extends ITBaseMini {
       String rowCol =
           k.getRow() + ":" + k.getColumnFamily() + ":" + k.getColumnQualifier() + ":"
               + String.format("%x", k.getTimestamp() & ColumnConstants.PREFIX_MASK);
+      if (rowCols.contains(rowCol)) {
+        System.err.println("DEBUG oldestTs : " + oldestTS + " recentTS : " + recentTS);
+        Iterables.transform(scanner, e -> "DEBUG " + FluoFormatter.toString(e)).forEach(
+            System.err::println);
+      }
       Assert.assertFalse("Duplicate row col " + rowCol, rowCols.contains(rowCol));
       rowCols.add(rowCol);
     }

-- 
To stop receiving notification emails like this one, please contact
['"commits@fluo.apache.org" <co...@fluo.apache.org>'].