[
https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629838#comment-17629838
]
Matthias Pohl commented on FLINK-29830:
---------------------------------------
There is some warning in the logs about some timeout on the Pulsar side:
{code}
160037 01:57:02,826 [Legacy Source Thread - Source: Custom Source (1/1)#0] WARN
org.apache.flink.connector.pulsar.testutils.function.ControlSource$StopSignal
[] - Timeout for waiting the records from Pulsar. We have consumed 0 messages,
expect 137 messages.
160038 01:57:02,987 [ Checkpoint Timer] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering
checkpoint 600 (type=CheckpointType{name='Checkpoint',
sharingFilesStrategy=FORWARD_BACKWARD}) @ 1667699822986 for job
6fa5e9f506b63276a4933daa137fdf43.
160039 01:57:02,994 [jobmanager-io-thread-13] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Completed
checkpoint 600 for job 6fa5e9f506b63276a4933daa137fdf43 (314 bytes,
checkpointDuration=8 ms, finalizationTime=0 ms).
160040 01:57:02,996 [Source: Custom Source (1/1)#0] INFO
org.apache.flink.runtime.taskmanager.Task [] - Source:
Custom Source (1/1)#0 (3cfeb328eb182887d817886aa848606d) switched from RUNNING
to FINISHED.
{code}
Subsequent checkpoints are declined as a consequence (AFAIU).
> PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
> ------------------------------------------------------------------
>
> Key: FLINK-29830
> URL: https://issues.apache.org/jira/browse/FLINK-29830
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.17.0, 1.15.2
> Reporter: Martijn Visser
> Priority: Critical
> Labels: test-stability
>
> {code:java}
> Nov 01 01:28:03 [ERROR] Failures:
> Nov 01 01:28:03 [ERROR]
> PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar:140
> Nov 01 01:28:03 Actual and expected should have same size but actual size is:
> Nov 01 01:28:03 0
> Nov 01 01:28:03 while expected size is:
> Nov 01 01:28:03 115
> Nov 01 01:28:03 Actual was:
> Nov 01 01:28:03 []
> Nov 01 01:28:03 Expected was:
> Nov 01 01:28:03 ["AT_LEAST_ONCE-isxrFGAL-0-kO65unDUKX",
> Nov 01 01:28:03 "AT_LEAST_ONCE-isxrFGAL-1-4tBNu1UmeR",
> Nov 01 01:28:03 "AT_LEAST_ONCE-isxrFGAL-2-9PTnEahlNU",
> Nov 01 01:28:03 "AT_LEAST_ONCE-isxrFGAL-3-GjWqEp21yz",
> Nov 01 01:28:03 "AT_LEAST_ONCE-isxrFGAL-4-jnbJr9C0w8",
> Nov 01 01:28:03 "AT_LEAST_ONCE-isxrFGAL-5-e8Wacz5yDO",
> Nov 01 01:28:03 "AT_LEAST_ONCE-isxrFGAL-6-9cW53j3Zcf",
> Nov 01 01:28:03 "AT_LEAST_ONCE-isxrFGAL-7-jk8z3m2Aa5",
> Nov 01 01:28:03 "AT_LEAST_ONCE-isxrFGAL-8-VU56KmMeiz",
> Nov 01 01:28:03 "AT_LEAST_ONCE-isxrFGAL-9-uvMdFxxDAj",
> Nov 01 01:28:03 "AT_LEAST_ONCE-isxrFGAL-10-FQyWfwJFbH",
> ...
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=42680&view=logs&j=aa18c3f6-13b8-5f58-86bb-c1cffb239496&t=502fb6c0-30a2-5e49-c5c2-a00fa3acb203&l=37544
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
