[jira] [Created] (FLINK-28318) table idle state ttl configure does not have check when window size bigger then table state ttl

yutao created FLINK-28318: - Summary: table idle state ttl configure does not have check when window size bigger then table state ttl Key: FLINK-28318 URL: https://issues.apache.org/jira/browse/FLINK-28318 P

[jira] [Created] (FLINK-28317) Throw unsupport exception when RexSubQuery contains LogicalUnion and correlate variables

luoyuxia created FLINK-28317: Summary: Throw unsupport exception when RexSubQuery contains LogicalUnion and correlate variables Key: FLINK-28317 URL: https://issues.apache.org/jira/browse/FLINK-28317 Proj

[jira] [Created] (FLINK-28316) [UI] add external taskmanager log links in the vertex drawer under history server

Junhan Yang created FLINK-28316: --- Summary: [UI] add external taskmanager log links in the vertex drawer under history server Key: FLINK-28316 URL: https://issues.apache.org/jira/browse/FLINK-28316 Proje

[jira] [Created] (FLINK-28315) [UI] Introduce aggregate stats in tables of the subtasks and taskmanagers

Junhan Yang created FLINK-28315: --- Summary: [UI] Introduce aggregate stats in tables of the subtasks and taskmanagers Key: FLINK-28315 URL: https://issues.apache.org/jira/browse/FLINK-28315 Project: Flin

[jira] [Created] (FLINK-28314) Introduce "Cluster Environment" tab under history server Web UI

Junhan Yang created FLINK-28314: --- Summary: Introduce "Cluster Environment" tab under history server Web UI Key: FLINK-28314 URL: https://issues.apache.org/jira/browse/FLINK-28314 Project: Flink

[jira] [Created] (FLINK-28313) Add history server flag to DashboardConfiguration

Yangze Guo created FLINK-28313: -- Summary: Add history server flag to DashboardConfiguration Key: FLINK-28313 URL: https://issues.apache.org/jira/browse/FLINK-28313 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-28312) Introduce REST APIs for log URL retrieval

Yangze Guo created FLINK-28312: -- Summary: Introduce REST APIs for log URL retrieval Key: FLINK-28312 URL: https://issues.apache.org/jira/browse/FLINK-28312 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28311) Introduce REST APIs for the environmental information

Yangze Guo created FLINK-28311: -- Summary: Introduce REST APIs for the environmental information Key: FLINK-28311 URL: https://issues.apache.org/jira/browse/FLINK-28311 Project: Flink Issue Type:

[jira] [Created] (FLINK-28310) Introduce aggregating task metrics

Yangze Guo created FLINK-28310: -- Summary: Introduce aggregating task metrics Key: FLINK-28310 URL: https://issues.apache.org/jira/browse/FLINK-28310 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28309) Introduce metrics of the duration that a task stays in each status

Yangze Guo created FLINK-28309: -- Summary: Introduce metrics of the duration that a task stays in each status Key: FLINK-28309 URL: https://issues.apache.org/jira/browse/FLINK-28309 Project: Flink

[jira] [Created] (FLINK-28308) Introduce accumulated time metrics that a running task is busy / idle / back-pressured

Yangze Guo created FLINK-28308: -- Summary: Introduce accumulated time metrics that a running task is busy / idle / back-pressured Key: FLINK-28308 URL: https://issues.apache.org/jira/browse/FLINK-28308 Pr

[jira] [Created] (FLINK-28307) FLIP-241: Completed Jobs Information Enhancement

Yangze Guo created FLINK-28307: -- Summary: FLIP-241: Completed Jobs Information Enhancement Key: FLINK-28307 URL: https://issues.apache.org/jira/browse/FLINK-28307 Project: Flink Issue Type: New

[RESULT][VOTE] FLIP-240: Introduce "ANALYZE TABLE" Syntax

Hi, everyone. FLIP-240: Introduce "ANALYZE TABLE" Syntax[1] has been accepted. There are 3 binding votes, 2 non-binding votes[2]. - Jingsong Li(binding) - Shengkai Fang(binding) - Roc Marshal(non-binding) - Leonard Xu(binding) - yuxia(non-binding) None against. Thanks again for every one who co

[jira] [Created] (FLINK-28306) Support get table statistic for Hive partition table

luoyuxia created FLINK-28306: Summary: Support get table statistic for Hive partition table Key: FLINK-28306 URL: https://issues.apache.org/jira/browse/FLINK-28306 Project: Flink Issue Type: Sub-

[RESULT][VOTE] FLIP-241: Completed Jobs Information Enhancement

Hi everyone, FLIP-241[1] has been accepted according to the votes. There have been 4 approving votes, 4 out of 4 are binding[2]: - Yangze Guo - Xintong Song - Zhu Zhu - Yang Wang There is no disapproving vote. [1]: https://cwiki.apache.org/confluence/x/dRD1D [2]: https://lists.apach

Re: [VOTE] FLIP-241: Completed Jobs Information Enhancement

Hi all, Thanks for participating in this voting process. Closing it now. Best regards, Junhan Yang Wang 于2022年6月30日周四 10:15写道： > +1 (binding) > > Best, > Yang > > Zhu Zhu 于2022年6月29日周三 14:31写道： > > > +1 (binding) > > > > Thanks, > > Zhu > > > > Xintong Song 于2022年6月23日周四 17:01写道： > > > > > >

Re: [VOTE] Apache Flink ML Release 2.1.0, release candidate #1

Hi Dong, Thanks for the check. I will cancel this release and release RC2 today. Dong Lin 于2022年6月30日周四 08:47写道： > Hi Zhipeng, > > I just realized that these two PRs (link > and link > ) are not included

Re: [VOTE] FLIP-241: Completed Jobs Information Enhancement

+1 (binding) Best, Yang Zhu Zhu 于2022年6月29日周三 14:31写道： > +1 (binding) > > Thanks, > Zhu > > Xintong Song 于2022年6月23日周四 17:01写道： > > > > +1 (binding) > > > > Best, > > > > Xintong > > > > > > > > On Thu, Jun 23, 2022 at 1:49 PM Yangze Guo wrote: > > > > > +1 (binding) > > > > > > Best, > > > Y

[jira] [Created] (FLINK-28305) SQL Client end-to-end test failed with ElasticsearchException

Huang Xingbo created FLINK-28305: Summary: SQL Client end-to-end test failed with ElasticsearchException Key: FLINK-28305 URL: https://issues.apache.org/jira/browse/FLINK-28305 Project: Flink

Re: [VOTE] Apache Flink ML Release 2.1.0, release candidate #1

Hi Zhipeng, I just realized that these two PRs (link and link ) are not included in the release branch, which means that the Flink ML 2.1 website will not include the documentation (link

Re: [VOTE] FLIP-242: Introduce configurable RateLimitingStrategy for Async Sink

This is looking good! Thanks for the efforts. +1 (binding) Op wo 29 jun. 2022 om 20:55 schreef Piotr Nowojski > Thanks for starting the voting thread. +1 (binding) from my side. > > Best, > Piotrek > > > > śr., 29 cze 2022 o 17:32 Teoh, Hong > napisał(a): > > > Hi everyone, > > > > Thanks for

[jira] [Created] (FLINK-28304) Rework Kubernetes tests to no longer use driver version "none"

Martijn Visser created FLINK-28304: -- Summary: Rework Kubernetes tests to no longer use driver version "none" Key: FLINK-28304 URL: https://issues.apache.org/jira/browse/FLINK-28304 Project: Flink

Re: [VOTE] FLIP-242: Introduce configurable RateLimitingStrategy for Async Sink

Thanks for starting the voting thread. +1 (binding) from my side. Best, Piotrek śr., 29 cze 2022 o 17:32 Teoh, Hong napisał(a): > Hi everyone, > > Thanks for all the feedback so far. Based on the discussion [1], we seem > to have consensus. So, I would like to start a vote on FLIP-242 [2]. >

[jira] [Created] (FLINK-28303) Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions

Robert Metzger created FLINK-28303: -- Summary: Kafka SQL Connector loses data when restoring from a savepoint with a topic with empty partitions Key: FLINK-28303 URL: https://issues.apache.org/jira/browse/FLINK-28

[VOTE] FLIP-242: Introduce configurable RateLimitingStrategy for Async Sink

Hi everyone, Thanks for all the feedback so far. Based on the discussion [1], we seem to have consensus. So, I would like to start a vote on FLIP-242 [2]. The vote will last for at least 72 hours unless there is an objection or insufficient votes. [1] https://lists.apache.org/thread/k5s970xlqo

Re: [VOTE] Apache Flink ML Release 2.1.0, release candidate #1

Thanks for creating the release! +1 (non-binding) Here is what I checked. All required checks are included. - Verified that the checksums and GPG files match the corresponding release files. - Verified that the source distributions do not contain any binaries. - Built the source distribution and

Re: [DISCUSS] FLIP-245: Source Supports Speculative Execution For Batch Job

Hi, Jing Thanks a lot for writing this FLIP, which is very useful to Batch users. Currently I have only two small questions: 1. First of all, please complete the fault-tolerant processing flow in the FLIP. (Maybe you've already considered it, but it's better to explicitly give the specific solut