Hi,
@Roman very sorry for the late response for a long time,
> Merging artifacts from multiple checkpoints would apparently
require multiple concurrent checkpoints
I think it might not need concurrent checkpoints: suppose some
operators (like the committer aggregator in the option 2) maintains
t
Yun Gao created FLINK-25089:
---
Summary: KafkaSourceITCase.testBasicRead hangs on azure
Key: FLINK-25089
URL: https://issues.apache.org/jira/browse/FLINK-25089
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-25088:
---
Summary: KafkaSinkITCase failed on azure due to Container did not
start correctly
Key: FLINK-25088
URL: https://issues.apache.org/jira/browse/FLINK-25088
Project: Flink
Shammon created FLINK-25087:
---
Summary: Move heartbeats from akka to the dedicated thread pool in
JM
Key: FLINK-25087
URL: https://issues.apache.org/jira/browse/FLINK-25087
Project: Flink
Issue Typ
Shammon created FLINK-25086:
---
Summary: Move resource timeout checkers in JM from akka executors
to the dedicated thread pool
Key: FLINK-25086
URL: https://issues.apache.org/jira/browse/FLINK-25086
Project:
Shammon created FLINK-25085:
---
Summary: Add a scheduled thread pool in JM and close it when job
terminates
Key: FLINK-25085
URL: https://issues.apache.org/jira/browse/FLINK-25085
Project: Flink
Iss
+1 for Java 8 deprecation. It's an important signal for users and we
need to give sufficient time to adopt. Thanks Chesnay for starting the
discussion! Maybe user@ can be included into this discussion?
Thomas
On Fri, Nov 26, 2021 at 6:49 AM Becket Qin wrote:
>
> Thanks for raising the discussio
Ivan Budanaev created FLINK-25084:
-
Summary: Field names must be unique. Found duplicates
Key: FLINK-25084
URL: https://issues.apache.org/jira/browse/FLINK-25084
Project: Flink
Issue Type: Bu
