Task manger isn’t initiating with defined values in Flink 1.11 version as part of EMR 6.1.0

Hi Guys, I’m struggling while initiating the task manager with flink 1.11.0 in AWS EMR but with older versions it is not. Let me put the full context here. *When using Flink 1.9.1 and EMR 5.29.0* To create a long running session, we used the below command. *sudo flink-yarn-session -n -s -jm

[jira] [Created] (FLINK-20838) Implement SlotRequestAdapter for the FineGrainedSlotManager

Yangze Guo created FLINK-20838: -- Summary: Implement SlotRequestAdapter for the FineGrainedSlotManager Key: FLINK-20838 URL: https://issues.apache.org/jira/browse/FLINK-20838 Project: Flink

[jira] [Created] (FLINK-20837) Assign an increasing number larger than the numberOfSlot to dynamic slots

Yangze Guo created FLINK-20837: -- Summary: Assign an increasing number larger than the numberOfSlot to dynamic slots Key: FLINK-20837 URL: https://issues.apache.org/jira/browse/FLINK-20837 Project: Flink

[jira] [Created] (FLINK-20836) Register TaskManager with total and default slot resource profile in SlotManager

Yangze Guo created FLINK-20836: -- Summary: Register TaskManager with total and default slot resource profile in SlotManager Key: FLINK-20836 URL: https://issues.apache.org/jira/browse/FLINK-20836

[jira] [Created] (FLINK-20835) Implement FineGrainedSlotManager

Yangze Guo created FLINK-20835: -- Summary: Implement FineGrainedSlotManager Key: FLINK-20835 URL: https://issues.apache.org/jira/browse/FLINK-20835 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers

Wei Zhong created FLINK-20834: - Summary: Add metrics for reporting the memory usage and CPU usage of the Python UDF workers Key: FLINK-20834 URL: https://issues.apache.org/jira/browse/FLINK-20834

[jira] [Created] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

Zhenqiu Huang created FLINK-20833: - Summary: Expose pluggable interface for exception analysis and metrics reporting in Execution Graph Key: FLINK-20833 URL: https://issues.apache.org/jira/browse/FLINK-20833

Re: letter of application

Hi Welcome to the Flink community! There is no more specific contributor permission currently in Flink. You can simply create a JIRA ticket and ask to be assigned to start working. Please take a look at the Flink's contribution guidelines [1] [2] for more information. Best Regards, Yun Tang

letter of application

Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is Zsigner.

[jira] [Created] (FLINK-20832) flink.apache.org siete Typography exception

谢波 created FLINK-20832: -- Summary: flink.apache.org siete Typography exception Key: FLINK-20832 URL: https://issues.apache.org/jira/browse/FLINK-20832 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] Apache Flink Stateful Functions 2.2.2 released

@Gordon Thanks a lot for the release and for being the release manager. And thanks to everyone who made this release possible! Best, Xingbo Till Rohrmann 于2021年1月3日周日 下午8:31写道： > Great to hear! Thanks a lot to everyone who helped make this release > possible. > > Cheers, > Till > > On Sat, Jan

Re: [ANNOUNCE] Apache Flink Stateful Functions 2.2.2 released

Great to hear! Thanks a lot to everyone who helped make this release possible. Cheers, Till On Sat, Jan 2, 2021 at 3:37 AM Tzu-Li (Gordon) Tai wrote: > The Apache Flink community released the second bugfix release of the > Stateful Functions (StateFun) 2.2 series, version 2.2.2. > > *We

[jira] [Created] (FLINK-20831) Introduce the in memory topN buffer

Shengkai Fang created FLINK-20831: - Summary: Introduce the in memory topN buffer Key: FLINK-20831 URL: https://issues.apache.org/jira/browse/FLINK-20831 Project: Flink Issue Type: New