[
https://issues.apache.org/jira/browse/FLINK-34127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836149#comment-17836149
]
Martijn Visser commented on FLINK-34127:
----------------------------------------
[~mason6345] Is this something that you can check? I think I also see some
flakyness here, like with
https://github.com/apache/flink-connector-kafka/actions/runs/8646160813/job/23704885473
> Kafka connector repo runs a duplicate of `IntegrationTests` framework tests
> ---------------------------------------------------------------------------
>
> Key: FLINK-34127
> URL: https://issues.apache.org/jira/browse/FLINK-34127
> Project: Flink
> Issue Type: Improvement
> Components: Build System / CI, Connectors / Kafka
> Affects Versions: kafka-3.0.2
> Reporter: Mason Chen
> Priority: Major
>
> I found out this behavior when troubleshooting CI flakiness. These
> integration tests make heavy use of the CI since they require Kafka,
> Zookeeper, and Docker containers. We can further stablize CI by not
> redundantly running these set of tests.
> `grep -E ".*testIdleReader\[TestEnvironment.*" 14_Compile\ and\ test.txt`
> returns:
> ```
> 2024-01-17T00:51:05.2943150Z Test
> org.apache.flink.connector.kafka.dynamic.source.DynamicKafkaSourceITTest.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext:
> [org.apache.flink.connector.kafka.testutils.DynamicKafkaSourceExternalContext@43e9a8a2],
> Semantic: [EXACTLY_ONCE]] is running.
> 2024-01-17T00:51:07.6922535Z Test
> org.apache.flink.connector.kafka.dynamic.source.DynamicKafkaSourceITTest.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext:
> [org.apache.flink.connector.kafka.testutils.DynamicKafkaSourceExternalContext@43e9a8a2],
> Semantic: [EXACTLY_ONCE]] successfully run.
> 2024-01-17T00:56:27.1326332Z Test
> org.apache.flink.connector.kafka.dynamic.source.DynamicKafkaSourceITTest.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext:
> [org.apache.flink.connector.kafka.testutils.DynamicKafkaSourceExternalContext@2db4a84a],
> Semantic: [EXACTLY_ONCE]] is running.
> 2024-01-17T00:56:28.4000830Z Test
> org.apache.flink.connector.kafka.dynamic.source.DynamicKafkaSourceITTest.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext:
> [org.apache.flink.connector.kafka.testutils.DynamicKafkaSourceExternalContext@2db4a84a],
> Semantic: [EXACTLY_ONCE]] successfully run.
> 2024-01-17T00:56:58.7830792Z Test
> org.apache.flink.connector.kafka.source.KafkaSourceITCase.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext: [KafkaSource-PARTITION], Semantic:
> [EXACTLY_ONCE]] is running.
> 2024-01-17T00:56:59.0544092Z Test
> org.apache.flink.connector.kafka.source.KafkaSourceITCase.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext: [KafkaSource-PARTITION], Semantic:
> [EXACTLY_ONCE]] successfully run.
> 2024-01-17T00:56:59.3910987Z Test
> org.apache.flink.connector.kafka.source.KafkaSourceITCase.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext: [KafkaSource-TOPIC], Semantic:
> [EXACTLY_ONCE]] is running.
> 2024-01-17T00:56:59.6025298Z Test
> org.apache.flink.connector.kafka.source.KafkaSourceITCase.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext: [KafkaSource-TOPIC], Semantic:
> [EXACTLY_ONCE]] successfully run.
> 2024-01-17T00:57:37.8378640Z Test
> org.apache.flink.connector.kafka.source.KafkaSourceITCase.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext: [KafkaSource-PARTITION], Semantic:
> [EXACTLY_ONCE]] is running.
> 2024-01-17T00:57:38.0144732Z Test
> org.apache.flink.connector.kafka.source.KafkaSourceITCase.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext: [KafkaSource-PARTITION], Semantic:
> [EXACTLY_ONCE]] successfully run.
> 2024-01-17T00:57:38.2004796Z Test
> org.apache.flink.connector.kafka.source.KafkaSourceITCase.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext: [KafkaSource-TOPIC], Semantic:
> [EXACTLY_ONCE]] is running.
> 2024-01-17T00:57:38.4072815Z Test
> org.apache.flink.connector.kafka.source.KafkaSourceITCase.IntegrationTests.testIdleReader[TestEnvironment:
> [MiniCluster], ExternalContext: [KafkaSource-TOPIC], Semantic:
> [EXACTLY_ONCE]] successfully run.
> 2024-01-17T01:06:11.2933375Z Test
> org.apache.flink.tests.util.kafka.KafkaSourceE2ECase.testIdleReader[TestEnvironment:
> [FlinkContainers], ExternalContext: [KafkaSource-PARTITION], Semantic:
> [EXACTLY_ONCE]] is running.
> 2024-01-17T01:06:12.1790031Z Test
> org.apache.flink.tests.util.kafka.KafkaSourceE2ECase.testIdleReader[TestEnvironment:
> [FlinkContainers], ExternalContext: [KafkaSource-PARTITION], Semantic:
> [EXACTLY_ONCE]] successfully run.
> 2024-01-17T01:06:12.5703927Z Test
> org.apache.flink.tests.util.kafka.KafkaSourceE2ECase.testIdleReader[TestEnvironment:
> [FlinkContainers], ExternalContext: [KafkaSource-TOPIC], Semantic:
> [EXACTLY_ONCE]] is running.
> 2024-01-17T01:06:13.3369574Z Test
> org.apache.flink.tests.util.kafka.KafkaSourceE2ECase.testIdleReader[TestEnvironment:
> [FlinkContainers], ExternalContext: [KafkaSource-TOPIC], Semantic:
> [EXACTLY_ONCE]] successfully run.
> ```
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
