Re: Usage of PublicEvolving annotation

2022-07-10 Thread Konstantin Knauf
Hi Blake, thank you for reaching out. @PublicEvolving interface can only be changed with a minor release of Apache Flink (e.g. 1.6). While the JavaDoc is indeed ambiguous there was a FLIP recently that discussed this topic:

Re: Re: Re: [DISCUSS ] Make state.backend.incremental as true by default

2022-07-10 Thread Yuan Mei
Hey Lihe Ma, 1. I do not think making different state backends with different default setups (configs) is a bad idea. I have some similar ideas as Zakelly, Hangxiang and you mentioned above. Think about this: even though the incremental checkpoint for HashMap Statebackend is released in 1.16, it

Re: [DISCUSS] FLIP-249: Flink Web UI Enhancement for Speculative Execution

2022-07-10 Thread Gen Luo
Hi Lijie and Zhu, Thanks for the suggestion. I agree that the name "Blocked Free Slots" is more clear to users. I'll take the suggestion and update the FLIP. On Fri, Jul 8, 2022 at 9:12 PM Zhu Zhu wrote: > I agree that it can be more useful to show the number of slots that are > free but

[jira] [Created] (FLINK-28481) Bump the fabric8 kubernetes-client to 5.12.3

2022-07-10 Thread Yang Wang (Jira)
Yang Wang created FLINK-28481: - Summary: Bump the fabric8 kubernetes-client to 5.12.3 Key: FLINK-28481 URL: https://issues.apache.org/jira/browse/FLINK-28481 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-251: Support collecting arbitrary number of streams

2022-07-10 Thread Konstantin Knauf
Makes sense to me. Thank you, Chesnay. +1 David Anderson schrieb am Fr., 8. Juli 2022, 13:56: > I've found that with our current tooling it's frustrating to try to write > good end-to-end tests for real-world jobs with multiple sinks. > DataStream#executeAndCollect() is okay for simple

[jira] [Created] (FLINK-28480) Forward timeControllerExecution time as histogram for JOSDK Metrics interface

2022-07-10 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-28480: -- Summary: Forward timeControllerExecution time as histogram for JOSDK Metrics interface Key: FLINK-28480 URL: https://issues.apache.org/jira/browse/FLINK-28480 Project:

[jira] [Created] (FLINK-28479) Add latency histogram for resource state transitions

2022-07-10 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-28479: -- Summary: Add latency histogram for resource state transitions Key: FLINK-28479 URL: https://issues.apache.org/jira/browse/FLINK-28479 Project: Flink Issue Type: