Re: RIC Incremental and GIC Incremental checkpoint use question

2023-03-25 Thread Yanfei Lei
Hi ConradJam, > If Generic Incremental Checkpoint (GIC) enable, rocksdb Incremental > Checkpoint can be disable or enable, Do they both have conflicting switches, > does my turning on (GIC) mean I no longer need enable rocksdb Incremental > Checkpoint ? The GIC and rocksdb incremental Checkp

[jira] [Created] (FLINK-31615) Fix some parts forgot to translate in "Table API" page of "Table API & SQL"

2023-03-25 Thread Hang Ruan (Jira)
Hang Ruan created FLINK-31615: - Summary: Fix some parts forgot to translate in "Table API" page of "Table API & SQL" Key: FLINK-31615 URL: https://issues.apache.org/jira/browse/FLINK-31615 Project: Flink

RIC Incremental and GIC Incremental checkpoint use question

2023-03-25 Thread ConradJam
Hi Community . I would like to consult about some configurations of Rocksdb incremental checkpoints and GIC. In Flink 1.17,I want to try this feature . If Generic Incremental Checkpoint (GIC) enable, rocksdb Incremental Checkpoint can be disable or enable, Do they both have conflicting switches, do

Re: Unit Testing onTimer() event function with TestHarness - onTimer() not being called

2023-03-25 Thread David Anderson
1. The timestamp passed to testHarness.processElement should be the timestamp that would have been extracted from the element by the timestamp extractor in your watermark strategy. 2. Your tests should call testHarness.processWatermark and pass in the watermark(s) you want to work with. processBr

[jira] [Created] (FLINK-31614) Upgrade autoscaling example to 1.17.0 image

2023-03-25 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-31614: -- Summary: Upgrade autoscaling example to 1.17.0 image Key: FLINK-31614 URL: https://issues.apache.org/jira/browse/FLINK-31614 Project: Flink Issue Type: Improveme

Re: [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs

2023-03-25 Thread Jane Chan
Hi Benchao, Thank you for sharing the discussion thread with us; it's very informational and helpful. Let's set aside the semantics for a moment, and let me respond to the rest of your points. > SQL + hints may be the easiest way for users to write and maintain their SQL jobs. Of course, hints ar

Re: [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs

2023-03-25 Thread Jane Chan
Hi Leonard, Jing and Shengkai, Thanks so much for your insightful comments. Here are my thoughts @Shengkai > 1. How the Gateway users use this feature? As far as I know, the EXEUCTE PLAN only supports local file right now. Is it possible to extend this syntax to allow for reading plan files from

[jira] [Created] (FLINK-31613) Some default operator config values are overwritten by values.yaml

2023-03-25 Thread Mate Czagany (Jira)
Mate Czagany created FLINK-31613: Summary: Some default operator config values are overwritten by values.yaml Key: FLINK-31613 URL: https://issues.apache.org/jira/browse/FLINK-31613 Project: Flink

[jira] [Created] (FLINK-31612) ClassNotFoundException when using GCS path as HA directory.

2023-03-25 Thread Mohit Aggarwal (Jira)
Mohit Aggarwal created FLINK-31612: -- Summary: ClassNotFoundException when using GCS path as HA directory. Key: FLINK-31612 URL: https://issues.apache.org/jira/browse/FLINK-31612 Project: Flink

Re: [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs

2023-03-25 Thread Benchao Li
Thanks Jane for starting this discussion. Finally we are considering fine-grained configurations for SQL jobs, this is very exciting! I see a lot of opinions that "SQL hints should not affect the results", and this indeed has been discussed extensively while we introduced FLIP-113[1][2]. After thr

Re: [ANNOUNCE] Apache Flink 1.17.0 released

2023-03-25 Thread Hang Ruan
Thanks for the great work ! Congrats all! Best, Hang Panagiotis Garefalakis 于2023年3月25日周六 03:22写道: > Congrats all! Well done! > > Cheers, > Panagiotis > > On Fri, Mar 24, 2023 at 2:46 AM Qingsheng Ren wrote: > > > I'd like to say thank you to all contributors of Flink 1.17. Your support > > an