[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641928#comment-17641928 ] Martijn Visser commented on FLINK-29830: Fixed in Pulsar external connector repo: 5162b766bb042705ecafefc773bb2600b7e56263 > PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed > -- > > Key: FLINK-29830 > URL: https://issues.apache.org/jira/browse/FLINK-29830 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Pulsar >Affects Versions: 1.16.0, 1.17.0, 1.15.3 >Reporter: Martijn Visser >Assignee: Yufan Sheng >Priority: Critical > Labels: pull-request-available, test-stability > Fix For: pulsar-3.0.1 > > > {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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641094#comment-17641094 ] Matthias Pohl commented on FLINK-29830: --- I moved this under the Umbrella Pulsar stability ticket. > PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed > -- > > Key: FLINK-29830 > URL: https://issues.apache.org/jira/browse/FLINK-29830 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Pulsar >Affects Versions: 1.16.0, 1.17.0, 1.15.3 >Reporter: Martijn Visser >Assignee: Yufan Sheng >Priority: Critical > Labels: pull-request-available, 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638075#comment-17638075 ] Matthias Pohl commented on FLINK-29830: --- [~syhily] may you create a backport PR for 1.16 and 1.15 as well, please? > 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.16.0, 1.17.0, 1.15.3 >Reporter: Martijn Visser >Assignee: Yufan Sheng >Priority: Critical > Labels: pull-request-available, 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636585#comment-17636585 ] Leonard Xu commented on FLINK-29830: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43253=logs=5cae8624-c7eb-5c51-92d3-4d2dacedd221=5acec1b4-945b-59ca-34f8-168928ce5199 > 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.16.0, 1.17.0, 1.15.3 >Reporter: Martijn Visser >Assignee: Yufan Sheng >Priority: Critical > Labels: pull-request-available, 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17633482#comment-17633482 ] Leonard Xu commented on FLINK-29830: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43089=logs=8eee98ee-a482-5f7c-2c51-b3456453e704=da58e781-88fe-508b-b74c-018210e533cc > 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.16.0, 1.17.0, 1.15.3 >Reporter: Martijn Visser >Assignee: Yufan Sheng >Priority: Critical > Labels: pull-request-available, 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17633479#comment-17633479 ] Leonard Xu commented on FLINK-29830: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43089=logs=8eee98ee-a482-5f7c-2c51-b3456453e704=da58e781-88fe-508b-b74c-018210e533cc > 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.16.0, 1.17.0, 1.15.3 >Reporter: Martijn Visser >Assignee: Yufan Sheng >Priority: Critical > Labels: pull-request-available, 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629860#comment-17629860 ] Yufan Sheng commented on FLINK-29830: - [~mapohl] Can you help review the PR? https://github.com/apache/flink/pull/21252 > 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.16.0, 1.17.0, 1.15.2 >Reporter: Martijn Visser >Assignee: Yufan Sheng >Priority: Critical > Labels: pull-request-available, 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629846#comment-17629846 ] Yufan Sheng commented on FLINK-29830: - Yep, I'll submit a fix right now. Assign this ticket to me and thanks for helping me find this undetectable bug. > 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.16.0, 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629842#comment-17629842 ] Matthias Pohl commented on FLINK-29830: --- Done. Are you going to provide a fix for that? I would assign this Jira issue to you in that case. > 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.16.0, 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629841#comment-17629841 ] Yufan Sheng commented on FLINK-29830: - [~mapohl] It's my mistake in {{ControlSource.StopSignal}}. I consuming messages with the latest stop cursor. Which would cause the race condition that all message has been sent before I start the consumer. > 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629820#comment-17629820 ] Yufan Sheng commented on FLINK-29830: - The log couldn't show the real cause. We shall add some log to print the true error stack. > 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629646#comment-17629646 ] Matthias Pohl commented on FLINK-29830: --- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=42857=logs=fc5181b0-e452-5c8f-68de-1097947f6483=995c650b-6573-581c-9ce6-7ad4cc038461=28624 > 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627719#comment-17627719 ] Martijn Visser commented on FLINK-29830: This is not a blocker for 1.15.3 > 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627688#comment-17627688 ] Fabian Paul commented on FLINK-29830: - [~martijnvisser] do you think this is a block for the 1.15.3 release? The pulsar tests seem to be flaky for a while. > 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627020#comment-17627020 ] Matthias Pohl commented on FLINK-29830: --- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=42681=logs=fc5181b0-e452-5c8f-68de-1097947f6483=995c650b-6573-581c-9ce6-7ad4cc038461=27843 > 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=logs=aa18c3f6-13b8-5f58-86bb-c1cffb239496=502fb6c0-30a2-5e49-c5c2-a00fa3acb203=37544 -- This message was sent by Atlassian Jira (v8.20.10#820010)