[DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-01-02 Thread Zhanghao Chen
Dear Flink devs, I'd like to start a discussion on FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change [1]. Currently, when user does not explicitly set operator UIDs, the chaining behavior will still affect state compatibility, as the gener

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-01-09 Thread David Morávek
Hi Zhanghao, Thanks for the FLIP. What you're proposing makes a lot of sense +1 Have you thought about how this works with unaligned checkpoints in case you go from unchained to chained? I think it should be fine because this scenario should only apply to forward/rebalance scenarios where we, as

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-01-09 Thread Zhanghao Chen
Chen From: David Morávek Sent: Wednesday, January 10, 2024 6:26 To: dev@flink.apache.org ; Piotr Nowojski Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change Hi Zhanghao, Thanks for the

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-01-10 Thread Yu Chen
apache.org/flink/flink-docs-release-1.18/docs/ops/state/checkpointing_under_backpressure/ > > > Best, > Zhanghao Chen > > From: David Morávek > Sent: Wednesday, January 10, 2024 6:26 > To: dev@flink.apache.org ; Piotr Nowojski > > Subject: Re: [DISCUSS] F

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-01-10 Thread Zhanghao Chen
ocs-release-1.18/docs/ops/state/checkpointing_under_backpressure/ Best, Zhanghao Chen From: David Morávek Sent: Wednesday, January 10, 2024 6:26 To: dev@flink.apache.org ; Piotr Nowojski Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatib

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-01-11 Thread Yu Chen
idea so far. Do you have any suggestions on this? > > Best, > Zhanghao Chen > From: Yu Chen > Sent: Thursday, January 11, 2024 13:52 > To: dev@flink.apache.org > Cc: Piotr Nowojski ; zhanghao.c...@outlook.com > > Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Oper

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-01-11 Thread Piotr Nowojski
ghao Chen > -- > *From:* Yu Chen > *Sent:* Thursday, January 11, 2024 13:52 > *To:* dev@flink.apache.org > *Cc:* Piotr Nowojski ; zhanghao.c...@outlook.com > > *Subject:* Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID > generation for impr

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-01-11 Thread Zhanghao Chen
anghao Chen From: Piotr Nowojski Sent: Friday, January 12, 2024 1:55 To: Yu Chen Cc: Zhanghao Chen ; dev@flink.apache.org Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change Hi, Using unaligned checkpoints is or

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-02-07 Thread Zhanghao Chen
K-5290 Best, Zhanghao Chen From: Zhanghao Chen Sent: Friday, January 12, 2024 10:46 To: Piotr Nowojski ; Yu Chen Cc: dev@flink.apache.org Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change Thanks for

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-02-07 Thread Chesnay Schepler
Chen From: Zhanghao Chen Sent: Friday, January 12, 2024 10:46 To: Piotr Nowojski ; Yu Chen Cc: dev@flink.apache.org Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change Thanks for the i

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-02-07 Thread Zhanghao Chen
From: Chesnay Schepler Sent: Thursday, February 8, 2024 2:01 To: dev@flink.apache.org ; Zhanghao Chen ; Piotr Nowojski ; Yu Chen Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change The FLIP is a b

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-02-07 Thread Piotr Nowojski
--- > *From:* Chesnay Schepler > *Sent:* Thursday, February 8, 2024 2:01 > *To:* dev@flink.apache.org ; Zhanghao Chen < > zhanghao.c...@outlook.com>; Piotr Nowojski ; Yu > Chen > *Subject:* Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID >

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-02-08 Thread Zhanghao Chen
prove the SQL experience for all community users as well, WDYT? > > Best, > Zhanghao Chen > -- > *From:* Chesnay Schepler > *Sent:* Thursday, February 8, 2024 2:01 > *To:* dev@flink.apache.org ; Zhanghao Chen < > zhanghao.c...@outlook.com>; Pi

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-02-08 Thread Martijn Visser
_ > From: Piotr Nowojski > Sent: Thursday, February 8, 2024 14:50 > To: Zhanghao Chen > Cc: Chesnay Schepler ; dev@flink.apache.org > ; Yu Chen > Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for > improved state compatibility on parallel

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-02-08 Thread Chesnay Schepler
nghao Chen From: Piotr Nowojski Sent: Thursday, February 8, 2024 14:50 To: Zhanghao Chen Cc: Chesnay Schepler ; dev@flink.apache.org ; Yu Chen Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change H

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-02-08 Thread Zhanghao Chen
e.org ; Martijn Visser Cc: Yu Chen Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change How exactly are you tuning SQL jobs without compiled plans while ensuring that the resulting compiled plans are compatible? That&#

Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

2024-02-11 Thread Benchao Li
; Sent: Thursday, February 8, 2024 18:12 > To: dev@flink.apache.org ; Martijn Visser > > Cc: Yu Chen > Subject: Re: [DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for > improved state compatibility on parallelism change > > How exactly are you tuning SQL jobs wit