Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-6279

Failures in ElasticSearchIOTest: testWriteRetryValidRequest (versions 2 & 5) testDefaultRetryPredicate (version 5)

    XMLWordPrintableJSON

    Details

      Description

      https://builds.apache.org/job/beam_PreCommit_Java_Cron/730/

      https://scans.gradle.com/s/6rpbvgwx2nk7c

      I don't see recent changes, so thinking this is a flake.

      testDefaultRetryPredicate:

      java.lang.AssertionError
      : 
      All incoming requests on node [node_s0] should have finished. Expected 0 but got 2540 Expected: <0L> but: was <2540L>
      at __randomizedtesting.SeedInfo.seed([4CF46FDC92DC07B8:B39A5DDFBC85274E]:0)
      at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
      at org.junit.Assert.assertThat(Assert.java:956)
      at org.elasticsearch.test.InternalTestCluster.lambda$assertRequestsFinished$17(InternalTestCluster.java:2086)
      at org.elasticsearch.test.ESTestCase.assertBusy(ESTestCase.java:705)
      at org.elasticsearch.test.ESTestCase.assertBusy(ESTestCase.java:679)
      at org.elasticsearch.test.InternalTestCluster.assertRequestsFinished(InternalTestCluster.java:2083)
      at org.elasticsearch.test.InternalTestCluster.assertAfterTest(InternalTestCluster.java:2062)
      at org.elasticsearch.test.ESIntegTestCase.afterInternal(ESIntegTestCase.java:581)
      at org.elasticsearch.test.ESIntegTestCase.cleanUpCluster(ESIntegTestCase.java:2054)
      ...
      

      This looks like an internal assertion (aka checkState) failed and the cluster became unhealthy, maybe?

       testWriteRetryValidRequest:

      org.apache.beam.sdk.Pipeline$PipelineExecutionException
      : 
      java.io.IOException: listener timeout after waiting for [90000] ms
      Open stacktrace
      Caused by: 
      java.io.IOException
      : 
      listener timeout after waiting for [90000] ms
      Close stacktrace
      at org.elasticsearch.client.RestClient$SyncResponseListener.get(RestClient.java:899)
      at org.elasticsearch.client.RestClient.performRequest(RestClient.java:227)
      at org.elasticsearch.client.RestClient.performRequest(RestClient.java:321)
      at org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO$Write$WriteFn.flushBatch(ElasticsearchIO.java:1285)
      at org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO$Write$WriteFn.finishBundle(ElasticsearchIO.java:1260)

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                echauchot Etienne Chauchot
                Reporter:
                kenn Kenneth Knowles
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 1h 40m
                  1h 40m