[ 
https://issues.apache.org/jira/browse/BEAM-9779?focusedWorklogId=426344&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-426344
 ]

ASF GitHub Bot logged work on BEAM-9779:
----------------------------------------

                Author: ASF GitHub Bot
            Created on: 23/Apr/20 01:46
            Start Date: 23/Apr/20 01:46
    Worklog Time Spent: 10m 
      Work Description: jaketf commented on a change in pull request #11450:
URL: https://github.com/apache/beam/pull/11450#discussion_r413448804



##########
File path: 
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2IOTestUtil.java
##########
@@ -91,10 +92,13 @@ static void deleteAllHL7v2Messages(HealthcareApiClient 
client, String hl7v2Store
   }
 
   /** Populate the test messages into the HL7v2 store. */
-  static void writeHL7v2Messages(HealthcareApiClient client, String 
hl7v2Store) throws IOException {
+  static void writeHL7v2Messages(HealthcareApiClient client, String hl7v2Store)
+      throws IOException, InterruptedException {
     for (HL7v2Message msg : MESSAGES) {
       client.createHL7v2Message(hl7v2Store, msg.toModel());
     }
+    // [BEAM-9779] HL7v2 indexing is asyncronous. Add sleep to stabilize this 
IT.
+    Sleeper.DEFAULT.sleep(5000);

Review comment:
       Alternatively we could throw some EBO / retry logic waiting until the 
list returns the number of messages we expect.




----------------------------------------------------------------
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.

For queries about this service, please contact Infrastructure at:
[email protected]


Issue Time Tracking
-------------------

    Worklog Id:     (was: 426344)
    Time Spent: 2h  (was: 1h 50m)

> HL7v2IOWriteIT is flaky
> -----------------------
>
>                 Key: BEAM-9779
>                 URL: https://issues.apache.org/jira/browse/BEAM-9779
>             Project: Beam
>          Issue Type: Bug
>          Components: io-java-gcp
>            Reporter: Jacob Ferriero
>            Assignee: Jacob Ferriero
>            Priority: Minor
>          Time Spent: 2h
>  Remaining Estimate: 0h
>
> There seems to be a race condition somewhere in HL7v2IOWriteIT that causes 
> flakiness.
> https://builds.apache.org/job/beam_PostCommit_Java/5947/
> https://builds.apache.org/job/beam_PostCommit_Java/5943/
> https://builds.apache.org/job/beam_PostCommit_Java/5942/



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to