[jira] [Created] (FLINK-28483) Basic schema evolution for table store

Jingsong Lee created FLINK-28483: Summary: Basic schema evolution for table store Key: FLINK-28483 URL: https://issues.apache.org/jira/browse/FLINK-28483 Project: Flink Issue Type: New Featur

[jira] [Created] (FLINK-28482) num-sorted-run.stop-trigger introduced a unstable merging

Jingsong Lee created FLINK-28482: Summary: num-sorted-run.stop-trigger introduced a unstable merging Key: FLINK-28482 URL: https://issues.apache.org/jira/browse/FLINK-28482 Project: Flink Iss

Re: [VOTE] Creating benchmark channel in Apache Flink slack

+1 (binding) Thanks Anton for driving this! Best, Yun Gao -- From:Anton Kalashnikov Send Time:2022 Jul. 8 (Fri.) 22:59 To:undefined Subject:[VOTE] Creating benchmark channel in Apache Flink slack Hi everyone, I would like to

Re: Usage of PublicEvolving annotation

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: https://cwiki.apache.org/confluence/display/FLINK/FLIP-196%3A+Source+API+s

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

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 m

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

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 blocke

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

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

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 pipelines

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

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: Fl

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

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: