[
https://issues.apache.org/jira/browse/FLINK-23971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405622#comment-17405622
]
Hang Ruan edited comment on FLINK-23971 at 8/27/21, 6:35 AM:
-------------------------------------------------------------
After a lot of times to test, I reproduced the error and get the [^error.log]
that I have provided in the attachments.
The log shows that there is a duplicate string "3" in both split 2 and split 3.
When taking the next loop, the logic uses the "3" in split 2(we should take it
from split 3), and the next string "aXf1QgrCBzQNlr" in the result can not be
found.
was (Author: ruanhang1993):
After a lot of times to test, I reproduced the error and get the log that I
have provided in the attachments.
The log shows that there is a duplicate string "3" in both split 2 and split 3.
When taking the next loop, the logic uses the "3" in split 2(we should take it
from split 3), and the next string "aXf1QgrCBzQNlr" in the result can not be
found.
> 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
> Priority: Blocker
> Labels: 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.3.4#803005)
