[jira] [Created] (FLINK-18836) Python UDTF doesn't work well when the return type isn't generator

2020-08-05 Thread Dian Fu (Jira)
Dian Fu created FLINK-18836: --- Summary: Python UDTF doesn't work well when the return type isn't generator Key: FLINK-18836 URL: https://issues.apache.org/jira/browse/FLINK-18836 Project: Flink

Re: [DISCUSS] Planning Flink 1.12

2020-08-05 Thread Yu Li
+1 for extending feature freeze date to end of October. Feature development in the master branch could be unblocked through creating the release branch, but every coin has its two sides (smile) Best Regards, Yu On Wed, 5 Aug 2020 at 20:12, Robert Metzger wrote: > Thanks all for your opinion.

[jira] [Created] (FLINK-18835) sql using group by, duplicated group fileld appears

2020-08-05 Thread YHF (Jira)
YHF created FLINK-18835: --- Summary: sql using group by, duplicated group fileld appears Key: FLINK-18835 URL: https://issues.apache.org/jira/browse/FLINK-18835 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18834) Could not locate the included file 'generated/rocks_db_native_metric_configuration.html'

2020-08-05 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-18834: Summary: Could not locate the included file 'generated/rocks_db_native_metric_configuration.html' Key: FLINK-18834 URL: https://issues.apache.org/jira/browse/FLINK-18834

[jira] [Created] (FLINK-18833) Improve the Python documentation about sql

2020-08-05 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-18833: Summary: Improve the Python documentation about sql Key: FLINK-18833 URL: https://issues.apache.org/jira/browse/FLINK-18833 Project: Flink Issue Type:

Re: A question when use flink sql 1.11.0

2020-08-05 Thread godfrey he
Hi, u...@flink.apache.org is used for question discussions, dev@flink.apache.org is used for development related discussions. Regarding the exception, that indicates flink-table-blink_xx.jar is not in the classpath, please check it. Best, Godfrey 魏烽 于2020年8月5日周三 下午5:15写道: > Hi > >I have

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

2020-08-05 Thread jincheng sun
Hi David, Thank you for sharing the problems with the current document, and I agree with you as I also got the same feedback from Chinese users. I am often contacted by users to ask questions such as whether PyFlink supports "Java UDF" and whether PyFlink supports "xxxConnector". The root cause of

[jira] [Created] (FLINK-18831) Improve the Python documentation about the operations in Table

2020-08-05 Thread Dian Fu (Jira)
Dian Fu created FLINK-18831: --- Summary: Improve the Python documentation about the operations in Table Key: FLINK-18831 URL: https://issues.apache.org/jira/browse/FLINK-18831 Project: Flink Issue

[jira] [Created] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask

2020-08-05 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-18832: - Summary: BoundedBlockingSubpartition does not work with StreamTask Key: FLINK-18832 URL: https://issues.apache.org/jira/browse/FLINK-18832 Project: Flink

[jira] [Created] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-08-05 Thread liupengcheng (Jira)
liupengcheng created FLINK-18830: Summary: JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty Key: FLINK-18830 URL:

[jira] [Created] (FLINK-18829) Remove logback-related codepaths and configuration file

2020-08-05 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18829: -- Summary: Remove logback-related codepaths and configuration file Key: FLINK-18829 URL: https://issues.apache.org/jira/browse/FLINK-18829 Project: Flink

Re: [DISCUSS] Planning Flink 1.12

2020-08-05 Thread Robert Metzger
Thanks all for your opinion. @Chesnay: That is a risk, but I hope the people responsible for individual FLIPs plan accordingly. Extending the time till the feature freeze should not mean that we are extending the scope of the release. Ideally, features are done before FF, and they use the time

[jira] [Created] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s

2020-08-05 Thread Yang Wang (Jira)
Yang Wang created FLINK-18828: - Summary: Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s Key: FLINK-18828 URL: https://issues.apache.org/jira/browse/FLINK-18828

Re: [DISCUSS] Planning Flink 1.12

2020-08-05 Thread Chesnay Schepler
I'm a bit concerned about end of October, because it means we have Flink forward, which usually means at least 1 week of little-to-no activity, and then 1 week until feature-freeze. On 05/08/2020 11:56, jincheng sun wrote: +1 for end of October from me as well. Best, Jincheng Kostas

Re: [DISCUSS] Planning Flink 1.12

2020-08-05 Thread jincheng sun
+1 for end of October from me as well. Best, Jincheng Kostas Kloudas 于2020年8月5日周三 下午4:59写道: > +1 for end of October from me as well. > > Cheers, > Kostas > > On Wed, Aug 5, 2020 at 9:59 AM Till Rohrmann wrote: > > > +1 for end of October from my side as well. > > > > Cheers, > > Till > > > >

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

2020-08-05 Thread Wei Zhong
Hi Xingbo, Thanks for your information. I think the PySpark's documentation redesigning deserves our attention. It seems that the Spark community has also begun to treat the user experience of Python documentation more seriously. We can continue to pay attention to the discussion and

[jira] [Created] (FLINK-18827) The time attribute is lost when constructing a Table via TableEnvironment.from

2020-08-05 Thread Dian Fu (Jira)
Dian Fu created FLINK-18827: --- Summary: The time attribute is lost when constructing a Table via TableEnvironment.from Key: FLINK-18827 URL: https://issues.apache.org/jira/browse/FLINK-18827 Project: Flink

A question when use flink sql 1.11.0

2020-08-05 Thread 魏烽
Hi I have a question when use flink sql 1.11.0 Error: Exception in thread "main" org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath. Reason: No factory

Re: [DISCUSS] Planning Flink 1.12

2020-08-05 Thread Kostas Kloudas
+1 for end of October from me as well. Cheers, Kostas On Wed, Aug 5, 2020 at 9:59 AM Till Rohrmann wrote: > +1 for end of October from my side as well. > > Cheers, > Till > > On Tue, Aug 4, 2020 at 9:46 PM Stephan Ewen wrote: > > > The end of October sounds good from my side, unless it

Re: [DISCUSS] Planning Flink 1.12

2020-08-05 Thread Till Rohrmann
+1 for end of October from my side as well. Cheers, Till On Tue, Aug 4, 2020 at 9:46 PM Stephan Ewen wrote: > The end of October sounds good from my side, unless it collides with some > holidays that affect many committers. > > Feature-wise, I believe we can definitely make good use of the

[jira] [Created] (FLINK-18826) Support to emit and encode upsert messages to Kafka

2020-08-05 Thread Jark Wu (Jira)
Jark Wu created FLINK-18826: --- Summary: Support to emit and encode upsert messages to Kafka Key: FLINK-18826 URL: https://issues.apache.org/jira/browse/FLINK-18826 Project: Flink Issue Type:

[jira] [Created] (FLINK-18825) Support to process CDC message in batch mode

2020-08-05 Thread Jark Wu (Jira)
Jark Wu created FLINK-18825: --- Summary: Support to process CDC message in batch mode Key: FLINK-18825 URL: https://issues.apache.org/jira/browse/FLINK-18825 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-18824) Support serialization for canal-json format

2020-08-05 Thread Jark Wu (Jira)
Jark Wu created FLINK-18824: --- Summary: Support serialization for canal-json format Key: FLINK-18824 URL: https://issues.apache.org/jira/browse/FLINK-18824 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-18823) Support serialization for debezium-json format

2020-08-05 Thread Jark Wu (Jira)
Jark Wu created FLINK-18823: --- Summary: Support serialization for debezium-json format Key: FLINK-18823 URL: https://issues.apache.org/jira/browse/FLINK-18823 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-18822) [umbrella] Improve and complete Change Data Capture formats

2020-08-05 Thread Jark Wu (Jira)
Jark Wu created FLINK-18822: --- Summary: [umbrella] Improve and complete Change Data Capture formats Key: FLINK-18822 URL: https://issues.apache.org/jira/browse/FLINK-18822 Project: Flink Issue

Re: Status of FLIPs

2020-08-05 Thread jincheng sun
Good job Dian! Thank you for helping to maintain the state of FLIPs which is very important for the community to understand the progress of FLIPs. Best, Jincheng Dian Fu 于2020年8月4日周二 下午5:41写道: > Hi all, > > When going through the status of existing FLIPs[1], I found that the > status of quite

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

2020-08-05 Thread Xingbo Huang
Hi, I found that the spark community is also working on redesigning pyspark documentation[1] recently. Maybe we can compare the difference between our document structure and its document structure. [1] https://issues.apache.org/jira/browse/SPARK-31851

[jira] [Created] (FLINK-18821) Netty client retry mechanism may cause PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely

2020-08-05 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-18821: --- Summary: Netty client retry mechanism may cause PartitionRequestClientFactory#createPartitionRequestClient to wait infinitely Key: FLINK-18821 URL: