removed bad assertion test (it depends on timing)

Netflix · Sep 18, 2014 · fa42389 · fa42389
1 parent 000d4b3
commit fa42389
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/suro-kafka/src/test/java/com/netflix/suro/sink/kafka/TestKafkaSinkV2.java b/suro-kafka/src/test/java/com/netflix/suro/sink/kafka/TestKafkaSinkV2.java
@@ -78,7 +78,6 @@ public void testDefaultParameters() throws IOException {
             sink.writeTo(next); // send
             sentPayloads.add( new String( next.getMessage().getPayload() ) ); // record
         }
-        assertTrue(sink.getNumOfPendingMessages() > 0);
         sink.close();
         assertEquals(sink.getNumOfPendingMessages(), 0);
         System.out.println(sink.getStat());