Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project

2025-06-02 Thread Sharath
+1(non-binding) On Mon, Jun 2, 2025 at 10:43 PM weijie guo wrote: > +1(binding) > > > Best regards, > > Weijie > > > pranav tiwari 于2025年6月3日周二 12:47写道: > > > Hi Xintong, > > > > Thank you for your response. > > > > I will continue following the thread. > > > > Flink is new to me, and I’ve been

[jira] [Created] (FLINK-37872) Autoscaler computes negative true processing rate

2025-05-29 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-37872: - Summary: Autoscaler computes negative true processing rate Key: FLINK-37872 URL: https://issues.apache.org/jira/browse/FLINK-37872 Project: Flink

Re: Proposal Flip-233: Donate GetInData HTTP Connector to Flink

2025-05-29 Thread Sharath
+1 (non-binding). I think this would be a great addition as well! On Thu, May 29, 2025 at 9:28 AM Tom Cooper wrote: > +1 (non-binding) from me! This seems like it would be a really useful > functionality to have within Flink. > > Can we get some official notice (email on this thread, Github > di

[jira] [Created] (FLINK-37798) Persist DelayedScaleDown info in state store

2025-05-13 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-37798: - Summary: Persist DelayedScaleDown info in state store Key: FLINK-37798 URL: https://issues.apache.org/jira/browse/FLINK-37798 Project: Flink Issue

Re: Long Initial Checkpoint Start Delay in PyFlink FlatMap Operator

2025-05-13 Thread Sharath
Hello, Have you tried enabling the buffer debloating feature to improve checkpoint times? Refer taskmanager.network.memory.buffer-debloat.enabled in https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/ Regards, Sharath On Tue, May 13, 2025 at 1:59 AM 张河川 wrote: >

[jira] [Created] (FLINK-37751) Add vertex name to autoscaler metrics

2025-04-29 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-37751: - Summary: Add vertex name to autoscaler metrics Key: FLINK-37751 URL: https://issues.apache.org/jira/browse/FLINK-37751 Project: Flink Issue Type

[jira] [Created] (FLINK-37528) Protobuf Format (proto3): Handle default values for optional primitive types and primitive types in one of fields

2025-03-27 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-37528: - Summary: Protobuf Format (proto3): Handle default values for optional primitive types and primitive types in one of fields Key: FLINK-37528 URL: https

Re: Flink Operator 1.11 release planning

2025-02-01 Thread Sharath
+1, Looking forward to the release! On Sat, Feb 1, 2025 at 6:50 PM Peter Huang wrote: > +1 from me. I can help with some release verification. > > On Sat, Feb 1, 2025 at 6:40 PM ConradJam wrote: > > > +1 > > > > Tom Cooper 于2025年1月31日周五 18:20写道: > > > > > +1 from me. Getting a release out with

[jira] [Created] (FLINK-37238) Flink Web UI does not take scaled parallelism into account when showing job graph

2025-01-29 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-37238: - Summary: Flink Web UI does not take scaled parallelism into account when showing job graph Key: FLINK-37238 URL: https://issues.apache.org/jira/browse/FLINK-37238

[jira] [Created] (FLINK-37018) Adaptive scheduler triggers multiple internal restarts for a single rescale event

2025-01-06 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-37018: - Summary: Adaptive scheduler triggers multiple internal restarts for a single rescale event Key: FLINK-37018 URL: https://issues.apache.org/jira/browse/FLINK-37018

[jira] [Created] (FLINK-36752) Emit state related metrics when checkpoints are disabled

2024-11-20 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-36752: - Summary: Emit state related metrics when checkpoints are disabled Key: FLINK-36752 URL: https://issues.apache.org/jira/browse/FLINK-36752 Project: Flink

[jira] [Created] (FLINK-36734) Potential issue in autoscaler algorithm

2024-11-16 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-36734: - Summary: Potential issue in autoscaler algorithm Key: FLINK-36734 URL: https://issues.apache.org/jira/browse/FLINK-36734 Project: Flink Issue Type

[jira] [Created] (FLINK-36712) Autoscaler should skip resource check when new parallelism/memory is lower than current

2024-11-13 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-36712: - Summary: Autoscaler should skip resource check when new parallelism/memory is lower than current Key: FLINK-36712 URL: https://issues.apache.org/jira/browse/FLINK-36712

[jira] [Created] (FLINK-36696) JDBC Autoscaler plugin should use DataSource and not connection

2024-11-12 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-36696: - Summary: JDBC Autoscaler plugin should use DataSource and not connection Key: FLINK-36696 URL: https://issues.apache.org/jira/browse/FLINK-36696 Project

[jira] [Created] (FLINK-36645) Gracefully handle null execution plan from autoscaler

2024-10-31 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-36645: - Summary: Gracefully handle null execution plan from autoscaler Key: FLINK-36645 URL: https://issues.apache.org/jira/browse/FLINK-36645 Project: Flink

[jira] [Created] (FLINK-36557) Stale Autoscaler Context in Kubernetes Operator

2024-10-16 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-36557: - Summary: Stale Autoscaler Context in Kubernetes Operator Key: FLINK-36557 URL: https://issues.apache.org/jira/browse/FLINK-36557 Project: Flink

[jira] [Created] (FLINK-36531) AutoScaler needs to consider the lag from last checkpoint

2024-10-14 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-36531: - Summary: AutoScaler needs to consider the lag from last checkpoint Key: FLINK-36531 URL: https://issues.apache.org/jira/browse/FLINK-36531 Project: Flink

[jira] [Created] (FLINK-36411) Allow configuring job vertex throughput limits for auto scaler

2024-09-30 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-36411: - Summary: Allow configuring job vertex throughput limits for auto scaler Key: FLINK-36411 URL: https://issues.apache.org/jira/browse/FLINK-36411 Project

[jira] [Created] (FLINK-34635) Clear successful records from the batch in JDBC connector

2024-03-09 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-34635: - Summary: Clear successful records from the batch in JDBC connector Key: FLINK-34635 URL: https://issues.apache.org/jira/browse/FLINK-34635 Project: Flink

Re: Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-09 Thread Sharath
+1 (non-binding) Best, Sharath On Tue, Jan 9, 2024 at 1:02 PM Venkata Sanath Muppalla wrote: > +1 (non-binding) > > Thanks, > Sanath > > On Tue, Jan 9, 2024 at 11:16 AM Peter Huang > wrote: > > > +1 (non-binding) > > > > > > Best Regards >

[jira] [Created] (FLINK-33817) Allow ReadDefaultValues = False for non primitive types on Proto3

2023-12-13 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-33817: - Summary: Allow ReadDefaultValues = False for non primitive types on Proto3 Key: FLINK-33817 URL: https://issues.apache.org/jira/browse/FLINK-33817 Project

[jira] [Created] (FLINK-33611) Add the ability to reuse variable names across different split method scopes

2023-11-21 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-33611: - Summary: Add the ability to reuse variable names across different split method scopes Key: FLINK-33611 URL: https://issues.apache.org/jira/browse/FLINK-33611

[jira] [Created] (FLINK-33458) Add env.java.opts.gateway option in flink-conf.yaml

2023-11-04 Thread Sharath Avadoot Gururaj (Jira)
Sharath Avadoot Gururaj created FLINK-33458: --- Summary: Add env.java.opts.gateway option in flink-conf.yaml Key: FLINK-33458 URL: https://issues.apache.org/jira/browse/FLINK-33458 Project