Sergey Nuyanzin created FLINK-34010: ---------------------------------------
Summary: KafkaTableITCase.testPerPartitionWatermarkWithIdleSource is unstable on AZP Key: FLINK-34010 URL: https://issues.apache.org/jira/browse/FLINK-34010 Project: Flink Issue Type: Bug Components: Connectors / Kafka Affects Versions: 1.17.3 Reporter: Sergey Nuyanzin This build https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=55965&view=logs&j=9c5a5fe6-2f39-545e-1630-feb3d8d0a1ba&t=99b23320-1d05-5741-d63f-9e78473da39e&l=32434 fails as {noformat} Jan 02 05:24:56 [ERROR] Tests run: 39, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 97.948 s <<< FAILURE! - in org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase Jan 02 05:24:56 [ERROR] KafkaTableITCase.testPerPartitionWatermarkWithIdleSource Time elapsed: 5.494 s <<< ERROR! Jan 02 05:24:56 java.util.concurrent.TimeoutException: Can not get the expected result. Jan 02 05:24:56 at org.apache.flink.core.testutils.CommonTestUtils.waitUtil(CommonTestUtils.java:214) Jan 02 05:24:56 at org.apache.flink.core.testutils.CommonTestUtils.waitUtil(CommonTestUtils.java:230) Jan 02 05:24:56 at org.apache.flink.streaming.connectors.kafka.table.KafkaTableTestUtils.waitingExpectedResults(KafkaTableTestUtils.java:82) Jan 02 05:24:56 at org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase.testPerPartitionWatermarkWithIdleSource(KafkaTableITCase.java:951) Jan 02 05:24:56 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) Jan 02 05:24:56 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) Jan 02 05:24:56 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) {noformat} -- This message was sent by Atlassian Jira (v8.20.10#820010)