[jira] [Created] (FLINK-31622) Add ARRAY_APPEND supported in SQL & Table API

jackylau created FLINK-31622: Summary: Add ARRAY_APPEND supported in SQL & Table API Key: FLINK-31622 URL: https://issues.apache.org/jira/browse/FLINK-31622 Project: Flink Issue Type:

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

Hi, Jane Thanks for your detailed explanation. > Maybe it deserves another FLIP to discuss whether we need a multiple-level state TTL configuration mechanism and how to properly implement it. +1, and this is also what I want to emphasize. The title of this FLIP is "For Table API & SQL", but

[jira] [Created] (FLINK-31621) Add ARRAY_REVERSE supported in SQL & Table API

jackylau created FLINK-31621: Summary: Add ARRAY_REVERSE supported in SQL & Table API Key: FLINK-31621 URL: https://issues.apache.org/jira/browse/FLINK-31621 Project: Flink Issue Type:

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

Hi, dev, Thank you all for the helpful information and discussion. I have updated FLIP according to the discussion. The main changes are as follows: <1> Proposed Changes will support extending the SerDes to a local file to Flink's FileSystem and support SQL client gateway mode usage. <2>

Re: RIC Incremental and GIC Incremental checkpoint use question

Hey Thanks for trying out GIC! As Yanfei mentioned, GIC and RocksDB incremental do not conflict with each other. GIC is a generalized way to do incremental Flink checkpoints. At the same time, RocksDB-incremental is a way to do incremental snapshots for backend db (RocksDB). Please let us know

Re: [ANNOUNCE] Kafka Connector Code Removal from apache/flink:main branch and code freezing

Hi Gordon. https://issues.apache.org/jira/browse/FLINK-31006, which is also a critical bug in kafka. it will not exit after all partitions consumed when jobmanager failover in pipeline mode running unbounded source. and i talked with @PatrickRen offline, don't

[jira] [Created] (FLINK-31620) ReducingUpsertWriter does not flush the wrapped writer

Alex Sorokoumov created FLINK-31620: --- Summary: ReducingUpsertWriter does not flush the wrapped writer Key: FLINK-31620 URL: https://issues.apache.org/jira/browse/FLINK-31620 Project: Flink

[jira] [Created] (FLINK-31619) Upgrade Stateful Functions to Flink 1.16.1

nowke created FLINK-31619: - Summary: Upgrade Stateful Functions to Flink 1.16.1 Key: FLINK-31619 URL: https://issues.apache.org/jira/browse/FLINK-31619 Project: Flink Issue Type: Improvement

[VOTE] FLIP-284: Making AsyncSinkWriter Flush triggers adjustable

Dear Flink developers, I want to move discussion on this FLIP[1] to voting. Discussion thread[2] has been inactive for more than 2 months. Please feel free to add your feedback below. The vote will be open for at least 72 hours unless there is an objection or not enough votes. [1]

[jira] [Created] (FLINK-31618) Broken links in docs for Pulsar connector

Ran Tao created FLINK-31618: --- Summary: Broken links in docs for Pulsar connector Key: FLINK-31618 URL: https://issues.apache.org/jira/browse/FLINK-31618 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31617) Upgrade the SnakeYaml Maven dependency

Jeff Yang created FLINK-31617: - Summary: Upgrade the SnakeYaml Maven dependency Key: FLINK-31617 URL: https://issues.apache.org/jira/browse/FLINK-31617 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31616) Add user docs for canary resources

Gyula Fora created FLINK-31616: -- Summary: Add user docs for canary resources Key: FLINK-31616 URL: https://issues.apache.org/jira/browse/FLINK-31616 Project: Flink Issue Type: Improvement

Re: RIC Incremental and GIC Incremental checkpoint use question

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

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

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: