[jira] [Created] (FLINK-21298) Update user documentation of modules

Jane Chan created FLINK-21298: - Summary: Update user documentation of modules Key: FLINK-21298 URL: https://issues.apache.org/jira/browse/FLINK-21298 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21292) Python StreamRowBasedOperationITTests fails on azure

Dawid Wysakowicz created FLINK-21292: Summary: Python StreamRowBasedOperationITTests fails on azure Key: FLINK-21292 URL: https://issues.apache.org/jira/browse/FLINK-21292 Project: Flink

[jira] [Created] (FLINK-21294) Support state access API for the map operation of Python ConnectedStreams

Wei Zhong created FLINK-21294: - Summary: Support state access API for the map operation of Python ConnectedStreams Key: FLINK-21294 URL: https://issues.apache.org/jira/browse/FLINK-21294 Project: Flink

[jira] [Created] (FLINK-21293) Support 'LOAD/UNLOAD MODULE', 'USE MODULES', and 'SHOW [FULL] MODULES' syntax

Jane Chan created FLINK-21293: - Summary: Support 'LOAD/UNLOAD MODULE', 'USE MODULES', and 'SHOW [FULL] MODULES' syntax Key: FLINK-21293 URL: https://issues.apache.org/jira/browse/FLINK-21293 Project: Flin

Flink 1.11.4 release? And usual plan for maintenance etc

Hey everyone, a few short questions please - is there an expected release date/target for 1.11.4 please? I ask as I've noticed a couple of dependency upgrades that I'd really like to pick up if possible, instead of moving to Flink 1.12 or 1.13 due to the existing Flink jobs we have. My second qu

[jira] [Created] (FLINK-21295) Support 'LOAD/UNLOAD MODULE', 'USE MODULES', and 'SHOW [FULL] MODULES' syntax

Jane Chan created FLINK-21295: - Summary: Support 'LOAD/UNLOAD MODULE', 'USE MODULES', and 'SHOW [FULL] MODULES' syntax Key: FLINK-21295 URL: https://issues.apache.org/jira/browse/FLINK-21295 Project: Flin

[jira] [Created] (FLINK-21296) Support changing the resolution order of modules in a flexible manner

Jane Chan created FLINK-21296: - Summary: Support changing the resolution order of modules in a flexible manner Key: FLINK-21296 URL: https://issues.apache.org/jira/browse/FLINK-21296 Project: Flink

[jira] [Created] (FLINK-21300) Support 'SHOW [FULL] MODULES' syntax

Jane Chan created FLINK-21300: - Summary: Support 'SHOW [FULL] MODULES' syntax Key: FLINK-21300 URL: https://issues.apache.org/jira/browse/FLINK-21300 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21299) Support 'USE MODULES' syntax

Jane Chan created FLINK-21299: - Summary: Support 'USE MODULES' syntax Key: FLINK-21299 URL: https://issues.apache.org/jira/browse/FLINK-21299 Project: Flink Issue Type: Sub-task Compone

[jira] [Created] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

Andy created FLINK-21301: Summary: Decouple window aggregate allow lateness with state ttl configuration Key: FLINK-21301 URL: https://issues.apache.org/jira/browse/FLINK-21301 Project: Flink Issue

[jira] [Created] (FLINK-21297) Simplify the module discovery mapping by module name

Jane Chan created FLINK-21297: - Summary: Simplify the module discovery mapping by module name Key: FLINK-21297 URL: https://issues.apache.org/jira/browse/FLINK-21297 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-21302) Fix NPE when use row_number() in over agg

Andy created FLINK-21302: Summary: Fix NPE when use row_number() in over agg Key: FLINK-21302 URL: https://issues.apache.org/jira/browse/FLINK-21302 Project: Flink Issue Type: New Feature C

[DISCUSS] Releasing Apache Flink 1.12.2

Hey devs, One of the major issues that have not been resolved in Apache Flink 1.12.1 is "unaligned checkpoint recovery may lead to corrupted data stream"[1]. Since the problem is now fixed and it is critical to the users, I would like to kick off a discussion on releasing Flink 1.12.2 that include

[jira] [Created] (FLINK-21303) Maybe remove LogicalSlot#getPhysicalSlotNumber

Chesnay Schepler created FLINK-21303: Summary: Maybe remove LogicalSlot#getPhysicalSlotNumber Key: FLINK-21303 URL: https://issues.apache.org/jira/browse/FLINK-21303 Project: Flink Issue

??????[DISCUSS] Releasing Apache Flink 1.12.2

Hi Yuan, I am a Firefox user and I just fixed a long lasting bug https://github.com/apache/flink/pull/14848 , wish this would be merged in this release. Best wishes --  -- ??:

[jira] [Created] (FLINK-21304) Support split distinct aggregate for window TVF based aggregate

Jark Wu created FLINK-21304: --- Summary: Support split distinct aggregate for window TVF based aggregate Key: FLINK-21304 URL: https://issues.apache.org/jira/browse/FLINK-21304 Project: Flink Issue

[jira] [Created] (FLINK-21305) Cumulative window should accumulate late events belonging to the cleaned slice

Jark Wu created FLINK-21305: --- Summary: Cumulative window should accumulate late events belonging to the cleaned slice Key: FLINK-21305 URL: https://issues.apache.org/jira/browse/FLINK-21305 Project: Flink

Re: Is development in FlinkML still active?

Hi Badrul, I think this ticket is a part of the effort of contributing Alink[1] into Flink as its ML library. The ticket became dormant for some time mainly due to the bandwidth of the contributor and reviewer. I'd imagine that Xu would like to resume the ticket some time soon. cc Xu. Thanks, J

Re: [DISCUSS]FLIP-163: SQL Client Improvements

Hi Jark, thanks for the summary. I hope we can also find a good long-term solution on the async/sync execution behavior topic. It should be discussed in a bigger round because it is (similar to the time function discussion) related to batch-streaming unification where we should stick to the

[jira] [Created] (FLINK-21306) FlinkSecurityManager might avoid fatal system exits

Robert Metzger created FLINK-21306: -- Summary: FlinkSecurityManager might avoid fatal system exits Key: FLINK-21306 URL: https://issues.apache.org/jira/browse/FLINK-21306 Project: Flink Issue

[jira] [Created] (FLINK-21307) Revisit activation model of FlinkSecurityManager

Robert Metzger created FLINK-21307: -- Summary: Revisit activation model of FlinkSecurityManager Key: FLINK-21307 URL: https://issues.apache.org/jira/browse/FLINK-21307 Project: Flink Issue Ty

[DISCUSS] FLIP-164: Improve Schema Handling in Catalogs

Hi everyone, you might have seen that we discussed a better schema API in past as part of FLIP-129 and FLIP-136. We also discussed this topic during different releases: https://issues.apache.org/jira/browse/FLINK-17793 Jark and I had an offline discussion how we can finally fix this shortco

Re: [DISCUSS] Releasing Apache Flink 1.12.2

Hi, Thanks Yuan for bringing up this topic. +1 for the quick 1.12.2 release. As Yuan mentioned, me and Roman can help whenever committer rights will be required. > I am a Firefox user and I just fixed a long lasting bug https://github.com/apache/flink/pull/14848 , wish this would be merged in t

[jira] [Created] (FLINK-21308) Cancel "sendAfter"

Stephan Pelikan created FLINK-21308: --- Summary: Cancel "sendAfter" Key: FLINK-21308 URL: https://issues.apache.org/jira/browse/FLINK-21308 Project: Flink Issue Type: New Feature Co

Re: [DISCUSS] Releasing Apache Flink 1.12.2

Thanks for volunteering for being our release manager Yuan :-) +1 for a timely bug fix release. I will try to review the PR for FLINK- 20417 [1] which is a good fix to include in the next bug fix release. We don't have to block the release on this fix though. [1] https://issues.apache.org/jira/b

Re: Flink 1.11.4 release? And usual plan for maintenance etc

Hi Adam, Currently there are no concrete plans for the 1.11.4 release. Usually the community creates a new release after enough fixes have been merged or if there is enough demand for it. We have indeed accumulated 35 fixes for 1.11.4 already which could justify a new release. Which fixes do you n

Re: [DISCUSS] Releasing Apache Flink 1.12.2

Thanks for being our release manager Yuan. We found a out of memory issue [1] which will affect most batch jobs thus I think it would be great if we can include this fix in 1.12.2. [1] https://issues.apache.org/jira/browse/FLINK-20663 Best, Kurt On Sat, Feb 6, 2021 at 12:36 AM Till Rohrmann w

[jira] [Created] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

jiguodai created FLINK-21309: Summary: Metrics of JobManager and TaskManager overwrite each other in pushgateway Key: FLINK-21309 URL: https://issues.apache.org/jira/browse/FLINK-21309 Project: Flink

First development steps, broken build workarounds?

Hi All, How do you start a fresh ticket in the flink repo for you guys' workflows? Master doesn't seem to build `mvn clean package` after trying a few different commits and a few tweaks to fork settings. Is there maybe some workaround part of the development setup? Maybe it's just windows linu

Re: [DISCUSS] Releasing Apache Flink 1.12.2

+1 for releasing 1.12.2, and thanks for volunteering to be our release manager Yuan. Besides the mentioned issues, I could see two more blockers with 1.12.2 as fix version [1] and need some tracking: * FLINK-21013 Blink planner does not ingest ti