[jira] [Created] (FLINK-21808) Support DQL in HiveParser

2021-03-15 Thread Rui Li (Jira)
Rui Li created FLINK-21808: -- Summary: Support DQL in HiveParser Key: FLINK-21808 URL: https://issues.apache.org/jira/browse/FLINK-21808 Project: Flink Issue Type: Sub-task Components: Conn

[jira] [Created] (FLINK-21807) Make ApplicationDeployer interface public

2021-03-15 Thread Yang Wang (Jira)
Yang Wang created FLINK-21807: - Summary: Make ApplicationDeployer interface public Key: FLINK-21807 URL: https://issues.apache.org/jira/browse/FLINK-21807 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21806) ContinuousEventTimeTrigger should register its first timer base on current watermark

2021-03-15 Thread Kezhu Wang (Jira)
Kezhu Wang created FLINK-21806: -- Summary: ContinuousEventTimeTrigger should register its first timer base on current watermark Key: FLINK-21806 URL: https://issues.apache.org/jira/browse/FLINK-21806 Proj

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

2021-03-15 Thread Dian Fu
Hi Xingbo, Thanks a lot for bringing up this discussion. Actually the size limit already becomes an issue during releasing 1.11.3 and 1.12.1. It blocks us to publish PyFlink packages to PyPI during the release as there is no enough space left (PS: already published the packages after increasin

[jira] [Created] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit Json ser/de

2021-03-15 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-21805: --- Summary: Support StreamExecRank and StreamExecSortLimit Json ser/de Key: FLINK-21805 URL: https://issues.apache.org/jira/browse/FLINK-21805 Project: Flink Issu

Beam College invitation

2021-03-15 Thread Mara Ruvalcaba
*Hi Apache Flink community, * *We want to invite you to Beam College, a fee training program focused on Apache Beam. * * ** The demand for people with data analytics skills is growing. Partnered with Google Cloud and the Apache Beam Open Source community, Beam College provides free trainin

[jira] [Created] (FLINK-21804) Load Changelog implementation via PluginManager

2021-03-15 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-21804: - Summary: Load Changelog implementation via PluginManager Key: FLINK-21804 URL: https://issues.apache.org/jira/browse/FLINK-21804 Project: Flink Iss

Re: [ANNOUCE][DISCUSS] Roadmap Update for Website

2021-03-15 Thread Stephan Ewen
I created a Pull Request for the roadmap update: https://github.com/apache/flink-web/pull/426 Happy to take reviews! Best, Stephan On Wed, Mar 10, 2021 at 1:55 PM Stephan Ewen wrote: > Thanks for the positive feedback. Will convert this to a pull request then > in the next days. > > Still loo

[jira] [Created] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

2021-03-15 Thread Craig Smoothey (Jira)
Craig Smoothey created FLINK-21803: -- Summary: Tumbling / Sliding windows are unaware of daylight savings time Key: FLINK-21803 URL: https://issues.apache.org/jira/browse/FLINK-21803 Project: Flink

Find many strange measurements in metrics database of influxdb

2021-03-15 Thread Tim yu
Hi all, I run many flink jobs that contains sql, they reports the metrics to infuxdb. I find many strange measurements in metrics database of influxdb, e.g. "from table1". Does sql produce those measurements ? What is the meanings of those measurements ? -- tim yu

[jira] [Created] (FLINK-21802) LogicalTypeJsonDeserializer/Serializer custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread Terry Wang (Jira)
Terry Wang created FLINK-21802: -- Summary: LogicalTypeJsonDeserializer/Serializer custom RowType/MapType/ArrayType/MultisetType Key: FLINK-21802 URL: https://issues.apache.org/jira/browse/FLINK-21802 Proj

[jira] [Created] (FLINK-21801) Update use new schema in Table, TableResult, TableOperation

2021-03-15 Thread Timo Walther (Jira)
Timo Walther created FLINK-21801: Summary: Update use new schema in Table, TableResult, TableOperation Key: FLINK-21801 URL: https://issues.apache.org/jira/browse/FLINK-21801 Project: Flink

[jira] [Created] (FLINK-21800) Guard MemorySegment against concurrent frees.

2021-03-15 Thread Xintong Song (Jira)
Xintong Song created FLINK-21800: Summary: Guard MemorySegment against concurrent frees. Key: FLINK-21800 URL: https://issues.apache.org/jira/browse/FLINK-21800 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-21799) Detect and fail explicitly on managed memory leaking

2021-03-15 Thread Xintong Song (Jira)
Xintong Song created FLINK-21799: Summary: Detect and fail explicitly on managed memory leaking Key: FLINK-21799 URL: https://issues.apache.org/jira/browse/FLINK-21799 Project: Flink Issue Ty

[jira] [Created] (FLINK-21798) Guard MemorySegment against multiple frees.

2021-03-15 Thread Xintong Song (Jira)
Xintong Song created FLINK-21798: Summary: Guard MemorySegment against multiple frees. Key: FLINK-21798 URL: https://issues.apache.org/jira/browse/FLINK-21798 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-21797) Performance regression on 03/11/21

2021-03-15 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-21797: --- Summary: Performance regression on 03/11/21 Key: FLINK-21797 URL: https://issues.apache.org/jira/browse/FLINK-21797 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21796) https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=14665&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=ff888d9b-cd34-53cc-d90f-3e446d355529

2021-03-15 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-21796: Summary: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=14665&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=ff888d9b-cd34-53cc-d90f-3e446d355529 Key: FLINK-217

Re: [DISCUSS] Move Flink ML pipeline API and library code to a separate repository named flink-ml

2021-03-15 Thread Till Rohrmann
+1 for moving Flink ML to a separate repository. Thanks for driving this discussion and effort Dong! Cheers, Till On Fri, Mar 12, 2021 at 1:19 PM Becket Qin wrote: > Thanks for raising the discussion, Dong. +1 on moving the Flink ML to a > separate repository. > > Machine learning is a big area

[jira] [Created] (FLINK-21795) Support retrieving slot details via rest api

2021-03-15 Thread Xintong Song (Jira)
Xintong Song created FLINK-21795: Summary: Support retrieving slot details via rest api Key: FLINK-21795 URL: https://issues.apache.org/jira/browse/FLINK-21795 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-21794) Support retrieving slot details via rest api

2021-03-15 Thread Xintong Song (Jira)
Xintong Song created FLINK-21794: Summary: Support retrieving slot details via rest api Key: FLINK-21794 URL: https://issues.apache.org/jira/browse/FLINK-21794 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-21793) Native K8s does not respect TM memory setups decided by RM

2021-03-15 Thread Xintong Song (Jira)
Xintong Song created FLINK-21793: Summary: Native K8s does not respect TM memory setups decided by RM Key: FLINK-21793 URL: https://issues.apache.org/jira/browse/FLINK-21793 Project: Flink Is

[jira] [Created] (FLINK-21792) Add a PythonFunctionRunnerDescriptor and unify the creation of all the PythonFunctionRunner

2021-03-15 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-21792: - Summary: Add a PythonFunctionRunnerDescriptor and unify the creation of all the PythonFunctionRunner Key: FLINK-21792 URL: https://issues.apache.org/jira/browse/FLINK-21792

[jira] [Created] (FLINK-21791) Support StreamExecLocalGroupAggregate and StreamExecGlobalGroupAggregate json serialization/deserialization

2021-03-15 Thread godfrey he (Jira)
godfrey he created FLINK-21791: -- Summary: Support StreamExecLocalGroupAggregate and StreamExecGlobalGroupAggregate json serialization/deserialization Key: FLINK-21791 URL: https://issues.apache.org/jira/browse/FLINK-