Merge pull request apache#12301 from Xeli/FLINK-16572-logs

[FLINK-16572] [pubsub,e2e] Add check to see if adding a timeout to th…
tongcheng-elong · May 25, 2020 · 50253c6 · 50253c6
1 parent edfb7c4
commit 50253c6
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...c/test/java/org/apache/flink/streaming/connectors/gcp/pubsub/CheckPubSubEmulatorTest.java b/...c/test/java/org/apache/flink/streaming/connectors/gcp/pubsub/CheckPubSubEmulatorTest.java
@@ -75,6 +75,13 @@ public void testPull() throws Exception {
  .get();
 
  List<ReceivedMessage> receivedMessages = pubsubHelper.pullMessages(PROJECT_NAME, SUBSCRIPTION_NAME, 1);
+
+ //TODO this is just to test if we need to wait longer, or if something has gone wrong and the message will never arrive
+ if (receivedMessages.isEmpty()) {
+ LOG.error("Message did not arrive, gonna wait 60s and try to pull again.");
+ Thread.sleep(30 * 1000);
+ receivedMessages = pubsubHelper.pullMessages(PROJECT_NAME, SUBSCRIPTION_NAME, 1);
+ }
  assertEquals(1, receivedMessages.size());
  assertEquals("Hello World PULL", receivedMessages.get(0).getMessage().getData().toStringUtf8());