Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-28352 [Umbrella] Make Pulsar connector stable
  3. FLINK-23944

PulsarSourceITCase.testTaskManagerFailure is instable

    XMLWordPrintableJSON

Details

    Description

      https://dev.azure.com/dianfu/Flink/_build/results?buildId=430&view=logs&j=f3dc9b18-b77a-55c1-591e-264c46fe44d1&t=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d

      It's from my personal azure pipeline, however, I'm pretty sure that I have not touched any code related to this. 

      Aug 24 10:44:13 [ERROR] testTaskManagerFailure{TestEnvironment, ExternalContext, ClusterControllable}[1] Time elapsed: 258.397 s <<< FAILURE! Aug 24 10:44:13 java.lang.AssertionError: Aug 24 10:44:13 Aug 24 10:44:13 Expected: Records consumed by Flink should be identical to test data and preserve the order in split Aug 24 10:44:13 but: Mismatched record at position 7: Expected '0W6SzacX7MNL4xLL3BZ8C3ljho4iCydbvxIl' but was 'wVi5JaJpNvgkDEOBRC775qHgw0LyRW2HBxwLmfONeEmr' Aug 24 10:44:13 at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20) Aug 24 10:44:13 at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8) Aug 24 10:44:13 at org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testTaskManagerFailure(SourceTestSuiteBase.java:271)

      Attachments

        Issue Links

          is blocked by

          Bug - A problem which impairs or prevents the functions of the product. FLINK-24733 Data loss in pulsar source when using shared mode

          • Major - Major loss of function.
          • Resolved

          Bug - A problem which impairs or prevents the functions of the product. FLINK-27399 Pulsar connector didn't set start consuming position correctly

          • Blocker - Blocks development and/or testing work, production could not run
          • Closed
          is duplicated by

          Bug - A problem which impairs or prevents the functions of the product. FLINK-24449 PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure fails with record mismatch

          • Major - Major loss of function.
          • Closed
          is related to

          Sub-task - The sub-task of the issue FLINK-25740 PulsarSourceOrderedE2ECase fails on azure

          • Critical - Crashes, loss of data, severe memory leak.
          • Closed
          relates to

          Bug - A problem which impairs or prevents the functions of the product. FLINK-23807 Use RestClient to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover

          • Blocker - Blocks development and/or testing work, production could not run
          • Resolved
          links to

          Web Link GitHub Pull Request #17201

          Web Link GitHub Pull Request #18411

          Activity

            People

              syhily Yufan Sheng
              dianfu Dian Fu
              Votes:
              0 Vote for this issue
              Watchers:
              14 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: