Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

2020-09-27 Thread liupengcheng
ri, 25 Sep 2020 at 22:59, liupengcheng wrote: > Hi, Jark, > I'm very interested in this feature, and I'm also working on this > recently. > I just have a glance at the FLIP, it's good, but I found that > there is no plan to add SESSION windows.

Re: [DISCUSS] FLIP-145: Support SQL windowing table-valued function

2020-09-25 Thread liupengcheng
Hi, Jark, I'm very interested in this feature, and I'm also working on this recently. I just have a glance at the FLIP, it's good, but I found that there is no plan to add SESSION windows. Also, I think there can be more things we can do based on this new syntax. For

Re: [ANNOUNCE] New Apache Flink Committer - Godfrey He

2020-09-16 Thread liupengcheng
Congrats! Best, PengchengLiu 在 2020/9/16 下午2:23,“Benchao Li” 写入: Congratulations! Zhu Zhu 于2020年9月16日周三 下午1:36写道: > Congratulations! > > Thanks, > Zhu > > Leonard Xu 于2020年9月16日周三 下午1:32写道: > > > Congratulations! Godfrey > > > > Best, >

Re: [ANNOUNCE] Apache Flink 1.10.2 released

2020-08-26 Thread liupengcheng
Thanks ZhuZhu for managing this release and everyone who contributed to this. Best, Pengcheng 在 2020/8/26 下午7:06,“Congxian Qiu” 写入: Thanks ZhuZhu for managing this release and everyone else who contributed to this release! Best, Congxian Xingbo Huang 于2020年8月26日周三

[jira] [Created] (FLINK-18852) StreamScan should keep the same parallelism as the input

2020-08-07 Thread liupengcheng (Jira)
liupengcheng created FLINK-18852: Summary: StreamScan should keep the same parallelism as the input Key: FLINK-18852 URL: https://issues.apache.org/jira/browse/FLINK-18852 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: https://issues.apache.org/jira

[jira] [Created] (FLINK-15906) physical memory exceeded causing being killed by yarn

2020-02-04 Thread liupengcheng (Jira)
liupengcheng created FLINK-15906: Summary: physical memory exceeded causing being killed by yarn Key: FLINK-15906 URL: https://issues.apache.org/jira/browse/FLINK-15906 Project: Flink Issue

[jira] [Created] (FLINK-15848) Support both fixed allocator and dynamic allocator in flink

2020-02-02 Thread liupengcheng (Jira)
liupengcheng created FLINK-15848: Summary: Support both fixed allocator and dynamic allocator in flink Key: FLINK-15848 URL: https://issues.apache.org/jira/browse/FLINK-15848 Project: Flink

[jira] [Created] (FLINK-15702) Make sqlClient classloader aligned with other components

2020-01-20 Thread liupengcheng (Jira)
liupengcheng created FLINK-15702: Summary: Make sqlClient classloader aligned with other components Key: FLINK-15702 URL: https://issues.apache.org/jira/browse/FLINK-15702 Project: Flink

[jira] [Created] (FLINK-15392) SqlClient

2019-12-25 Thread liupengcheng (Jira)
liupengcheng created FLINK-15392: Summary: SqlClient Key: FLINK-15392 URL: https://issues.apache.org/jira/browse/FLINK-15392 Project: Flink Issue Type: Bug Reporter

[jira] [Created] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

2019-12-10 Thread liupengcheng (Jira)
liupengcheng created FLINK-15175: Summary: syntax not supported in SQLClient for TPCDS queries Key: FLINK-15175 URL: https://issues.apache.org/jira/browse/FLINK-15175 Project: Flink Issue

[jira] [Created] (FLINK-14876) Putting xercesImpl related classes into alwaysParentFirstLoaderPatterns

2019-11-20 Thread liupengcheng (Jira)
liupengcheng created FLINK-14876: Summary: Putting xercesImpl related classes into alwaysParentFirstLoaderPatterns Key: FLINK-14876 URL: https://issues.apache.org/jira/browse/FLINK-14876 Project

[jira] [Created] (FLINK-14429) Wrong app final status when running yarn-cluster in non-detached mode

2019-10-17 Thread liupengcheng (Jira)
liupengcheng created FLINK-14429: Summary: Wrong app final status when running yarn-cluster in non-detached mode Key: FLINK-14429 URL: https://issues.apache.org/jira/browse/FLINK-14429 Project: Flink

[jira] [Created] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

2019-10-07 Thread liupengcheng (Jira)
liupengcheng created FLINK-14341: Summary: Flink-python builds with failure: no such option: --prefix Key: FLINK-14341 URL: https://issues.apache.org/jira/browse/FLINK-14341 Project: Flink

[jira] [Created] (FLINK-14292) Provide terasort examples

2019-09-30 Thread liupengcheng (Jira)
liupengcheng created FLINK-14292: Summary: Provide terasort examples Key: FLINK-14292 URL: https://issues.apache.org/jira/browse/FLINK-14292 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-09-19 Thread liupengcheng (Jira)
liupengcheng created FLINK-14123: Summary: Change taskmanager.memory.fraction default value to 0.6 Key: FLINK-14123 URL: https://issues.apache.org/jira/browse/FLINK-14123 Project: Flink

[jira] [Created] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

2019-09-09 Thread liupengcheng (Jira)
liupengcheng created FLINK-14038: Summary: ExecutionGraph deploy failed due to akka timeout Key: FLINK-14038 URL: https://issues.apache.org/jira/browse/FLINK-14038 Project: Flink Issue Type

[jira] [Created] (FLINK-14037) Deserializing the input/output formats failed: unread block data

2019-09-09 Thread liupengcheng (Jira)
liupengcheng created FLINK-14037: Summary: Deserializing the input/output formats failed: unread block data Key: FLINK-14037 URL: https://issues.apache.org/jira/browse/FLINK-14037 Project: Flink