[jira] [Created] (FLINK-26834) Introduce BlockingIterator to help testing

2022-03-23 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26834: Summary: Introduce BlockingIterator to help testing Key: FLINK-26834 URL: https://issues.apache.org/jira/browse/FLINK-26834 Project: Flink Issue Type:

[jira] [Created] (FLINK-26833) missing link to setup-pyflink-virtual-env.sh / error during deploy

2022-03-23 Thread Kafka Chris (Jira)
Kafka Chris created FLINK-26833: --- Summary: missing link to setup-pyflink-virtual-env.sh / error during deploy Key: FLINK-26833 URL: https://issues.apache.org/jira/browse/FLINK-26833 Project: Flink

[jira] [Created] (FLINK-26832) Output more status info for JobObserver

2022-03-23 Thread Biao Geng (Jira)
Biao Geng created FLINK-26832: - Summary: Output more status info for JobObserver Key: FLINK-26832 URL: https://issues.apache.org/jira/browse/FLINK-26832 Project: Flink Issue Type: Sub-task

Re: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-03-23 Thread 刘大龙
> -原始邮件- > 发件人: "Peter Huang" > 发送时间: 2022-03-23 11:13:32 (星期三) > 收件人: dev > 抄送: > 主题: Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL > > Hi Ron, > > Thanks for reviving the discussion of the work. The design looks good. A > small typo in the FLIP is that currently it

Re: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-03-23 Thread 刘大龙
> -原始邮件- > 发件人: "罗宇侠(莫辞)" > 发送时间: 2022-03-23 10:02:26 (星期三) > 收件人: "Mang Zhang" , "Flink Dev" > 抄送: > 主题: 回复:Re:[DISCUSS] FLIP-214 Support Advanced Function DDL > > Hi Ron, Thanks for starting this dicuss, some Spark/Hive users will benefit > from it. The flip looks good to me. I

Re: Re:[DISCUSS] FLIP-214 Support Advanced Function DDL

2022-03-23 Thread 刘大龙
> -原始邮件- > 发件人: "Mang Zhang" > 发送时间: 2022-03-22 11:35:24 (星期二) > 收件人: dev@flink.apache.org > 抄送: > 主题: Re:[DISCUSS] FLIP-214 Support Advanced Function DDL > > Hi Ron, Thank you so much for this suggestion, this is so good. > In our company, when users use custom UDF, it is very

Apache Flink 1.15 Meetup

2022-03-23 Thread Johannes Moser
Dear Flink community, On the 30th of March we will host a meetup on the upcoming Flink 1.15 release. Get all the information here [1]. There will also be an AMA with Matthias and Chesnay. If you already got a question on your mind, let me know. You might want to have a look at the release wiki

[jira] [Created] (FLINK-26831) Move JarHandlers to flink-runtime

2022-03-23 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-26831: Summary: Move JarHandlers to flink-runtime Key: FLINK-26831 URL: https://issues.apache.org/jira/browse/FLINK-26831 Project: Flink Issue Type:

[jira] [Created] (FLINK-26830) Move jobs to suspended state before upgrading

2022-03-23 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26830: -- Summary: Move jobs to suspended state before upgrading Key: FLINK-26830 URL: https://issues.apache.org/jira/browse/FLINK-26830 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26829) ClassCastException will be thrown when the second operand of divide is a function call

2022-03-23 Thread luoyuxia (Jira)
luoyuxia created FLINK-26829: Summary: ClassCastException will be thrown when the second operand of divide is a function call Key: FLINK-26829 URL: https://issues.apache.org/jira/browse/FLINK-26829

[jira] [Created] (FLINK-26828) build flink-ml example module

2022-03-23 Thread Jing Ge (Jira)
Jing Ge created FLINK-26828: --- Summary: build flink-ml example module Key: FLINK-26828 URL: https://issues.apache.org/jira/browse/FLINK-26828 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26827) FlinkSQL和hive整合报错

2022-03-23 Thread zhushifeng (Jira)
zhushifeng created FLINK-26827: -- Summary: FlinkSQL和hive整合报错 Key: FLINK-26827 URL: https://issues.apache.org/jira/browse/FLINK-26827 Project: Flink Issue Type: Bug Components: Table

Re: [DISCUSS] Structure of the Flink Documentation (Languages & APIs)

2022-03-23 Thread Timo Walther
Hi Konstantin, thank you for starting this discussion again. It is a pitty that we have never implemented FLIP-60 because it was the result of long offline discussions with a lot of people closer working on the documentation topic. I think splitting the documentation into *Option 1:

[jira] [Created] (FLINK-26826) env.readFile() fails if auto-generated UIDs disabled

2022-03-23 Thread Arseniy Tashoyan (Jira)
Arseniy Tashoyan created FLINK-26826: Summary: env.readFile() fails if auto-generated UIDs disabled Key: FLINK-26826 URL: https://issues.apache.org/jira/browse/FLINK-26826 Project: Flink

Re: [DISCUSS] Preview release for Flink Kubernetes Operator

2022-03-23 Thread Yang Wang
The whole release plan sounds good to me. Thanks for driving this. Best, Yang Gyula Fóra 于2022年3月23日周三 16:22写道: > Hi Team! > > I think we are in good shape to cut the preview release branch in a few > days and start testing. > I suggest we aim for a feature freeze on Friday the 25th (except

Re: [DISCUSS] Structure of the Flink Documentation (Languages & APIs)

2022-03-23 Thread Martijn Visser
Hi everyone, Thanks for bringing this up for discussion Konstantin. I do think we are currently not serving Flink users proper documentation, which hurts Flink's adoption and results in unnecessary opened Jira tickets, Stackoverflow posts and email threads which in the end also cause a strain on

Re: [DISCUSS] Structure of the Flink Documentation (Languages & APIs)

2022-03-23 Thread Dian Fu
To summarize, I tend to Option 2 "Language First" in case we could find a way to eliminate documentation duplication. On Wed, Mar 23, 2022 at 5:02 PM Dian Fu wrote: > Hi Konstantin, > > Thanks a lot for bringing up this discussion. > > Currently, the Python documentation is more like a mixture

Re: [DISCUSS] Structure of the Flink Documentation (Languages & APIs)

2022-03-23 Thread Konstantin Knauf
Hi Dian, Thank you for sharing your thoughts. What do you propose going forward? I am not sure I got this from your email. Best, Konstantin On Wed, Mar 23, 2022 at 10:03 AM Dian Fu wrote: > Hi Konstantin, > > Thanks a lot for bringing up this discussion. > > Currently, the Python

Re: [DISCUSS] Structure of the Flink Documentation (Languages & APIs)

2022-03-23 Thread Dian Fu
Hi Konstantin, Thanks a lot for bringing up this discussion. Currently, the Python documentation is more like a mixture of Option 1 and Option 2. It contains two parts: 1) The first part is the independent page [1] which could be seen as the main entrypoint for Python users. 2) The second part

Re: [DISCUSS] Structure of the Flink Documentation (Languages & APIs)

2022-03-23 Thread Konstantin Knauf
Hi Jark, Thank you for joining the discussion. I am totally fine with the "Language Tabs". Would be good to hear what the PyFlink community thinks, because the Python Documentation is the biggest exception to the "Language Tabs" approach. @Jark Wu : Do you agree that SQL should be separate from

问题咨询: Too more data in this partition: 2147483648

2022-03-23 Thread Kevin Lee
Version: 1.13 mode:batch & FlinkSQL 这是什么原因导致的 Error: ``` java.lang.RuntimeException: Too more data in this partition: 2147483648 at org.apache.flink.table.runtime.hashtable.BinaryHashPartition.insertIntoBuildBuffer(BinaryHashPartition.java:264) at

[jira] [Created] (FLINK-26825) Document State Machine Graph for JM Deployment

2022-03-23 Thread Biao Geng (Jira)
Biao Geng created FLINK-26825: - Summary: Document State Machine Graph for JM Deployment Key: FLINK-26825 URL: https://issues.apache.org/jira/browse/FLINK-26825 Project: Flink Issue Type:

[jira] [Created] (FLINK-26824) Upgrade Flink's supported Cassandra versions to match with the Cassandra community supported versions

2022-03-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26824: -- Summary: Upgrade Flink's supported Cassandra versions to match with the Cassandra community supported versions Key: FLINK-26824 URL:

Re: [DISCUSS] Preview release for Flink Kubernetes Operator

2022-03-23 Thread Gyula Fóra
Hi Team! I think we are in good shape to cut the preview release branch in a few days and start testing. I suggest we aim for a feature freeze on Friday the 25th (except for the ongoing session job work which might need 1-2 extra days) and cut the release branch on Monday the 28th (and hopefully

[jira] [Created] (FLINK-26823) Make Cassandra Source available for Flink SQL users

2022-03-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26823: -- Summary: Make Cassandra Source available for Flink SQL users Key: FLINK-26823 URL: https://issues.apache.org/jira/browse/FLINK-26823 Project: Flink

Re: [DISCUSS] Structure of the Flink Documentation (Languages & APIs)

2022-03-23 Thread Jark Wu
Hi Konstantin, Thanks for starting this discussion. >From my perspective, I prefer the "Language Tabs" approach. But maybe we can improve the tabs to move to the sidebar or top menu, which allows users to first decide on their language and then the API. IMO, programming languages are just like

[jira] [Created] (FLINK-26822) Add Source implementation for Cassandra connector

2022-03-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26822: -- Summary: Add Source implementation for Cassandra connector Key: FLINK-26822 URL: https://issues.apache.org/jira/browse/FLINK-26822 Project: Flink Issue

[jira] [Created] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink

2022-03-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26821: -- Summary: Refactor Cassandra Sink implementation to the ASync Sink Key: FLINK-26821 URL: https://issues.apache.org/jira/browse/FLINK-26821 Project: Flink

[jira] [Created] (FLINK-26820) Improve Cassandra connector by adding missing features and refactoring to latest standards

2022-03-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26820: -- Summary: Improve Cassandra connector by adding missing features and refactoring to latest standards Key: FLINK-26820 URL: https://issues.apache.org/jira/browse/FLINK-26820

[jira] [Created] (FLINK-26819) AppendOnlyFirstNFunction produce wrong result when with offset and without rank number

2022-03-23 Thread lincoln lee (Jira)
lincoln lee created FLINK-26819: --- Summary: AppendOnlyFirstNFunction produce wrong result when with offset and without rank number Key: FLINK-26819 URL: https://issues.apache.org/jira/browse/FLINK-26819

[jira] [Created] (FLINK-26818) Required Information on parsing complex nested JSON using SQL API

2022-03-23 Thread Arindam Bhattacharjee (Jira)
Arindam Bhattacharjee created FLINK-26818: - Summary: Required Information on parsing complex nested JSON using SQL API Key: FLINK-26818 URL: https://issues.apache.org/jira/browse/FLINK-26818

[jira] [Created] (FLINK-26817) Update ingress docs with templating examples

2022-03-23 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-26817: - Summary: Update ingress docs with templating examples Key: FLINK-26817 URL: https://issues.apache.org/jira/browse/FLINK-26817 Project: Flink Issue Type:

[jira] [Created] (FLINK-26816) Verify the java doc is consistent with the code implementation

2022-03-23 Thread Yang Wang (Jira)
Yang Wang created FLINK-26816: - Summary: Verify the java doc is consistent with the code implementation Key: FLINK-26816 URL: https://issues.apache.org/jira/browse/FLINK-26816 Project: Flink

[jira] [Created] (FLINK-26815) NullPointerException in FlinkConfigBuilderTest

2022-03-23 Thread Yang Wang (Jira)
Yang Wang created FLINK-26815: - Summary: NullPointerException in FlinkConfigBuilderTest Key: FLINK-26815 URL: https://issues.apache.org/jira/browse/FLINK-26815 Project: Flink Issue Type: Bug