[jira] [Created] (FLINK-28126) Iteration gets stuck when replayable datastream and its downstream operator have different parallelism

Xuannan Su created FLINK-28126: -- Summary: Iteration gets stuck when replayable datastream and its downstream operator have different parallelism Key: FLINK-28126 URL:

[jira] [Created] (FLINK-28125) Promote leadership changing logs to INFO level

Xintong Song created FLINK-28125: Summary: Promote leadership changing logs to INFO level Key: FLINK-28125 URL: https://issues.apache.org/jira/browse/FLINK-28125 Project: Flink Issue Type:

Re: [DISCUSS] Releasing 1.15.1

Thanks for driving this release David! The plan for FLINK-28060 sounds good to me. I’ll also put my eyes on this issue then. +1 for resuming the release. Best regards, Qingsheng > On Jun 17, 2022, at 18:33, David Anderson wrote: > > After hitting pause on the 1.15.1 release a couple of days

[jira] [Created] (FLINK-28124) Flink on K8S in hosetNetwork mode, the CPU usage will spike

liuzhuo created FLINK-28124: --- Summary: Flink on K8S in hosetNetwork mode, the CPU usage will spike Key: FLINK-28124 URL: https://issues.apache.org/jira/browse/FLINK-28124 Project: Flink Issue

Re: [VOTE] FLIP-224: Blocklist Mechanism

+1(binding) Best, Yang Yun Gao 于2022年6月17日周五 18:03写道： > +1 (binding) > > Thanks for the discussion and updates! > > Best, > Yun Gao > > > -- > From:Peter Huang > Send Time:2022 Jun. 16 (Thu.) 00:05 > To:dev > Subject:Re: [VOTE]

[jira] [Created] (FLINK-28123) When a flink job is restarted, the metaspce size of the taskmanager does not decrease but keeps increasing. After several restarts, the flink job metaspce oom.

Zhuang Liu created FLINK-28123: --- Summary: When a flink job is restarted, the metaspce size of the taskmanager does not decrease but keeps increasing. After several restarts, the flink job metaspce oom. Key: FLINK-28123

[jira] [Created] (FLINK-28122) Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page

Chengkai Yang created FLINK-28122: - Summary: Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page Key: FLINK-28122 URL: https://issues.apache.org/jira/browse/FLINK-28122

[jira] [Created] (FLINK-28121) Translate in "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page

Chengkai Yang created FLINK-28121: - Summary: Translate in "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page Key: FLINK-28121 URL:

[jira] [Created] (FLINK-28120) Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]]

luoyuxia created FLINK-28120: Summary: Meet assert error: BatchPhysicalExchange.BATCH_PHYSICAL has lower cost then best cost of subset :RelSubset#15.BATCH_PHYSICAL.hash[0, 1]true.[]] Key: FLINK-28120 URL:

[jira] [Created] (FLINK-28119) Update the document for Contribute Documentation

Shuiqiang Chen created FLINK-28119: -- Summary: Update the document for Contribute Documentation Key: FLINK-28119 URL: https://issues.apache.org/jira/browse/FLINK-28119 Project: Flink Issue

Re: Re: [DISCUSS ] Make state.backend.incremental as true by default

Hey @Lihe Ma, Thanks and I appreciate your feedback! *What do I think of introducing a new state backend?* I am hesitant to follow this way of introducing a new state backend to implement `HashMapStateBackend with incremental checkpoint enabled`, because: - It causes more confusion for users:

Re: Permission to create a FLIP wiki page

Hi Hong, you should now have the access. Looking forward to your FLIP. Best regards, Jing On Sat, Jun 18, 2022 at 4:51 PM Teoh, Hong wrote: > Thank you! __ > > Hong > > On 18/06/2022, 15:11, "Jing Ge" wrote: > > CAUTION: This email originated from outside of the organization. Do > not

[jira] [Created] (FLINK-28118) Introduce TableStoreOptions to merge all options

Jingsong Lee created FLINK-28118: Summary: Introduce TableStoreOptions to merge all options Key: FLINK-28118 URL: https://issues.apache.org/jira/browse/FLINK-28118 Project: Flink Issue Type: