JIRA Username

2021-03-11 Thread 积淀智慧
Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is zph.

[DISCUSS] Split PyFlink packages into two packages: apache-flink and apache-flink-libraries

2021-03-11 Thread Xingbo Huang
Hi everyone, Since release-1.11, pyflink has introduced cython support and we will release 7 packages (for different platforms and Python versions) to PyPI for each release and the size of each package is more than 200MB as we need to bundle the jar files into the package. The entire project

[jira] [Created] (FLINK-21741) Support SHOW JARS statement in SQL Client

2021-03-11 Thread Jark Wu (Jira)
Jark Wu created FLINK-21741: --- Summary: Support SHOW JARS statement in SQL Client Key: FLINK-21741 URL: https://issues.apache.org/jira/browse/FLINK-21741 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21742) Support REMOVE JAR statement in SQL Client

2021-03-11 Thread Jark Wu (Jira)
Jark Wu created FLINK-21742: --- Summary: Support REMOVE JAR statement in SQL Client Key: FLINK-21742 URL: https://issues.apache.org/jira/browse/FLINK-21742 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21740) CliTableauResultViewTest.testCancelBatchResult fails

2021-03-11 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21740: - Summary: CliTableauResultViewTest.testCancelBatchResult fails Key: FLINK-21740 URL: https://issues.apache.org/jira/browse/FLINK-21740 Project: Flink Issue Type:

[jira] [Created] (FLINK-21739) TopN with TUMBLE window get Incorrect result

2021-03-11 Thread wxmimperio (Jira)
wxmimperio created FLINK-21739: -- Summary: TopN with TUMBLE window get Incorrect result Key: FLINK-21739 URL: https://issues.apache.org/jira/browse/FLINK-21739 Project: Flink Issue Type: Bug

Re: [Parquet support]

2021-03-11 Thread Jingsong Li
Hi Etienne, Sorry for the late reply, I just merged your bug fixing. I think you can submit a PR for release-1.12. Best, Jingsong On Fri, Mar 12, 2021 at 12:22 AM Etienne Chauchot wrote: > Hi, > > I forgot to mention that I submitted the new ParquetAvroInputFormat to > master (1.13) but it

[jira] [Created] (FLINK-21738) reduce unnecessary method calls in ModuleManager

2021-03-11 Thread zoucao (Jira)
zoucao created FLINK-21738: -- Summary: reduce unnecessary method calls in ModuleManager Key: FLINK-21738 URL: https://issues.apache.org/jira/browse/FLINK-21738 Project: Flink Issue Type:

[jira] [Created] (FLINK-21737) FileSourceTextLinesITCase.testContinuousTextFileSourceWithJobManagerFailover fails

2021-03-11 Thread Matthias (Jira)
Matthias created FLINK-21737: Summary: FileSourceTextLinesITCase.testContinuousTextFileSourceWithJobManagerFailover fails Key: FLINK-21737 URL: https://issues.apache.org/jira/browse/FLINK-21737 Project:

Re: [Parquet support]

2021-03-11 Thread Etienne Chauchot
Hi, I forgot to mention that I submitted the new ParquetAvroInputFormat to master (1.13) but it is made to work for 1.12.x (last release) also and I'm using it with Flink 1.12.x. Maybe it could be a good candidate to be included in an upcoming 1.12.3 release, WDYT ? Best Etienne On

[jira] [Created] (FLINK-21736) Introduce latency tracking state

2021-03-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-21736: Summary: Introduce latency tracking state Key: FLINK-21736 URL: https://issues.apache.org/jira/browse/FLINK-21736 Project: Flink Issue Type: New Feature

Re: [Parquet support]

2021-03-11 Thread Etienne Chauchot
Hi all, I just submitted another parquet PR that adds ParquetAvroInputFormat (I'm using it in a benchmark I'm coding). If anyone is interested in reviewing it, be my guest: https://github.com/apache/flink/pull/15156 I have also an older parquet PR that fixes a format conversion bug that is

[RESULT][VOTE] FLIP-165: Operator's Flame Graphs

2021-03-11 Thread Alexander Fedulov
Hi All, I am happy to announce that FLIP-165 [1] is approved. The vote [2] is now closed. we received four +1 votes, all of which are binding, and no vetoes: - Till Rohrmann (binding) - Roman Khachatryan (binding) - Piotr Nowojski (binding) - Zhu Zhu (binding) Thanks everyone for participating!

[jira] [Created] (FLINK-21735) Harden JobMaster#updateTaskExecutionState()

2021-03-11 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-21735: --- Summary: Harden JobMaster#updateTaskExecutionState() Key: FLINK-21735 URL: https://issues.apache.org/jira/browse/FLINK-21735 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21734) Allow BLOCKING result partition to be individually consumable

2021-03-11 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-21734: --- Summary: Allow BLOCKING result partition to be individually consumable Key: FLINK-21734 URL: https://issues.apache.org/jira/browse/FLINK-21734 Project: Flink Issue

[jira] [Created] (FLINK-21733) WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBoundsException

2021-03-11 Thread lincoln lee (Jira)
lincoln lee created FLINK-21733: --- Summary: WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBoundsException Key: FLINK-21733 URL:

[jira] [Created] (FLINK-21732) Add apache-flink-libraries module

2021-03-11 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-21732: Summary: Add apache-flink-libraries module Key: FLINK-21732 URL: https://issues.apache.org/jira/browse/FLINK-21732 Project: Flink Issue Type: New Feature

Re: Upgrade calcite version

2021-03-11 Thread Jingsong Li
Hi, Yes, as Danny said, it is very hard work... A suggestion is that you can cherry-pick some bugfixs from the new Calcite version to your own internal Calcite branch, if you just want to fix some bugs. Best, Jingsong On Thu, Mar 11, 2021 at 2:28 PM Danny Chan wrote: > Hi Sheng ~ > > It is a