[jira] [Created] (FLINK-32137) Flame graph is hard to use with many task managers

Vladimir Matveev created FLINK-32137: Summary: Flame graph is hard to use with many task managers Key: FLINK-32137 URL: https://issues.apache.org/jira/browse/FLINK-32137 Project: Flink Is

Re: [jira] [Created] (FLINK-32130) previous checkpoint will be broke by the subsequent incremental checkpoint

How to unsubscribe? On Fri, May 19, 2023 at 8:13 AM Feifan Wang (Jira) wrote: > Feifan Wang created FLINK-32130: > --- > > Summary: previous checkpoint will be broke by the subsequent > incremental checkpoint > Key: FLINK-32130 >

Re: Job stuck in CREATED state with scheduling failures

How to unsubscribe from mailing list ? On Thu, May 18, 2023 at 1:03 AM Gyula Fóra wrote: > Hey Devs! > > I am bumping this thread to see if someone has any ideas how to go about > solving this. > > Yang Wang earlier had this comment but I am not sure how to proceed: > > "From the logs you have p

[jira] [Created] (FLINK-32136) Pyflink gateway server launch fails when purelib != platlib

William Ashley created FLINK-32136: -- Summary: Pyflink gateway server launch fails when purelib != platlib Key: FLINK-32136 URL: https://issues.apache.org/jira/browse/FLINK-32136 Project: Flink

[jira] [Created] (FLINK-32135) FRocksDB fix log file create failed caused by file name too long

Feifan Wang created FLINK-32135: --- Summary: FRocksDB fix log file create failed caused by file name too long Key: FLINK-32135 URL: https://issues.apache.org/jira/browse/FLINK-32135 Project: Flink

Re: [DISCUSS] FLIP-229: Prometheus Sink Connector

Hi LijieThank you for pointing this out. I've corrected it [1]. Also, this page [2] still shows 178 and 229 as available, which is why I picked it up.ThanksKarthi[1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-312%3A+Prometheus+Sink+Connector[2]  https://cwiki.apache.org/confluence/dis

[jira] [Created] (FLINK-32134) Autoscaler min/max parallelism configs should respect the current job parallelism

Gyula Fora created FLINK-32134: -- Summary: Autoscaler min/max parallelism configs should respect the current job parallelism Key: FLINK-32134 URL: https://issues.apache.org/jira/browse/FLINK-32134 Project

[jira] [Created] (FLINK-32133) Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers

Liu created FLINK-32133: --- Summary: Batch requests and remove requests in the end to reduce YarnResourceManager's excess containers Key: FLINK-32133 URL: https://issues.apache.org/jira/browse/FLINK-32133 Project

Re: [DISCUSS] Release Flink 1.17.1

Hi Weijie, Thanks for your effort and sharing the status! Best regards, Jing On Fri, May 19, 2023 at 11:50 AM weijie guo wrote: > Hi Jing, > > Thank you for your attention! > > I have cut off the code for release-1.17.1-rc1 and started deploying it to > the apache repository, while preparing t

Re: Call for help on the Web UI (In-Place Rescaling)

Hi David, Thanks for driving this. I'd like to second Emre, especially the second suggestion. In practice, the parallelism number could be big. Users will be frustrated, if they have to click hundred or even more times in order to reach the wished number. Anyone who will take over the design task,

RE: Call for help on the Web UI (In-Place Rescaling)

Hi David, This looks awesome. I am no expert on UI/UX, but still have opinions 😊 I normally use the Overview tab for monitoring Flink jobs, and having control inputs there breaks my assumption that Overview is “read-only” and for “watching”. Having said that for “educational purposes” that migh

[jira] [Created] (FLINK-32132) Cast function CODEGEN does not work as expected when nullOnFailure enabled

xiaogang zhou created FLINK-32132: - Summary: Cast function CODEGEN does not work as expected when nullOnFailure enabled Key: FLINK-32132 URL: https://issues.apache.org/jira/browse/FLINK-32132 Project:

Re: [DISCUSS] Release Flink 1.17.1

Hi Jing, Thank you for your attention! I have cut off the code for release-1.17.1-rc1 and started deploying it to the apache repository, while preparing the pull request for the blog post. The specific released time depends on the speed at which they are completed. VOTE thread will be launched no

Re: [VOTE] Release 1.16.2, release candidate #1

+1 (non-binding) - Verified signature - Verified hashes - Build form source with mac - Verify that the source archives do not contain any binaries - Run streaming and batch job in sql-client successfully. Thanks weijie for driving this release candidate. Best, Yuxin weijie guo 于2023年5月19日周五 1

Re: [DISCUSS] FLIP-287: Extend Sink#InitContext to expose ExecutionConfig and JobID

Updated the FLIP to use this option.

[VOTE] Release 1.16.2, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.16.2, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes

Re: [DISCUSS] FLIP-229: Prometheus Sink Connector

Hi Karthi Thanks for the proposal. I personally like the idea of having a specific prometheus sink vs using metrics reporters. I think this is a clear boundary between monitoring the job metrics and treating metrics as data payloads. Additionally we would benefit of AsyncSink framework :D. I would