[
https://issues.apache.org/jira/browse/FLINK-34320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18113946#comment-18113946
]
Sylwester Lachiewicz commented on FLINK-34320:
----------------------------------------------
Triage finding (2026-09-10): the only evidence on this ticket is one CI run
against [PR #83|https://github.com/apache/flink-connector-kafka/pull/83],
closed without merging, where the log went silent after
{{FlinkKafkaProducerMigrationTest}} and the job was killed 45 minutes later by
the workflow timeout. That test class was removed with {{FlinkKafkaProducer}}
in [FLINK-36848|https://issues.apache.org/jira/browse/FLINK-36848] and no
longer exists on main.
The five most recent weekly runs (2026-08-23 to 2026-09-10, runs 32607460418,
33283936010, 34002024546, 34132678569, 34480435278) contain no silently killed
job; every failure is a surefire failure or a JUnit {{@Timeout}} with a stack
trace.
The underlying concern, a hung test eating the CI budget without a diagnostic,
is now tracked by
[FLINK-40139|https://issues.apache.org/jira/browse/FLINK-40139] (default
per-method JUnit timeout, [PR
#288|https://github.com/apache/flink-connector-kafka/pull/288]) and
[FLINK-40511|https://issues.apache.org/jira/browse/FLINK-40511] (measuring and
speeding up the slow ITCases).
Recommendation: link to FLINK-40511 and FLINK-40139 and close this one as a
duplicate of FLINK-40511; there is nothing left to investigate under this key.
_This comment was created with AI assistance._
> Flink Kafka connector tests time out
> ------------------------------------
>
> Key: FLINK-34320
> URL: https://issues.apache.org/jira/browse/FLINK-34320
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: kafka-3.1.0
> Reporter: Martijn Visser
> Priority: Critical
> Labels: test-stability
>
> https://github.com/apache/flink-connector-kafka/actions/runs/7700171105/job/20987805277?pr=83#step:14:61746
> {code:java}
> 2024-01-29T19:45:07.4412975Z 19:45:07,094 [ main] INFO
> org.apache.kafka.common.utils.AppInfoParser [] - App info
> kafka.producer for producer-client-id unregistered
> 2024-01-29T19:45:07.4413978Z 19:45:07,097 [ main] INFO
> org.apache.flink.runtime.io.disk.FileChannelManagerImpl [] -
> FileChannelManager removed spill file directory
> /tmp/flink-io-3306202c-1639-4b7b-a54c-381826e3682e
> 2024-01-29T19:45:07.4414533Z 19:45:07,440 [ main] INFO
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerMigrationTest
> [] -
> 2024-01-29T19:45:07.4414785Z
> --------------------------------------------------------------------------------
> 2024-01-29T19:45:07.4415494Z Test testRestoreProducer[Migration Savepoint:
> 1.16](org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerMigrationTest)
> successfully run.
> 2024-01-29T19:45:07.4415646Z
> ================================================================================
> 2024-01-29T19:45:07.4698277Z [WARNING] Tests run: 18, Failures: 0, Errors: 0,
> Skipped: 9, Time elapsed: 206.197 s - in
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerMigrationTest
> 2024-01-29T20:30:32.8459835Z ##[error]The action has timed out.
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
