[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578609#comment-17578609 ] Yufan Sheng commented on FLINK-26177: - After detailed debugging and logging. We can confirm this is a race condition on pulsar-client-all. It's reported as a bug on https://github.com/apache/pulsar/pull/16171. We will have a quick workaround for fixing this issue. Sorry for anyone who was bothered by Pulsar's test failure. 硫 > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Pulsar >Affects Versions: 1.15.0, 1.16.0 >Reporter: Matthias Pohl >Priority: Major > Labels: auto-deprioritized-critical, pull-request-available, > stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550897#comment-17550897 ] Ahmed Hamdy commented on FLINK-26177: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=36335=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203 > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0, 1.16.0 >Reporter: Matthias Pohl >Priority: Major > Labels: auto-deprioritized-critical, pull-request-available, > stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515266#comment-17515266 ] Niklas Semmler commented on FLINK-26177: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=34020=logs=fc5181b0-e452-5c8f-68de-1097947f6483=995c650b-6573-581c-9ce6-7ad4cc038461 > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0, 1.16.0 >Reporter: Matthias Pohl >Priority: Critical > Labels: pull-request-available, stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513859#comment-17513859 ] Yun Gao commented on FLINK-26177: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=33795=logs=298e20ef-7951-5965-0e79-ea664ddc435e=d4c90338-c843-57b0-3232-10ae74f00347=28004 > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0, 1.16.0 >Reporter: Matthias Pohl >Priority: Critical > Labels: pull-request-available, stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511631#comment-17511631 ] Yun Gao commented on FLINK-26177: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=33671=logs=245e1f2e-ba5b-5570-d689-25ae21e5302f=d04c9862-880c-52f5-574b-a7a79fef8e0f=27236 > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510286#comment-17510286 ] Yun Gao commented on FLINK-26177: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=33443=logs=298e20ef-7951-5965-0e79-ea664ddc435e=d4c90338-c843-57b0-3232-10ae74f00347=27543 > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510188#comment-17510188 ] Yun Gao commented on FLINK-26177: - https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=33522=logs=fc5181b0-e452-5c8f-68de-1097947f6483=995c650b-6573-581c-9ce6-7ad4cc038461=26986 > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507790#comment-17507790 ] Matthias Pohl commented on FLINK-26177: --- https://dev.azure.com/mapohl/flink/_build/results?buildId=877=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26851 > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507463#comment-17507463 ] Yufan Sheng commented on FLINK-26177: - [~mapohl] Tks for your mention, I'm working on this now. > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507400#comment-17507400 ] Matthias Pohl commented on FLINK-26177: --- There's a [build failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=873=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26838] on my branch that included {{1572908edbb17455a83f9e45974cf312a478283b}} but failed {{PulsarSourceITCase>SourceTestSuiteBase.testSavepoint}} having a similar stacktrace as the build failure in the issue description: {code:java} Mar 15 21:56:43 [ERROR] Failures: Mar 15 21:56:43 [ERROR] PulsarSourceITCase>SourceTestSuiteBase.testSavepoint:241->SourceTestSuiteBase.restartFromSavepoint:399->SourceTestSuiteBase.checkResultWithSemantic:766 Mar 15 21:56:43 Expecting Mar 15 21:56:43 Mar 15 21:56:43 to be completed within 2M. Mar 15 21:56:43 Mar 15 21:56:43 exception caught while trying to get the future result: java.util.concurrent.TimeoutException Mar 15 21:56:43 at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) Mar 15 21:56:43 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) Mar 15 21:56:43 at org.assertj.core.internal.Futures.assertSucceededWithin(Futures.java:109) Mar 15 21:56:43 at org.assertj.core.api.AbstractCompletableFutureAssert.internalSucceedsWithin(AbstractCompletableFutureAssert.java:400) Mar 15 21:56:43 at org.assertj.core.api.AbstractCompletableFutureAssert.succeedsWithin(AbstractCompletableFutureAssert.java:396) Mar 15 21:56:43 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.checkResultWithSemantic(SourceTestSuiteBase.java:766) Mar 15 21:56:43 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.restartFromSavepoint(SourceTestSuiteBase.java:399) [...] {code} > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506830#comment-17506830 ] Fabian Paul commented on FLINK-26177: - Merged in master: 1572908edbb17455a83f9e45974cf312a478283b release-1.15: TBD > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503381#comment-17503381 ] Yun Gao commented on FLINK-26177: - Hi~ do we still to fix this issue in the 1.15 release cycle~? > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, stale-blocker, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493613#comment-17493613 ] Hang Ruan commented on FLINK-26177: --- LGTM. The test case `testSavepoint` uses the same code as the `testScaleUp/Down`. It is weird. We will take a look later. thanks ~ > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493302#comment-17493302 ] Roman Khachatryan commented on FLINK-26177: --- Test disabled in master via 20e03f424c468ef11aa5aba710d94366c690af86. > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493108#comment-17493108 ] Roman Khachatryan commented on FLINK-26177: --- [~ruanhang1993], [~renqs], [~dwysakowicz], could you please review the [PR|https://github.com/apache/flink/pull/18798] to disable the tests? Thanks. > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: pull-request-available, test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493070#comment-17493070 ] Roman Khachatryan commented on FLINK-26177: --- [https://dev.azure.com/khachatryanroman/flink/_build/results?buildId=1407=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26782] Looks like no build succeeds because of this issue. I'm going to disable the test (without closing the ticket). > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Blocker > Labels: test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout
[ https://issues.apache.org/jira/browse/FLINK-26177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493062#comment-17493062 ] Dawid Wysakowicz commented on FLINK-26177: -- I see the test (actually {{testScaleUp}}) failing on all my builds and some others. E.g. * https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31570=logs=fc5181b0-e452-5c8f-68de-1097947f6483=995c650b-6573-581c-9ce6-7ad4cc038461=26789 * https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31580=logs=fc5181b0-e452-5c8f-68de-1097947f6483=995c650b-6573-581c-9ce6-7ad4cc038461=27264 Bumping to blocker > PulsarSourceITCase.testScaleDown fails with timeout > --- > > Key: FLINK-26177 > URL: https://issues.apache.org/jira/browse/FLINK-26177 > Project: Flink > Issue Type: Bug > Components: Connectors / Pulsar >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Major > Labels: test-stability > > We observed a [build > failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=742=logs=f3dc9b18-b77a-55c1-591e-264c46fe44d1=2d3cd81e-1c37-5c31-0ee4-f5d5cdb9324d=26553] > caused by {{PulsarSourceITCase.testScaleDown}}: > {code} > Feb 15 20:56:02 [ERROR] Tests run: 16, Failures: 1, Errors: 0, Skipped: 0, > Time elapsed: 431.023 s <<< FAILURE! - in > org.apache.flink.connector.pulsar.source.PulsarSourceITCase > Feb 15 20:56:02 [ERROR] > org.apache.flink.connector.pulsar.source.PulsarSourceITCase.testScaleDown(TestEnvironment, > DataStreamSourceExternalContext, CheckpointingMode)[2] Time elapsed: > 138.444 s <<< FAILURE! > Feb 15 20:56:02 java.lang.AssertionError: > Feb 15 20:56:02 > Feb 15 20:56:02 Expecting > Feb 15 20:56:02 > Feb 15 20:56:02 to be completed within 2M. > Feb 15 20:56:02 > Feb 15 20:56:02 exception caught while trying to get the future result: > java.util.concurrent.TimeoutException > Feb 15 20:56:02 at > java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784) > [...] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)