[jira] [Updated] (FLINK-33879) Hybrid Shuffle may hang during redistribution

2023-12-20 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-33879: -- Description: Currently, the Hybrid Shuffle can work with Memory Tier and Disk Tier together, however,

[jira] [Updated] (FLINK-33879) Hybrid Shuffle may hang during redistribution

2023-12-20 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-33879: -- Description: Currently, the Hybrid Shuffle can work with Memory Tier and Disk Tier together. Image

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-20 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1432535390 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -334,7 +334,9 @@ public void onUnknownDeploymentsOf(

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-20 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1432535390 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -334,7 +334,9 @@ public void onUnknownDeploymentsOf(

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

2023-12-20 Thread via GitHub
flashJd commented on PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#issuecomment-1864238511 @gyfora @mxm by the way, I'd like to discuss the logic of scaling effectiveness evaluation with you. 1. Now it's controlled by two config

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-20 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1432535390 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -334,7 +334,9 @@ public void onUnknownDeploymentsOf(

Re: [PR] [FLINK-33823] Make PlannerQueryOperation SQL serializable [flink]

2023-12-20 Thread via GitHub
dawidwys commented on code in PR #23948: URL: https://github.com/apache/flink/pull/23948#discussion_r1432520652 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala: ## @@ -1646,6 +1650,28 @@ object TableTestUtil {

[jira] [Created] (FLINK-33898) Allow triggering unaligned checkpoint via REST api

2023-12-20 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-33898: --- Summary: Allow triggering unaligned checkpoint via REST api Key: FLINK-33898 URL: https://issues.apache.org/jira/browse/FLINK-33898 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-33897) Allow triggering unaligned checkpoint via CLI

2023-12-20 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-33897: --- Assignee: Zakelly Lan > Allow triggering unaligned checkpoint via CLI >

[jira] [Created] (FLINK-33897) Allow triggering unaligned checkpoint via CLI

2023-12-20 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-33897: --- Summary: Allow triggering unaligned checkpoint via CLI Key: FLINK-33897 URL: https://issues.apache.org/jira/browse/FLINK-33897 Project: Flink Issue Type:

Re: [PR] [FLINK-33863][checkpoint] Fix restoring compressed operator state [flink]

2023-12-20 Thread via GitHub
fredia merged PR #23938: URL: https://github.com/apache/flink/pull/23938 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-33823] Make PlannerQueryOperation SQL serializable [flink]

2023-12-20 Thread via GitHub
twalthr commented on code in PR #23948: URL: https://github.com/apache/flink/pull/23948#discussion_r1432489408 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/PlannerQueryOperation.java: ## @@ -72,6 +77,15 @@ public String

Re: [PR] [FLINK-33632] Adding custom flink mutator [flink-kubernetes-operator]

2023-12-20 Thread via GitHub
tagarr commented on PR #733: URL: https://github.com/apache/flink-kubernetes-operator/pull/733#issuecomment-1864167599 @gyfora We had considered adding mutation into the controller loop in the same manner that the validator is done, but we believe that mutation of the CR should only

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-20 Thread via GitHub
KarmaGYZ commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1432482972 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java: ## @@ -118,26 +129,47 @@ public

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-20 Thread via GitHub
KarmaGYZ commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1432481088 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -334,7 +334,9 @@ public void onUnknownDeploymentsOf(

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

2023-12-20 Thread via GitHub
flashJd commented on code in PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1432470030 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java: ## @@ -147,7 +149,13 @@ public CollectedMetricHistory

[jira] [Created] (FLINK-33896) Implement restore tests for Correlate node

2023-12-20 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-33896: - Summary: Implement restore tests for Correlate node Key: FLINK-33896 URL: https://issues.apache.org/jira/browse/FLINK-33896 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33894) Implement restore tests for PythonGroupAggregate node

2023-12-20 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-33894: - Summary: Implement restore tests for PythonGroupAggregate node Key: FLINK-33894 URL: https://issues.apache.org/jira/browse/FLINK-33894 Project: Flink Issue Type:

[jira] [Created] (FLINK-33895) Implement restore tests for PythonGroupWindowAggregate node

2023-12-20 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-33895: - Summary: Implement restore tests for PythonGroupWindowAggregate node Key: FLINK-33895 URL: https://issues.apache.org/jira/browse/FLINK-33895 Project: Flink Issue

[jira] [Created] (FLINK-33893) Implement restore tests for PythonCorrelate node

2023-12-20 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-33893: - Summary: Implement restore tests for PythonCorrelate node Key: FLINK-33893 URL: https://issues.apache.org/jira/browse/FLINK-33893 Project: Flink Issue Type:

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core package api-common [flink]

2023-12-20 Thread via GitHub
Jiabao-Sun commented on code in PR #23960: URL: https://github.com/apache/flink/pull/23960#discussion_r1432450266 ## flink-core/src/test/java/org/apache/flink/api/common/accumulators/AverageAccumulatorTest.java: ## @@ -94,19 +94,19 @@ public void testMergeSuccess() { }

Re: [PR] [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core [flink]

2023-12-20 Thread via GitHub
GOODBOY008 closed pull request #19563: [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core URL: https://github.com/apache/flink/pull/19563 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-33783) Add options to ignore parsing error in Kafka SQL Connector

2023-12-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798878#comment-17798878 ] Martijn Visser commented on FLINK-33783: No worries [~bartoszdeepbi] We shouldn't open up a PR

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core package api-common [flink]

2023-12-20 Thread via GitHub
GOODBOY008 commented on PR #23960: URL: https://github.com/apache/flink/pull/23960#issuecomment-1864104413 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Commented] (FLINK-33783) Add options to ignore parsing error in Kafka SQL Connector

2023-12-20 Thread Bartosz Mikulski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798873#comment-17798873 ] Bartosz Mikulski commented on FLINK-33783: -- Hi [~martijnvisser]! Sorry for the delayed

[jira] [Comment Edited] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility

2023-12-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798856#comment-17798856 ] RocMarshal edited comment on FLINK-29050 at 12/20/23 8:08 AM: -- Based on

[jira] [Comment Edited] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility

2023-12-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798856#comment-17798856 ] RocMarshal edited comment on FLINK-29050 at 12/20/23 8:07 AM: -- Based on

[jira] [Commented] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility

2023-12-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798856#comment-17798856 ] RocMarshal commented on FLINK-29050: Based on

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core package api-common [flink]

2023-12-20 Thread via GitHub
flinkbot commented on PR #23960: URL: https://github.com/apache/flink/pull/23960#issuecomment-1864026986 ## CI report: * f5a54bc7ae7fd532f00d043ecad6e998de786695 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

<    1   2   3