Matthias Pohl created FLINK-30703:
-------------------------------------
Summary:
PulsarOrderedPartitionSplitReaderTest>PulsarPartitionSplitReaderTestBase.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
fails
Key: FLINK-30703
URL: https://issues.apache.org/jira/browse/FLINK-30703
Project: Flink
Issue Type: Bug
Components: Connectors / Pulsar
Affects Versions: pulsar-3.0.0, 1.15.3, 1.16.0
Reporter: Matthias Pohl
A 1.15 build failed due to
{{PulsarOrderedPartitionSplitReaderTest>PulsarPartitionSplitReaderTestBase.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition}}:
{code}
an 11 03:08:20 [ERROR]
PulsarOrderedPartitionSplitReaderTest>PulsarPartitionSplitReaderTestBase.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition:260->PulsarPartitionSplitReaderTestBase.fetchedMessages:169->PulsarPartitionSplitReaderTestBase.fetchedMessages:199
[We should fetch the expected size]
Jan 11 03:08:20 Expected size: 20 but was: 25 in:
Jan 11 03:08:20 [PulsarMessage{id=154:0:0, value=ZHiaOiOhFT, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:1:0, value=uoOmKceWTh, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:2:0, value=oeYYWzisge, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:3:0, value=yhpOOkNLER, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:4:0, value=MIbzxkfFfp, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:0:0, value=ZHiaOiOhFT, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:1:0, value=uoOmKceWTh, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:2:0, value=oeYYWzisge, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:3:0, value=yhpOOkNLER, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:4:0, value=MIbzxkfFfp, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:5:0, value=FaEpggGBTE, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:6:0, value=IlGbzPRuvi, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:7:0, value=aqgIeSbOzo, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:8:0, value=CUScdPriyM, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:9:0, value=zLRsvDxpJG, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:10:0, value=iqsGFVkXDz, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:11:0, value=hFyHYPldqN, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:12:0, value=ZYTlJcwSst, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:13:0, value=mOWkzJQQxE, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:14:0, value=CTfcVXhfUN, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:15:0, value=wAhqCGGwXO, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:16:0, value=LOoTbXaEgG, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:17:0, value=UvfzGIRURy, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:18:0, value=vlYYGbZGAH, eventTime=0},
Jan 11 03:08:20 PulsarMessage{id=154:19:0, value=wrwPanXvql, eventTime=0}]
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=44691&view=logs&j=a5ef94ef-68c2-57fd-3794-dc108ed1c495&t=2c68b137-b01d-55c9-e603-3ff3f320364b&l=27466
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
