[jira] [Created] (FLINK-21731) Add a benchmark for DefaultScheduler#startScheduling

2021-03-10 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-21731: Summary: Add a benchmark for DefaultScheduler#startScheduling Key: FLINK-21731 URL: https://issues.apache.org/jira/browse/FLINK-21731 Project: Flink Issue Ty

Re: [DISCUSS] FLIP-154: SQL Implicit Type Coercion

2021-03-10 Thread Danny Chan
Thanks for the feedback, Jingsong ~ This design mainly follows the behaviors of PostgreSQL and SQL-SERVER, because their rules are more in line with the SQL standard. I have fixed the WIKI and add more details about the diff in it. Best, Danny Chan Jingsong Li 于2021年3月11日周四 下午1:34写道: > Thanks

[jira] [Created] (FLINK-21730) Introduce ExecNodeTranslator

2021-03-10 Thread godfrey he (Jira)
godfrey he created FLINK-21730: -- Summary: Introduce ExecNodeTranslator Key: FLINK-21730 URL: https://issues.apache.org/jira/browse/FLINK-21730 Project: Flink Issue Type: Sub-task Compo

Re: Upgrade calcite version

2021-03-10 Thread Danny Chan
Hi Sheng ~ It is a hard work to upgrade Calcite version because that means you need to: - Fix all the bug introduced by the new planner - Fix all the logical plan to have correct semantics - Replace the deprecate APIs to new In order to achieve this, you need to have good knowledge of Calcite ba

[jira] [Created] (FLINK-21729) SimpleRecoveryFailureRateStrategyITBase fail

2021-03-10 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21729: - Summary: SimpleRecoveryFailureRateStrategyITBase fail Key: FLINK-21729 URL: https://issues.apache.org/jira/browse/FLINK-21729 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21728) DegreesWithExceptionITCase crash

2021-03-10 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21728: - Summary: DegreesWithExceptionITCase crash Key: FLINK-21728 URL: https://issues.apache.org/jira/browse/FLINK-21728 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-21727) Support DDL in HiveParser

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

Re: [DISCUSS] FLIP-154: SQL Implicit Type Coercion

2021-03-10 Thread Jingsong Li
Thanks Danny for starting this discussion. Big +1 for Implicit Type Coercion, in my opinion, it is very useful for writing SQL conveniently. I think there are two orthogonal things to discuss here: 1.[Matrix] Which types and which types can be implicitly converted. 2.[Strategies] In different cas

[jira] [Created] (FLINK-21726) Fix checkpoint stuck

2021-03-10 Thread fanrui (Jira)
fanrui created FLINK-21726: -- Summary: Fix checkpoint stuck Key: FLINK-21726 URL: https://issues.apache.org/jira/browse/FLINK-21726 Project: Flink Issue Type: Bug Components: Runtime / Stat

[jira] [Created] (FLINK-21725) DataTypeExtractor extracts wrong fields ordering for Tuple12

2021-03-10 Thread Jark Wu (Jira)
Jark Wu created FLINK-21725: --- Summary: DataTypeExtractor extracts wrong fields ordering for Tuple12 Key: FLINK-21725 URL: https://issues.apache.org/jira/browse/FLINK-21725 Project: Flink Issue Typ

[jira] [Created] (FLINK-21724) Remove type annotation from python message.as_type

2021-03-10 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-21724: Summary: Remove type annotation from python message.as_type Key: FLINK-21724 URL: https://issues.apache.org/jira/browse/FLINK-21724 Project: Flink Issue Type

[jira] [Created] (FLINK-21723) Hadoop integration link is broken on download page

2021-03-10 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-21723: - Summary: Hadoop integration link is broken on download page Key: FLINK-21723 URL: https://issues.apache.org/jira/browse/FLINK-21723 Project: Flink Issue Ty

[jira] [Created] (FLINK-21722) Wrong class name used in 'Generating Watermarks' documentation page for the Scala examples

2021-03-10 Thread Thelgis Kotsos (Jira)
Thelgis Kotsos created FLINK-21722: -- Summary: Wrong class name used in 'Generating Watermarks' documentation page for the Scala examples Key: FLINK-21722 URL: https://issues.apache.org/jira/browse/FLINK-21722

[jira] [Created] (FLINK-21721) Add a generic egress message builder to the SDK

2021-03-10 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-21721: Summary: Add a generic egress message builder to the SDK Key: FLINK-21721 URL: https://issues.apache.org/jira/browse/FLINK-21721 Project: Flink Issue Type: T

[jira] [Created] (FLINK-21720) Rework Documentation Style Guide for the new build system

2021-03-10 Thread Marta Paes Moreira (Jira)
Marta Paes Moreira created FLINK-21720: -- Summary: Rework Documentation Style Guide for the new build system Key: FLINK-21720 URL: https://issues.apache.org/jira/browse/FLINK-21720 Project: Flink

Re: [DISCUSS] Support registering custom JobStatusListeners when scheduling a job

2021-03-10 Thread Till Rohrmann
Hi Wenhao, Aljoscha might not be as responsive as before. Surely you can create a POC to evaluate different approaches. But the outcome should be a design which we discuss before starting to implement the code properly. At the moment the community might be a bit busy with the upcoming feature free

[jira] [Created] (FLINK-21719) Update statefun developer docs for new protocol

2021-03-10 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-21719: Summary: Update statefun developer docs for new protocol Key: FLINK-21719 URL: https://issues.apache.org/jira/browse/FLINK-21719 Project: Flink Issue Type: I

Re: [DISCUSS] Support registering custom JobStatusListeners when scheduling a job

2021-03-10 Thread Wenhao Ji
Hi Till. Indeed, there is no proper solution now other than the polling method. It is painful to have such code in our platform since it consumes a lot of resources to keep the polling run periodically when there are hundreds of Flink clusters to maintain. A lot of pollings are actually useless as

[jira] [Created] (FLINK-21718) FineGrainedSlotManagerTest.testNotificationAboutNotEnoughResources fails

2021-03-10 Thread Matthias (Jira)
Matthias created FLINK-21718: Summary: FineGrainedSlotManagerTest.testNotificationAboutNotEnoughResources fails Key: FLINK-21718 URL: https://issues.apache.org/jira/browse/FLINK-21718 Project: Flink

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

2021-03-10 Thread Stephan Ewen
Thanks for the positive feedback. Will convert this to a pull request then in the next days. Still looking to beautify the Feature Radar graphic a bit. Best, Stephan On Wed, Mar 10, 2021 at 8:26 AM Dawid Wysakowicz wrote: > Thank you Stephan for working on this. It's really nice to see the >

[jira] [Created] (FLINK-21717) Links to Java/Python docs are Broken

2021-03-10 Thread Jane Chan (Jira)
Jane Chan created FLINK-21717: - Summary: Links to Java/Python docs are Broken Key: FLINK-21717 URL: https://issues.apache.org/jira/browse/FLINK-21717 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-21716)  Support higher precision for Data Type TIME(p)

2021-03-10 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-21716: -- Summary:  Support higher precision for Data Type TIME(p) Key: FLINK-21716 URL: https://issues.apache.org/jira/browse/FLINK-21716 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-21715) Introduce more conversion classes for LocalZonedTimestampType(TIMESTAMP_LTZ)

2021-03-10 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-21715: -- Summary: Introduce more conversion classes for LocalZonedTimestampType(TIMESTAMP_LTZ) Key: FLINK-21715 URL: https://issues.apache.org/jira/browse/FLINK-21715 Project: Fli

[jira] [Created] (FLINK-21714) Use TIMESTAMP_LTZ as return type for function PROCTIME()

2021-03-10 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-21714: -- Summary: Use TIMESTAMP_LTZ as return type for function PROCTIME() Key: FLINK-21714 URL: https://issues.apache.org/jira/browse/FLINK-21714 Project: Flink Issue Ty

[jira] [Created] (FLINK-21713) Correct function CURRENT_TIMESTAMP/CURRENT_TIME/CURRENT_DATE/NOW/LOCALTIME/LOCALTIMESTAMP

2021-03-10 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-21713: -- Summary: Correct function CURRENT_TIMESTAMP/CURRENT_TIME/CURRENT_DATE/NOW/LOCALTIME/LOCALTIMESTAMP Key: FLINK-21713 URL: https://issues.apache.org/jira/browse/FLINK-21713

Re: [ANNOUNCE] Apache Flink 1.12.2 released

2021-03-10 Thread Etienne Chauchot
Thanks Roman and Yuan for the great job ! Regards, Etienne On 05/03/2021 10:40, Roman Khachatryan wrote: The Apache Flink community is very happy to announce the release of Apache Flink 1.12.2, which is the second bugfix release for the Apache Flink 1.12 series. Apache Flink® is an open-source

[jira] [Created] (FLINK-21712) Extract interfaces for the Execution* (classes used by the DefaultExecutonGraph)

2021-03-10 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-21712: -- Summary: Extract interfaces for the Execution* (classes used by the DefaultExecutonGraph) Key: FLINK-21712 URL: https://issues.apache.org/jira/browse/FLINK-21712

[jira] [Created] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

2021-03-10 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-21711: -- Summary: DataStreamSink doesn't allow setting maxParallelism Key: FLINK-21711 URL: https://issues.apache.org/jira/browse/FLINK-21711 Project: Flink Issue

[jira] [Created] (FLINK-21710) FlinkRelMdUniqueKeys get incorrect result on TableScan after project push-down

2021-03-10 Thread godfrey he (Jira)
godfrey he created FLINK-21710: -- Summary: FlinkRelMdUniqueKeys get incorrect result on TableScan after project push-down Key: FLINK-21710 URL: https://issues.apache.org/jira/browse/FLINK-21710 Project: F

Re: [DISCUSS] Deprecation and removal of the legacy SQL planner

2021-03-10 Thread Timo Walther
Thanks for the feedback everyone. You can track the progress of these efforts in: https://issues.apache.org/jira/browse/FLINK-21709 and https://issues.apache.org/jira/browse/FLINK-14437 Regards, Timo On 04.03.21 16:08, Jark Wu wrote: big +1 from my side. Best, Jark On Thu, 4 Mar 2021 at

[jira] [Created] (FLINK-21709) Officially deprecate the legacy planner

2021-03-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-21709: Summary: Officially deprecate the legacy planner Key: FLINK-21709 URL: https://issues.apache.org/jira/browse/FLINK-21709 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21708) CloserCleaner warning

2021-03-10 Thread Avi Levi (Jira)
Avi Levi created FLINK-21708: Summary: CloserCleaner warning Key: FLINK-21708 URL: https://issues.apache.org/jira/browse/FLINK-21708 Project: Flink Issue Type: Bug Reporter: Avi Levi