[jira] [Commented] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

[ https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817115#comment-17817115 ] Sai Sharath Dandi commented on FLINK-34403: --- Sorry, I couldn't get back here i

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-34635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-34635: -- Priority: Minor (was: Major) > Clear successful records from the batch in JDBC connec

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

[ https://issues.apache.org/jira/browse/FLINK-34635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-34635: -- Affects Version/s: 1.18.1 > Clear successful records from the batch in JDBC connector

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

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] [Updated] (FLINK-33611) Add the ability to reuse variable names across different split method scopes

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-33611: -- Description: h3. Background Flink serializes and deserializes protobuf format data by

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

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-33611: -- Description: h3. Background Flink serializes and deserializes protobuf format data by

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

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812045#comment-17812045 ] Sai Sharath Dandi commented on FLINK-33817: --- [~libenchao] [~maosuhan] , Gentle

[jira] [Commented] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

[ https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815422#comment-17815422 ] Sai Sharath Dandi commented on FLINK-34403: --- The test was added for an extreme

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

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] [Updated] (FLINK-33817) Allow ReadDefaultValues = False for non primitive types on Proto3

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-33817: -- Description: *Background*   The current Protobuf format [implementation|https://git

[jira] [Updated] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-33611: -- Summary: Support Large Protobuf Schemas (was: Add the ability to reuse variable names

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

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-33817: -- Description: *Background*   The current Protobuf format [implementation|https://git

[jira] [Commented] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799560#comment-17799560 ] Sai Sharath Dandi commented on FLINK-33611: --- [~libenchao] , The constant pool

[jira] [Comment Edited] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799560#comment-17799560 ] Sai Sharath Dandi edited comment on FLINK-33611 at 12/21/23 8:18 PM: -

[jira] [Commented] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799583#comment-17799583 ] Sai Sharath Dandi commented on FLINK-33611: --- Fwiw, I've run into this issue fo

[jira] [Comment Edited] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799560#comment-17799560 ] Sai Sharath Dandi edited comment on FLINK-33611 at 12/21/23 9:22 PM: -

[jira] [Comment Edited] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799560#comment-17799560 ] Sai Sharath Dandi edited comment on FLINK-33611 at 12/21/23 9:23 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-33817: -- Description: *Background*   The current Protobuf format [implementation|https://git

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

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799584#comment-17799584 ] Sai Sharath Dandi commented on FLINK-33817: --- [~libenchao] , Can you please tak

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

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799959#comment-17799959 ] Sai Sharath Dandi commented on FLINK-33817: --- Yes, it is supported for message

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

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799959#comment-17799959 ] Sai Sharath Dandi edited comment on FLINK-33817 at 12/22/23 10:07 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799959#comment-17799959 ] Sai Sharath Dandi edited comment on FLINK-33817 at 12/22/23 10:08 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799959#comment-17799959 ] Sai Sharath Dandi edited comment on FLINK-33817 at 12/22/23 10:08 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799959#comment-17799959 ] Sai Sharath Dandi edited comment on FLINK-33817 at 12/22/23 10:09 PM:

[jira] [Commented] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799963#comment-17799963 ] Sai Sharath Dandi commented on FLINK-33611: --- Yes, it is quite large indeed but

[jira] [Commented] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17802335#comment-17802335 ] Sai Sharath Dandi commented on FLINK-33611: --- [~libenchao] All identifier names

[jira] [Comment Edited] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17802335#comment-17802335 ] Sai Sharath Dandi edited comment on FLINK-33611 at 1/3/24 10:15 PM: --

[jira] [Commented] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803388#comment-17803388 ] Sai Sharath Dandi commented on FLINK-33611: --- @libenchao, Thanks for the sugges

[jira] [Comment Edited] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803388#comment-17803388 ] Sai Sharath Dandi edited comment on FLINK-33611 at 1/5/24 3:03 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-33817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803389#comment-17803389 ] Sai Sharath Dandi commented on FLINK-33817: --- [~maosuhan] Gentle ping on this.

[jira] [Commented] (FLINK-33611) Support Large Protobuf Schemas

[ https://issues.apache.org/jira/browse/FLINK-33611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804434#comment-17804434 ] Sai Sharath Dandi commented on FLINK-33611: --- [~libenchao] Thanks for the feedb

[jira] [Commented] (FLINK-9161) Support STRUCT syntax to create named STRUCT in SQL

[ https://issues.apache.org/jira/browse/FLINK-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677996#comment-17677996 ] Sai Sharath Dandi commented on FLINK-9161: -- Was able to get it working using a c

[jira] [Commented] (FLINK-9161) Support STRUCT syntax to create named STRUCT in SQL

[ https://issues.apache.org/jira/browse/FLINK-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17676305#comment-17676305 ] Sai Sharath Dandi commented on FLINK-9161: -- [~leonard] ROW does not support crea

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

[ https://issues.apache.org/jira/browse/FLINK-36531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889805#comment-17889805 ] Sai Sharath Dandi commented on FLINK-36531: --- Thanks [~heigebupahei] for sharin

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

[ https://issues.apache.org/jira/browse/FLINK-36557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891612#comment-17891612 ] Sai Sharath Dandi commented on FLINK-36557: --- Hi [~gyfora] , Could you please h

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

[ https://issues.apache.org/jira/browse/FLINK-36557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-36557: -- Description: The KubernetesJobAutoScalerContext is [cached|https://github.com/apache/

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

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 Iss

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

[ https://issues.apache.org/jira/browse/FLINK-36557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890258#comment-17890258 ] Sai Sharath Dandi commented on FLINK-36557: --- We're trying to build an autoscal

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

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] [Updated] (FLINK-36531) AutoScaler needs to consider the lag from last checkpoint

[ https://issues.apache.org/jira/browse/FLINK-36531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-36531: -- Description: Autoscaler computes the target processing capacity as [below|https://sg.

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

[ https://issues.apache.org/jira/browse/FLINK-36696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897797#comment-17897797 ] Sai Sharath Dandi commented on FLINK-36696: --- [~fanrui] Sure! Please assign the

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

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: Fl

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

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-36645) Gracefully handle null execution plan from autoscaler

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] [Commented] (FLINK-36409) Publish some autoscaler metrics during stabilisation period

[ https://issues.apache.org/jira/browse/FLINK-36409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17894700#comment-17894700 ] Sai Sharath Dandi commented on FLINK-36409: --- Hello [~morhidi] , are you workin

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

[ https://issues.apache.org/jira/browse/FLINK-36411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885995#comment-17885995 ] Sai Sharath Dandi commented on FLINK-36411: --- Throttling may happen only under

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

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: Fli

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

[ https://issues.apache.org/jira/browse/FLINK-36411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-36411: -- Description: *Problem Statement*   Currently, auto scaler has the ability to detect

[jira] [Commented] (FLINK-36409) Publish some autoscaler metrics during stabilisation period

[ https://issues.apache.org/jira/browse/FLINK-36409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886275#comment-17886275 ] Sai Sharath Dandi commented on FLINK-36409: --- +1, I would like to add on that c

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

[ https://issues.apache.org/jira/browse/FLINK-36531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889879#comment-17889879 ] Sai Sharath Dandi commented on FLINK-36531: --- [~heigebupahei] I have checked th

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

[ https://issues.apache.org/jira/browse/FLINK-36531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi closed FLINK-36531. - Resolution: Not A Problem > AutoScaler needs to consider the lag from last checkpoint >

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

[ https://issues.apache.org/jira/browse/FLINK-36531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889879#comment-17889879 ] Sai Sharath Dandi edited comment on FLINK-36531 at 10/16/24 12:11 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-36531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899228#comment-17899228 ] Sai Sharath Dandi edited comment on FLINK-36531 at 11/18/24 7:35 PM: -

[jira] [Commented] (FLINK-36409) Publish some autoscaler metrics during stabilisation period

[ https://issues.apache.org/jira/browse/FLINK-36409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899234#comment-17899234 ] Sai Sharath Dandi commented on FLINK-36409: --- Yes, Apologies for the delay. I w

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

[ https://issues.apache.org/jira/browse/FLINK-36531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899228#comment-17899228 ] Sai Sharath Dandi edited comment on FLINK-36531 at 11/18/24 7:16 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-36531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899192#comment-17899192 ] Sai Sharath Dandi commented on FLINK-36531: --- Hi [~mxm] , As [~heigebupahei]  m

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

[ https://issues.apache.org/jira/browse/FLINK-36531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899228#comment-17899228 ] Sai Sharath Dandi commented on FLINK-36531: --- My understanding is that FLIP-461

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

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] [Updated] (FLINK-36734) Potential issue in autoscaler algorithm

[ https://issues.apache.org/jira/browse/FLINK-36734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-36734: -- Description: Currently, the autoscaler algorithm tries to keep all the Job vertices at

[jira] [Updated] (FLINK-36734) Potential improvement to autoscaler algorithm

[ https://issues.apache.org/jira/browse/FLINK-36734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-36734: -- Description: Currently, the autoscaler algorithm tries to keep all the Job vertices at

[jira] [Updated] (FLINK-36734) Potential improvement to autoscaler algorithm

[ https://issues.apache.org/jira/browse/FLINK-36734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-36734: -- Summary: Potential improvement to autoscaler algorithm (was: Potential issue in autos

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

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] [Updated] (FLINK-36734) Potential improvement to autoscaler algorithm

[ https://issues.apache.org/jira/browse/FLINK-36734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-36734: -- Description: Currently, the autoscaler algorithm tries to keep all the Job vertices at

[jira] [Updated] (FLINK-36734) Potential improvement to autoscaler algorithm

[ https://issues.apache.org/jira/browse/FLINK-36734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-36734: -- Description: Currently, the autoscaler algorithm tries to keep all the Job vertices at

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

[ https://issues.apache.org/jira/browse/FLINK-36734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-36734: -- Description: Currently, the autoscaler algorithm tries to keep all the Job vertices at

[jira] [Commented] (FLINK-35529) protobuf-format compatible protobuf bad indentifier

[ https://issues.apache.org/jira/browse/FLINK-35529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910353#comment-17910353 ] Sai Sharath Dandi commented on FLINK-35529: --- Nice catch, +1 to the issue > pr

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

[ https://issues.apache.org/jira/browse/FLINK-37018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-37018: -- Affects Version/s: 1.18.0 > Adaptive scheduler triggers multiple internal restarts for

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

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] [Commented] (FLINK-36609) Protobuf Format not support proto3

[ https://issues.apache.org/jira/browse/FLINK-36609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910352#comment-17910352 ] Sai Sharath Dandi commented on FLINK-36609: --- [~loserwang1024] Why is the messa

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

[ https://issues.apache.org/jira/browse/FLINK-37018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-37018: -- Description: We observe that a single rescale event from autoscaler triggers multiple

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

[ https://issues.apache.org/jira/browse/FLINK-37018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910724#comment-17910724 ] Sai Sharath Dandi commented on FLINK-37018: --- Hi [~heigebupahei] , thanks a lot

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17922528#comment-17922528 ] Sai Sharath Dandi commented on FLINK-31655: --- Hello, may I know the current sta

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

[ https://issues.apache.org/jira/browse/FLINK-37018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi resolved FLINK-37018. --- Resolution: Duplicate > Adaptive scheduler triggers multiple internal restarts for a

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

[ https://issues.apache.org/jira/browse/FLINK-37238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-37238: -- Description: The Flink Web UI shows an incorrect relationship between job vertices by

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

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] [Updated] (FLINK-37528) Protobuf Format (proto3): Handle default values for optional primitive types and primitive types in one of fields

[ https://issues.apache.org/jira/browse/FLINK-37528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-37528: -- Description: The Read Default Values is [forced|https://github.com/apache/flink/blob/

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

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://issues.apache.o

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

[ https://issues.apache.org/jira/browse/FLINK-37751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17948268#comment-17948268 ] Sai Sharath Dandi commented on FLINK-37751: --- Hi [~fanrui] , Could you please r

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

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: I

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

[ https://issues.apache.org/jira/browse/FLINK-37751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sai Sharath Dandi updated FLINK-37751: -- Priority: Minor (was: Major) > Add vertex name to autoscaler metrics > --

[jira] [Commented] (FLINK-31880) Bad Test in OrcColumnarRowSplitReaderTest

[ https://issues.apache.org/jira/browse/FLINK-31880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928603#comment-17928603 ] Sai Sharath Dandi commented on FLINK-31880: --- +1 to this. [~kurto] May I know w

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

[ https://issues.apache.org/jira/browse/FLINK-37528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937228#comment-17937228 ] Sai Sharath Dandi commented on FLINK-37528: --- [~libenchao] Could you please rev

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

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

[jira] [Commented] (FLINK-36609) Protobuf Format not support proto3

[ https://issues.apache.org/jira/browse/FLINK-36609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17986477#comment-17986477 ] Sai Sharath Dandi commented on FLINK-36609: --- Hi Hongshun, Thanks for the resp

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

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 I

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

[ https://issues.apache.org/jira/browse/FLINK-37872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955310#comment-17955310 ] Sai Sharath Dandi commented on FLINK-37872: --- Hi [~gyfora] , Could you please r

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

[ https://issues.apache.org/jira/browse/FLINK-36557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17995714#comment-17995714 ] Sai Sharath Dandi commented on FLINK-36557: --- 😊 Sharath reacted via Gmail