[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

[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-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

[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] https://cwiki.

[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

[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

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 have

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 t

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> Proposed

[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: Improvemen

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 this

[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: Improvement

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

Hi Shuo, Thanks for your comments. > The title of this FLIP is "For Table API & SQL", but this proposal actually only covers SQL jobs via compiled json plan Please correct me if I'm wrong, but I'm thinking that the scope of this FLIP should be consistent with the FLIP-190. Here is an example to