[jira] [Created] (FLINK-35831) Rotate job id on savepoint upgrade as well

2024-07-14 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-35831: -- Summary: Rotate job id on savepoint upgrade as well Key: FLINK-35831 URL: https://issues.apache.org/jira/browse/FLINK-35831 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-35832) IFNULL returns error result in Flink SQL

2024-07-14 Thread Yu Chen (Jira)
Yu Chen created FLINK-35832: --- Summary: IFNULL returns error result in Flink SQL Key: FLINK-35832 URL: https://issues.apache.org/jira/browse/FLINK-35832 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-35833) ArtifactFetchManager always requires writable filesystem

2024-07-14 Thread Dylan Meissner (Jira)
Dylan Meissner created FLINK-35833: -- Summary: ArtifactFetchManager always requires writable filesystem Key: FLINK-35833 URL: https://issues.apache.org/jira/browse/FLINK-35833 Project: Flink

[jira] [Created] (FLINK-35834) Update Doris Dependency to 1.6.2 to use group commit.

2024-07-14 Thread LvYanquan (Jira)
LvYanquan created FLINK-35834: - Summary: Update Doris Dependency to 1.6.2 to use group commit. Key: FLINK-35834 URL: https://issues.apache.org/jira/browse/FLINK-35834 Project: Flink Issue Type: B

Re: [DISCUSS] FLIP-469: Supports Adaptive Optimization of StreamGraph

2024-07-14 Thread Zhu Zhu
+1 for the FLIP It is useful to adaptively optimize logical execution plans(stream operators and stream edges) for batch jobs. One question: The FLIP already proposed to update the REST API & Web UI to show operators that are not yet converted to job vertices. However, I think it would be better

Re: Re: Re: [DISCUSS] FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2

2024-07-14 Thread Xuannan Su
Hi, Wencong, Thanks for driving the FLIP. +1 for this FLIP. It is a useful mechanism to let the operator provide the hint for the engine to optimize the execution. Best regards, Xuannan On Sat, Jul 6, 2024 at 3:53 PM Wencong Liu wrote: > > Hi Yuxin, > Thanks for the reply. > > For idempotence

[jira] [Created] (FLINK-35835) SnapshotFileMergingCompatibilityITCase.testSwitchFromDisablingToEnablingFileMerging failed on AZP

2024-07-14 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35835: -- Summary: SnapshotFileMergingCompatibilityITCase.testSwitchFromDisablingToEnablingFileMerging failed on AZP Key: FLINK-35835 URL: https://issues.apache.org/jira/browse/FLINK-35835

Re: [DISCUSS] FLIP-460: Display source/sink I/O metrics on Flink Web UI

2024-07-14 Thread Xintong Song
+1 Best, Xintong On Sat, Jul 13, 2024 at 12:54 AM Őrhidi Mátyás wrote: > +1 on this. Thank you, Zhanghao! > > Cheers, > Matyas > > On Fri, Jul 12, 2024 at 5:58 PM Becket Qin wrote: > > > Thanks for the proposal, Zhanghao. > > > > +1 on the proposal. It makes a lot of sense. > > > > Thanks,

Re: [DISCUSS] FLIP-460: Display source/sink I/O metrics on Flink Web UI

2024-07-14 Thread Leonard Xu
Thanks for zhanghao for kicking off the thread. > It is especially confusing for simple ETL jobs where there's a single > chained operator with 0 input rate and 0 output rate. This case have confused flink users for a long time, +1 for the FLIP. Best, Leonard

[jira] [Created] (FLINK-35836) Some S5 related ITCases failed in JDK17 due to reflection issue

2024-07-14 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35836: -- Summary: Some S5 related ITCases failed in JDK17 due to reflection issue Key: FLINK-35836 URL: https://issues.apache.org/jira/browse/FLINK-35836 Project: Flink

Re: [DISCUSS] FLIP-469: Supports Adaptive Optimization of StreamGraph

2024-07-14 Thread Junrui Lee
Hi Zhu, Thanks for your feedback. Following your suggestion, I have updated the public interface section of the FLIP with the following additions: 1. UI: The job topology will display a hybrid of the current JobGraph along with downstream components yet to be converted to a StreamGraph. On the t