More travisci debugging

Author: stanlemon

src/test/java/com/salesforce/storm/spout/dynamic/VirtualSpoutTest.java

@@ -49,15 +49,14 @@
 import org.apache.storm.task.TopologyContext;
 import org.apache.storm.tuple.Values;
 import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 
 import java.lang.reflect.Field;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.Map;
 
-import static org.awaitility.Awaitility.await;
-import static org.hamcrest.CoreMatchers.equalTo;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
@@ -81,6 +80,14 @@
  */
 public class VirtualSpoutTest {
 
+ /**
+ * Before each test reset the static on the MockConsumer.
+ */
+ @BeforeEach
+ void resetMockConsumerPartitions() {
+ MockConsumer.partitions = Arrays.asList(1);
+ }
+
  /**
  * Verify that constructor args get set appropriately.
  */
@@ -189,8 +196,6 @@ public void testSetAndGetConsumerId() {
  public void testAttemptToComplete() {
  final Map<String, Object> config = getDefaultConfig();
 
- MockConsumer.partitions = Arrays.asList(1);
-
  // Our starting state
  final ConsumerState startingState = ConsumerState.builder()
  .withPartition(new ConsumerPartition(MockConsumer.topic, 1), 1L)
@@ -199,7 +204,7 @@ public void testAttemptToComplete() {
  final ConsumerState endingState = ConsumerState.builder()
  .withPartition(new ConsumerPartition(MockConsumer.topic, 1), 1L)
  .build();
- System.out.println(endingState.toString());
+
  // Create spout
  final VirtualSpout virtualSpout = new VirtualSpout(
  new DefaultVirtualSpoutIdentifier("MyConsumerId"),
@@ -213,38 +218,12 @@ public void testAttemptToComplete() {
  // Open it, this will setup the consumer (which is our mock)
  virtualSpout.open();
 
- /*
- try {
- Thread.sleep(1000);
- } catch (InterruptedException ex) {
- System.out.println("Couldn't sleep as long as I liked...");
- }
- */
-
  // Should default to false, we haven't attempt completing yet
  assertFalse(virtualSpout.isCompleted(), "Should default to false");
 
- // This should wait to flush state until the consumer is opened. If we attempt to flush state before
- // the consumer is opened we will get a null pointer
- await()
- .until(() -> virtualSpout.isOpened(), equalTo(true));
-
-
- System.out.println(virtualSpout.getCurrentState());
- System.out.println(virtualSpout.getStartingState());
- System.out.println(virtualSpout.getEndingState());
-
- // Our spout is now complete
- await()
- .until(() -> {
-
- // Flushing state will attempt to complete the VirtualSpout, because our starting and offstate are the same
- // and we only have one partition this should call setCompleted() right away
- virtualSpout.flushState();
- return virtualSpout.isCompleted();
- }, equalTo(true));
+ virtualSpout.flushState();
 
- //assertTrue(virtualSpout.isCompleted(), "Should be true");
+ assertTrue(virtualSpout.isCompleted(), "Should be true");
  }
 
  /**