[jira] [Created] (FLINK-24664) Support merge for JSON_ARRAYAGG

2021-10-26 Thread Jira
Ingo Bürk created FLINK-24664: - Summary: Support merge for JSON_ARRAYAGG Key: FLINK-24664 URL: https://issues.apache.org/jira/browse/FLINK-24664 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-24663) PyFlink failed to get the site packege path because of no quote in shell command

2021-10-26 Thread jackwangcs (Jira)
jackwangcs created FLINK-24663: -- Summary: PyFlink failed to get the site packege path because of no quote in shell command Key: FLINK-24663 URL: https://issues.apache.org/jira/browse/FLINK-24663 Project:

[jira] [Created] (FLINK-24662) PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden"

2021-10-26 Thread Dian Fu (Jira)
Dian Fu created FLINK-24662: --- Summary: PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden" Key: FLINK-24662 URL: https://issues.apache.org/jira/browse/FLINK-24662

[jira] [Created] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

2021-10-26 Thread Ada Wong (Jira)
Ada Wong created FLINK-24661: Summary: ConfigOption add isSecret method to judge sensitive options Key: FLINK-24661 URL: https://issues.apache.org/jira/browse/FLINK-24661 Project: Flink Issue Ty

[jira] [Created] (FLINK-24660) Allow setting KafkaSubscriber in KafkaSourceBuilder

2021-10-26 Thread Mason Chen (Jira)
Mason Chen created FLINK-24660: -- Summary: Allow setting KafkaSubscriber in KafkaSourceBuilder Key: FLINK-24660 URL: https://issues.apache.org/jira/browse/FLINK-24660 Project: Flink Issue Type: I

[jira] [Created] (FLINK-24659) Two active miniCluster in RemoteBenchmarkBase

2021-10-26 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24659: - Summary: Two active miniCluster in RemoteBenchmarkBase Key: FLINK-24659 URL: https://issues.apache.org/jira/browse/FLINK-24659 Project: Flink Issue

[jira] [Created] (FLINK-24658) Debug logs for buffer size calculation

2021-10-26 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24658: - Summary: Debug logs for buffer size calculation Key: FLINK-24658 URL: https://issues.apache.org/jira/browse/FLINK-24658 Project: Flink Issue Type:

[jira] [Created] (FLINK-24657) Add metric of the total real size of input/output buffers queue

2021-10-26 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24657: - Summary: Add metric of the total real size of input/output buffers queue Key: FLINK-24657 URL: https://issues.apache.org/jira/browse/FLINK-24657 Project: F

Re: Flink sql client usability improvements

2021-10-26 Thread Jark Wu
Hi Sergey, Welcome contributions! You can read the FLIP introduction [1] first. I think FLIP-163 is a good example for you which is a SQL Client improvement we made in 1.13. [1]: https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals [2]: https://cwiki.apache.org/confluence

[jira] [Created] (FLINK-24656) Add user document for Window Deduplication

2021-10-26 Thread JING ZHANG (Jira)
JING ZHANG created FLINK-24656: -- Summary: Add user document for Window Deduplication Key: FLINK-24656 URL: https://issues.apache.org/jira/browse/FLINK-24656 Project: Flink Issue Type: Sub-task

Re: [NOTICE] flink-streaming-java no longer depends on Scala and lost it's suffix

2021-10-26 Thread Martijn Visser
This is an awesome accomplishment, many thanks! Ideally we also manage to complete https://issues.apache.org/jira/browse/FLINK-24427 for 1.15 to get Flink in a much better shape for our Scala users. On Tue, 26 Oct 2021 at 12:34, Arvid Heise wrote: > Awesome. Thank you very much for all the hard

Re: Shading in flink-table-blink and upgrade compatibility issue

2021-10-26 Thread Timo Walther
Hi Thomas, thanks for your feedback. The error that you are experiencing is definitely a bug in 1.13.3 and the missing method should be reintroduced in the next patch version to make code compiled against older patch versions run again. Regarding the discussion points: I agree that flink-ta

Flink sql client usability improvements

2021-10-26 Thread Sergey Nuyanzin
Hello Flink community currently I work a bit with some regarding Flink sql client usability issues [1] I noticed that there could be a lot more usability improvement, that's why first I want to ask if it makes sense for the community to raise such a FLIP. And yes, I would like to contribute here.

[jira] [Created] (FLINK-24655) Support checkpoint for jobs using iteration

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24655: --- Summary: Support checkpoint for jobs using iteration Key: FLINK-24655 URL: https://issues.apache.org/jira/browse/FLINK-24655 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24654) NPE on RetractableTopNFunction when some records were cleared by state ttl

2021-10-26 Thread lincoln lee (Jira)
lincoln lee created FLINK-24654: --- Summary: NPE on RetractableTopNFunction when some records were cleared by state ttl Key: FLINK-24654 URL: https://issues.apache.org/jira/browse/FLINK-24654 Project: Fl

[jira] [Created] (FLINK-24653) Support per-round operators inside the iteration.

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24653: --- Summary: Support per-round operators inside the iteration. Key: FLINK-24653 URL: https://issues.apache.org/jira/browse/FLINK-24653 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24652) Add operator wrapper for per-round operators

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24652: --- Summary: Add operator wrapper for per-round operators Key: FLINK-24652 URL: https://issues.apache.org/jira/browse/FLINK-24652 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24651) Support bounded all-round iteration

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24651: --- Summary: Support bounded all-round iteration Key: FLINK-24651 URL: https://issues.apache.org/jira/browse/FLINK-24651 Project: Flink Issue Type: Sub-task Com

[jira] [Created] (FLINK-24650) Support unbounded iteration.

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24650: --- Summary: Support unbounded iteration. Key: FLINK-24650 URL: https://issues.apache.org/jira/browse/FLINK-24650 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-24649) Add DraftExecutionEnvironment to support wrapping operators during compile time

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24649: --- Summary: Add DraftExecutionEnvironment to support wrapping operators during compile time Key: FLINK-24649 URL: https://issues.apache.org/jira/browse/FLINK-24649 Project: Flink

[jira] [Created] (FLINK-24648) Ceil, floor for some timeunit return wrong results or fail with CompileException

2021-10-26 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-24648: --- Summary: Ceil, floor for some timeunit return wrong results or fail with CompileException Key: FLINK-24648 URL: https://issues.apache.org/jira/browse/FLINK-24648

Re: [NOTICE] flink-streaming-java no longer depends on Scala and lost it's suffix

2021-10-26 Thread Arvid Heise
Awesome. Thank you very much for all the hard work! On Tue, Oct 26, 2021 at 1:06 AM Chesnay Schepler wrote: > This time with proper formatting... > > flink-batch-sql-test > flink-cep > flink-cli-test > flink-clients > flink-connector-elasticsearch-base > flink-connector-elasticsearch5 > flink-co

[jira] [Created] (FLINK-24647) ClusterUncaughtExceptionHandler does not log the exception

2021-10-26 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-24647: --- Summary: ClusterUncaughtExceptionHandler does not log the exception Key: FLINK-24647 URL: https://issues.apache.org/jira/browse/FLINK-24647 Project: Flink Issu

[jira] [Created] (FLINK-24646) Add operator wrapper for all-round iterations

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24646: --- Summary: Add operator wrapper for all-round iterations Key: FLINK-24646 URL: https://issues.apache.org/jira/browse/FLINK-24646 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24645) Implements the feedback mechanism and the controller operators

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24645: --- Summary: Implements the feedback mechanism and the controller operators Key: FLINK-24645 URL: https://issues.apache.org/jira/browse/FLINK-24645 Project: Flink Issue T

[jira] [Created] (FLINK-24644) Introduce Add broadcast output to broadcast events to all the downstream tasks

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24644: --- Summary: Introduce Add broadcast output to broadcast events to all the downstream tasks Key: FLINK-24644 URL: https://issues.apache.org/jira/browse/FLINK-24644 Project: Flink

[jira] [Created] (FLINK-24643) Introduce the flink-ml-iteration module and iteration api

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24643: --- Summary: Introduce the flink-ml-iteration module and iteration api Key: FLINK-24643 URL: https://issues.apache.org/jira/browse/FLINK-24643 Project: Flink Issue Type: S

[jira] [Created] (FLINK-24642) Implements unified iteration to support algorithms in flink-ml

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24642: --- Summary: Implements unified iteration to support algorithms in flink-ml Key: FLINK-24642 URL: https://issues.apache.org/jira/browse/FLINK-24642 Project: Flink Issue T

[jira] [Created] (FLINK-24641) Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file.

2021-10-26 Thread Hadiiiiiiiii (Jira)
Hadi created FLINK-24641: Summary: Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file. Key: FLINK-24641 URL: https://issues.apache.org/jira/browse/FLINK-24641

[RESULT][VOTE] FLIP-176: Unified Iteration to Support Algorithms (Flink ML)

2021-10-26 Thread Yun Gao
Hi all, I'm glad to annouce that we have unanimously approved this FLIP. There are 4 approved votings, 3 of which are binding: Guowei Ma (binding) Till Rohrmann (binding) Yunfeng Zhou (non-binding) Becket Qin (binding) Very thanks everyone for the dicussion and votings! Best, Yun -

Re: [DISCUSS] Creating an external connector repository

2021-10-26 Thread Arvid Heise
Hi folks, I think some questions came up and I'd like to address the question of the timing. Could you clarify what release cadence you're thinking of? There's quite > a big range that fits "more frequent than Flink" (per-commit, daily, > weekly, bi-weekly, monthly, even bi-monthly). The short a