[
https://issues.apache.org/jira/browse/FLINK-23778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410676#comment-17410676
]
Nicolaus Weidner commented on FLINK-23778:
------------------------------------------
Putting this on hold for now. The logs in both runs are consistent with the
conclusions on the linked ticket: It looks like between producing the records
in the Kafka topic and reading them, log compaction kicked in and removed them
(since we use explicit timestamps which are quite old), causing the test to
hang because it awaits records. Log compaction was disabled in
[https://github.com/apache/flink/commit/7814ee257b526d52f80a17143e228fb936b03ff5,]
so let's see if another failure happens with this fix in place.
> UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue hangs on Azure
> ----------------------------------------------------------------------------
>
> Key: FLINK-23778
> URL: https://issues.apache.org/jira/browse/FLINK-23778
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Table SQL / Ecosystem
> Affects Versions: 1.14.0
> Reporter: Till Rohrmann
> Assignee: Nicolaus Weidner
> Priority: Critical
> Labels: test-stability
> Fix For: 1.14.0
>
>
> The test {{UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue}}
> hangs on Azure.
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=22123&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=15a22db7-8faa-5b34-3920-d33c9f0ca23c&l=8847
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
