You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2022/01/12 14:25:00 UTC
[jira] (FLINK-23971) PulsarSourceITCase.testIdleReader failed on azure
[ https://issues.apache.org/jira/browse/FLINK-23971 ]
Yun Gao deleted comment on FLINK-23971:
---------------------------------
was (Author: gaoyunhaii):
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=29296&view=logs&j=af184cdd-c6d8-5084-0b69-7e9c67b35f7a&t=160c9ae5-96fd-516e-1c91-deb81f59292a&l=15065
> PulsarSourceITCase.testIdleReader failed on azure
> -------------------------------------------------
>
> Key: FLINK-23971
> URL: https://issues.apache.org/jira/browse/FLINK-23971
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.14.0
> Reporter: Roman Khachatryan
> Assignee: Hang Ruan
> Priority: Blocker
> Labels: pull-request-available, test-stability
> Fix For: 1.14.0
>
> Attachments: error.log
>
>
> {code:java}
> [INFO] Running org.apache.flink.connector.pulsar.source.PulsarSourceITCase
> [ERROR] Tests run: 8, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 353.527 s <<< FAILURE! - in org.apache.flink.connector.pulsar.source.PulsarSourceITCase
> [ERROR] testIdleReader{TestEnvironment, ExternalContext}[2] Time elapsed: 4.549 s <<< FAILURE!
> java.lang.AssertionError:
> Expected: Records consumed by Flink should be identical to test data and preserve the order in multiple splits
> but: Unexpected record 'tj7MpFRWX95GzBpSF3CCjxKSal6bRhR0aF'
> at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
> at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8)
> at org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testIdleReader(SourceTestSuiteBase.java:193)
> {code}
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=22819&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461&l=24448]
> This is the same error as in FLINK-23828 (kafka).
--
This message was sent by Atlassian Jira
(v8.20.1#820001)