dpcollins-google commented on a change in pull request #15537:
URL: https://github.com/apache/beam/pull/15537#discussion_r713258266
##########
File path:
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/ReadWriteIT.java
##########
@@ -236,6 +236,8 @@ public void testReadWrite() throws Exception {
pipeline.getOptions().as(TestPipelineOptions.class).setBlockOnRun(false);
TopicPath topic = createTopic(getProject(pipeline.getOptions()));
+ // Sleep for topic creation to propagate.
+ Thread.sleep(10000);
Review comment:
To be more specific: there's no check that can be made conclusively that
the topic will be found when you go to create the subscription. Just because
the server that you make a GetTopic request for example can get the topic
doesn't mean a subsequent subscription creation request is guaranteed to
succeed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
