[jira] [Comment Edited] (FLINK-30773) Add API for rescaling of jobs based on per-vertex parallelism overrides

[ https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717449#comment-17717449 ] Liu edited comment on FLINK-30773 at 4/28/23 6:43 AM: -- [~mxm] The r

[jira] [Updated] (FLINK-31965) Fix ClassNotFoundException in benchmarks

[ https://issues.apache.org/jira/browse/FLINK-31965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31965: --- Labels: pull-request-available (was: ) > Fix ClassNotFoundException in benchmarks > ---

[GitHub] [flink-benchmarks] link3280 opened a new pull request, #70: [FLINK-31965] Fix ClassNotFoundException in benchmarks

link3280 opened a new pull request, #70: URL: https://github.com/apache/flink-benchmarks/pull/70 The benchmarks rely on the test jar of `flink-streaming-java`. However, the jar is set to test scope, thus not included in the packaged jar. Therefore ClassNotFoundException occurs while running

[jira] [Updated] (FLINK-31965) Fix ClassNotFoundException in benchmarks

[ https://issues.apache.org/jira/browse/FLINK-31965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-31965: - Description: The benchmarks rely on the test jar of `flink-streaming-java`. However, the jar is set to

[jira] [Comment Edited] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717472#comment-17717472 ] Samrat Deb edited comment on FLINK-31080 at 4/28/23 6:29 AM: -

[jira] [Created] (FLINK-31965) Fix ClassNotFoundException in benchmarks

Paul Lin created FLINK-31965: Summary: Fix ClassNotFoundException in benchmarks Key: FLINK-31965 URL: https://issues.apache.org/jira/browse/FLINK-31965 Project: Flink Issue Type: Bug Co

[jira] [Comment Edited] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717472#comment-17717472 ] Samrat Deb edited comment on FLINK-31080 at 4/28/23 6:26 AM: -

[jira] [Commented] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717472#comment-17717472 ] Samrat Deb commented on FLINK-31080: >  Sure, but I'm leaning toward unifying the cl

[GitHub] [flink] reswqa commented on a diff in pull request #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharing

reswqa commented on code in PR #22495: URL: https://github.com/apache/flink/pull/22495#discussion_r1179978366 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolService.java: ## @@ -134,7 +139,25 @@ public final void start( *

[GitHub] [flink] flinkbot commented on pull request #22497: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.

flinkbot commented on PR #22497: URL: https://github.com/apache/flink/pull/22497#issuecomment-1527051062 ## CI report: * 0bcf62a6ce663371b78b41745035a9fc34737da5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] xishuaidelin opened a new pull request, #22497: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.

xishuaidelin opened a new pull request, #22497: URL: https://github.com/apache/flink/pull/22497 ## What is the purpose of the change * This pull request support 'EXPLAIN' statement for CompiledPlan which contributes to the FLINK-31791 ## Brief change log -

[GitHub] [flink] Samrat002 commented on a diff in pull request #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotShar

Samrat002 commented on code in PR #22495: URL: https://github.com/apache/flink/pull/22495#discussion_r1179966813 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolService.java: ## @@ -134,7 +139,25 @@ public final void start( *

[GitHub] [flink] Samrat002 commented on a diff in pull request #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotShar

Samrat002 commented on code in PR #22495: URL: https://github.com/apache/flink/pull/22495#discussion_r1179967566 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolService.java: ## @@ -134,7 +139,25 @@ public final void start( *

[GitHub] [flink] Samrat002 commented on a diff in pull request #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotShar

Samrat002 commented on code in PR #22495: URL: https://github.com/apache/flink/pull/22495#discussion_r1179966813 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolService.java: ## @@ -134,7 +139,25 @@ public final void start( *

[GitHub] [flink] Samrat002 commented on a diff in pull request #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotShar

Samrat002 commented on code in PR #22495: URL: https://github.com/apache/flink/pull/22495#discussion_r1179966813 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolService.java: ## @@ -134,7 +139,25 @@ public final void start( *

[GitHub] [flink] xishuaidelin closed pull request #22494: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.

xishuaidelin closed pull request #22494: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan. URL: https://github.com/apache/flink/pull/22494 -- 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

[GitHub] [flink-kubernetes-operator] yangjf2019 commented on pull request #578: [FLINK-31815] Fixing the container vulnerability by upgrade the SnakeYaml Maven dependency

yangjf2019 commented on PR #578: URL: https://github.com/apache/flink-kubernetes-operator/pull/578#issuecomment-1527030132 Perhaps we should upgrade the snakeyaml version in **apache flink** first, and then upgrade the snakeyaml dependency in the **flink kubernetes operator**? -- This is

[jira] [Comment Edited] (FLINK-24947) Support host network for native K8s integration

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717462#comment-17717462 ] Fei Feng edited comment on FLINK-24947 at 4/28/23 5:20 AM: --- Hi

[jira] [Commented] (FLINK-24947) Support host network for native K8s integration

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717462#comment-17717462 ] Fei Feng commented on FLINK-24947: -- Hi,  [Yang Wang|https://issues.apache.org/jira/sec

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717459#comment-17717459 ] Tan Kim commented on FLINK-31963: - Thanks, Hangxiang. I've saw unaligned checkpoint hav

[jira] [Commented] (FLINK-30773) Add API for rescaling of jobs based on per-vertex parallelism overrides

[ https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717458#comment-17717458 ] Gyula Fora commented on FLINK-30773: I think the features outlined in this ticket ar

[GitHub] [flink] reswqa commented on a diff in pull request #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharing

reswqa commented on code in PR #22495: URL: https://github.com/apache/flink/pull/22495#discussion_r1179915692 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolService.java: ## @@ -134,7 +139,25 @@ public final void start( *

[GitHub] [flink] reswqa commented on a diff in pull request #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharing

reswqa commented on code in PR #22495: URL: https://github.com/apache/flink/pull/22495#discussion_r1179914378 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolService.java: ## @@ -134,7 +139,25 @@ public final void start( *

[GitHub] [flink] flinkbot commented on pull request #22496: [FLINK-31959][checkpoint] Correct the unaligned checkpoint type at checkpoint level

flinkbot commented on PR #22496: URL: https://github.com/apache/flink/pull/22496#issuecomment-1526959306 ## CI report: * d343a24145e2d321e8d79b7651cfb52726d9bd7f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717456#comment-17717456 ] Weijie Guo commented on FLINK-31080: Thanks for pick-up this, I didn't fix this anyt

[GitHub] [flink] 1996fanrui opened a new pull request, #22496: [FLINK-31959][checkpoint] Correct the unaligned checkpoint type at checkpoint level

1996fanrui opened a new pull request, #22496: URL: https://github.com/apache/flink/pull/22496 ## What is the purpose of the change If UC and AC-timeout is enabled and the checkpoint is completed as aligned checkpoint. The checkpoint type at Checkpoint history should show the aligned

[GitHub] [flink] LadyForest commented on a diff in pull request #22478: [FLINK-31917][table-planner] Fix the idempotence lost in JsonSerDe round trip for AggregateCall and RexNode

LadyForest commented on code in PR #22478: URL: https://github.com/apache/flink/pull/22478#discussion_r1179903642 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RexNodeJsonSerializer.java: ## @@ -230,12 +226,10 @@ private st

[jira] [Updated] (FLINK-31959) Correct the unaligned checkpoint type at checkpoint level

[ https://issues.apache.org/jira/browse/FLINK-31959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31959: --- Labels: pull-request-available (was: ) > Correct the unaligned checkpoint type at checkpoin

[jira] [Comment Edited] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717455#comment-17717455 ] Samrat Deb edited comment on FLINK-31080 at 4/28/23 3:57 AM: -

[jira] [Commented] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717455#comment-17717455 ] Samrat Deb commented on FLINK-31080: [~huwh] i have raised pr with changes . can you

[GitHub] [flink] LadyForest commented on a diff in pull request #22478: [FLINK-31917][table-planner] Fix the idempotence lost in JsonSerDe round trip for AggregateCall and RexNode

LadyForest commented on code in PR #22478: URL: https://github.com/apache/flink/pull/22478#discussion_r1179903642 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RexNodeJsonSerializer.java: ## @@ -230,12 +226,10 @@ private st

[GitHub] [flink] reswqa commented on pull request #22438: [FLINK-31873][API / DataStream] Add method setMaxParallelism to DataStreamSink.

reswqa commented on PR #22438: URL: https://github.com/apache/flink/pull/22438#issuecomment-1526941787 Merge after CI green. -- 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.

[jira] [Commented] (FLINK-30773) Add API for rescaling of jobs based on per-vertex parallelism overrides

[ https://issues.apache.org/jira/browse/FLINK-30773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717449#comment-17717449 ] Liu commented on FLINK-30773: - [~mxm] The rescaling api is useful in many situations such as

[jira] [Commented] (FLINK-31884) Upgrade ExecNode to new version causes the old serialized plan failed to pass Json SerDe round trip

[ https://issues.apache.org/jira/browse/FLINK-31884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717446#comment-17717446 ] Godfrey He commented on FLINK-31884: Fixed in master: 3664609c7622ccae80e36e85099a1b

[GitHub] [flink] godfreyhe closed pull request #22459: [FLINK-31884][table-planner] Fix the issue that upgrade ExecNode to new version causes the old serialized plan failed to pass Json SerDe round tr

godfreyhe closed pull request #22459: [FLINK-31884][table-planner] Fix the issue that upgrade ExecNode to new version causes the old serialized plan failed to pass Json SerDe round trip URL: https://github.com/apache/flink/pull/22459 -- This is an automated message from the Apache Git Servic

[GitHub] [flink] godfreyhe commented on a diff in pull request #22478: [FLINK-31917][table-planner] Fix the idempotence lost in JsonSerDe round trip for AggregateCall and RexNode

godfreyhe commented on code in PR #22478: URL: https://github.com/apache/flink/pull/22478#discussion_r1179890814 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RexNodeJsonSerializer.java: ## @@ -230,12 +226,10 @@ private sta

[GitHub] [flink] ericxiao251 commented on pull request #22438: [FLINK-31873][API / DataStream] Add method setMaxParallelism to DataStreamSink.

ericxiao251 commented on PR #22438: URL: https://github.com/apache/flink/pull/22438#issuecomment-1526922302 @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 commen

[GitHub] [flink] ericxiao251 commented on pull request #22438: [FLINK-31873][API / DataStream] Add method setMaxParallelism to DataStreamSink.

ericxiao251 commented on PR #22438: URL: https://github.com/apache/flink/pull/22438#issuecomment-1526919022 > Please put the hotfix commit at the first. Done :). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717440#comment-17717440 ] Hangxiang Yu commented on FLINK-31963: -- We also saw simliar exception when rescalin

[jira] [Assigned] (FLINK-31953) FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-31953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-31953: - Assignee: Hongshun Wang > FLIP-288: Enable Dynamic Partition Discovery by Default in Ka

[jira] [Commented] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717439#comment-17717439 ] Weihua Hu commented on FLINK-31080: --- IIUC, currently declarativeSlotPool is used by tw

[GitHub] [flink] reswqa merged pull request #22489: [hotfix][docs] Fix link to Ververica Platform

reswqa merged PR #22489: URL: https://github.com/apache/flink/pull/22489 -- 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: issues-unsubscr...@flink.apache

[jira] [Commented] (FLINK-31850) Fix args in JobSpec not being passed through to Flink in Standalone mode - 1.4.0

[ https://issues.apache.org/jira/browse/FLINK-31850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717434#comment-17717434 ] Biao Geng commented on FLINK-31850: --- hi [~gil_shmaya], I checked relevant codes in the

[jira] [Created] (FLINK-31964) Improve the document of Autoscaler as 1.17.0 is released

Biao Geng created FLINK-31964: - Summary: Improve the document of Autoscaler as 1.17.0 is released Key: FLINK-31964 URL: https://issues.apache.org/jira/browse/FLINK-31964 Project: Flink Issue Type

[jira] [Updated] (FLINK-31959) Correct the unaligned checkpoint type at checkpoint level

[ https://issues.apache.org/jira/browse/FLINK-31959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31959: Description: FLINK-18851 added the checkpoint type in web UI to distinguish aligned checkpoint, unaligned

[jira] [Updated] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tan Kim updated FLINK-31963: Affects Version/s: 1.17.0 > java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler >

[jira] [Updated] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tan Kim updated FLINK-31963: Labels: stability (was: ) > java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler > ---

[jira] [Created] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

Tan Kim created FLINK-31963: --- Summary: java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler Key: FLINK-31963 URL: https://issues.apache.org/jira/browse/FLINK-31963 Project: Flink

[GitHub] [flink-training] alpinegizmo closed pull request #59: Changes done after Pavel review

alpinegizmo closed pull request #59: Changes done after Pavel review URL: https://github.com/apache/flink-training/pull/59 -- 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 un

[GitHub] [flink-training] alpinegizmo commented on pull request #59: Changes done after Pavel review

alpinegizmo commented on PR #59: URL: https://github.com/apache/flink-training/pull/59#issuecomment-1526862659 @ness-vaibhavtyagi Thank you for your interest in contributing to Flink. Please note, however, that we don't intend for the exercise classes in this repository to provide sol

[GitHub] [flink-kubernetes-operator] yangjf2019 opened a new pull request, #578: [FLINK-31815] Fixing the container vulnerability by upgrade the SnakeYaml Maven dependency

yangjf2019 opened a new pull request, #578: URL: https://github.com/apache/flink-kubernetes-operator/pull/578 ## What is the purpose of the change *Upgrade the SnakeYaml Maven dependency from 1.33 to 2.0 to fix the container vulnerability [CVE-2022-1471](https://github.com/ad

[GitHub] [flink-kubernetes-operator] yangjf2019 closed pull request #567: [FLINK-31815] Fixing the container vulnerability by upgrade the SnakeYaml Maven dependency

yangjf2019 closed pull request #567: [FLINK-31815] Fixing the container vulnerability by upgrade the SnakeYaml Maven dependency URL: https://github.com/apache/flink-kubernetes-operator/pull/567 -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink-kubernetes-operator] yangjf2019 commented on pull request #567: [FLINK-31815] Fixing the container vulnerability by upgrade the SnakeYaml Maven dependency

yangjf2019 commented on PR #567: URL: https://github.com/apache/flink-kubernetes-operator/pull/567#issuecomment-1526847015 Okay, I'll fix it, thanks! -- 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

[jira] [Commented] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17

[ https://issues.apache.org/jira/browse/FLINK-25000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717380#comment-17717380 ] Martijn Visser commented on FLINK-25000: Per https://docs.scala-lang.org/overvie

[jira] [Commented] (FLINK-31962) libssl not found when running CI

[ https://issues.apache.org/jira/browse/FLINK-31962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717365#comment-17717365 ] Martijn Visser commented on FLINK-31962: Fixed in master: ed7ca22efc68203d48828

[jira] [Closed] (FLINK-31962) libssl not found when running CI

[ https://issues.apache.org/jira/browse/FLINK-31962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31962. -- Fix Version/s: 1.16.2 1.18.0 1.17.1 Resolution: Fi

[jira] [Updated] (FLINK-31962) libssl not found when running CI

[ https://issues.apache.org/jira/browse/FLINK-31962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31962: --- Priority: Blocker (was: Major) > libssl not found when running CI > ---

[jira] [Created] (FLINK-31962) libssl not found when running CI

Martijn Visser created FLINK-31962: -- Summary: libssl not found when running CI Key: FLINK-31962 URL: https://issues.apache.org/jira/browse/FLINK-31962 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllo

flinkbot commented on PR #22495: URL: https://github.com/apache/flink/pull/22495#issuecomment-1526151788 ## CI report: * b64851ad2e4534020d637e26e1b14a61db38e555 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179537961 ## flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java: ## @@ -0,0 +1,227 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Comment Edited] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717308#comment-17717308 ] Samrat Deb edited comment on FLINK-31080 at 4/27/23 6:33 PM: -

[GitHub] [flink] ericxiao251 commented on pull request #22438: [FLINK-31873][API / DataStream] Add method setMaxParallelism to DataStreamSink.

ericxiao251 commented on PR #22438: URL: https://github.com/apache/flink/pull/22438#issuecomment-1526147308 @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 commen

[jira] [Updated] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31080: --- Labels: pull-request-available (was: ) > Idle slots are not released due to a mismatch in t

[GitHub] [flink] Samrat002 opened a new pull request, #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAl

Samrat002 opened a new pull request, #22495: URL: https://github.com/apache/flink/pull/22495 ## What is the purpose of the change Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator ## Does this pull request pote

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179539366 ## flink-runtime/src/test/java/org/apache/flink/runtime/failure/FailureEnricherUtilsTest.java: ## @@ -0,0 +1,284 @@ +/* + * Licensed to the Apache Software Foundation (A

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179537961 ## flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java: ## @@ -0,0 +1,227 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179535697 ## flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java: ## @@ -0,0 +1,227 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179534966 ## flink-core/src/main/java/org/apache/flink/core/failure/FailureEnricher.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one +

[jira] [Commented] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink

[ https://issues.apache.org/jira/browse/FLINK-26425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717324#comment-17717324 ] Prabhu Joseph commented on FLINK-26425: --- This is very useful to Flink on YARN, as

[GitHub] [flink] nateab commented on pull request #22359: [FLINK-31660][table] add jayway json path dependency to table-planner

nateab commented on PR #22359: URL: https://github.com/apache/flink/pull/22359#issuecomment-1526076794 CI failed with this, will look at fixing the notice file ```01:53:59,901 INFO org.apache.flink.tools.ci.licensecheck.NoticeFileChecker [] - Problems were detected for a NOTICE file

[jira] [Commented] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717308#comment-17717308 ] Samrat Deb commented on FLINK-31080: [~Weijie Guo] we have worked internally to fix

[jira] [Created] (FLINK-31961) Implement ExpandedQuery and OriginalQuery methods for glue in catalog

Samrat Deb created FLINK-31961: -- Summary: Implement ExpandedQuery and OriginalQuery methods for glue in catalog Key: FLINK-31961 URL: https://issues.apache.org/jira/browse/FLINK-31961 Project: Flink

[jira] [Updated] (FLINK-31960) SQL OverBy. Error on a code that does not exist

[ https://issues.apache.org/jira/browse/FLINK-31960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31960: Description: Hello. I use latest Flink. And want make query with LEAD, LAG function , but i got error   

[jira] [Updated] (FLINK-31960) SQL OverBy. Error on a code that does not exist

[ https://issues.apache.org/jira/browse/FLINK-31960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31960: Description: Hello. I use latest Flink. And want make query with LEAD, LAG function , but i got error  {n

[jira] [Created] (FLINK-31960) SQL OverBy. Error on a code that does not exist

padavan created FLINK-31960: --- Summary: SQL OverBy. Error on a code that does not exist Key: FLINK-31960 URL: https://issues.apache.org/jira/browse/FLINK-31960 Project: Flink Issue Type: Bug

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

gyfora commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179350480 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java: ## @@ -113,7 +115,13 @@ pu

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

gyfora commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179349838 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/metrics/ScalingMetrics.java: ## @@ -83,6 +83,8 @@

[GitHub] [flink-kubernetes-operator] rodmeneses commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

rodmeneses commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179342548 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java: ## @@ -113,7 +115,13 @

[GitHub] [flink-kubernetes-operator] rodmeneses commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

rodmeneses commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179340070 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java: ## @@ -113,7 +115,13 @

[GitHub] [flink-kubernetes-operator] rodmeneses commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

rodmeneses commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179330753 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java: ## @@ -81,17 +83,17 @@

[jira] [Resolved] (FLINK-31866) Autoscaler metric trimming reduces the number of metric observations on recovery

[ https://issues.apache.org/jira/browse/FLINK-31866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-31866. Resolution: Fixed > Autoscaler metric trimming reduces the number of metric observ

[GitHub] [flink] dmvk commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

dmvk commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179264603 ## flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java: ## @@ -0,0 +1,227 @@ +/* + * Licensed to the Apache Software Foundation (ASF) un

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

mxm commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179255242 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/metrics/ScalingMetrics.java: ## @@ -83,6 +83,8 @@ pub

[GitHub] [flink] ericxiao251 commented on pull request #22438: [FLINK-31873] Add method setMaxParallelism to DataStreamSink.

ericxiao251 commented on PR #22438: URL: https://github.com/apache/flink/pull/22438#issuecomment-1525799723 @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 commen

[GitHub] [flink] ericxiao251 commented on a diff in pull request #22438: [FLINK-31873] Add method setMaxParallelism to DataStreamSink.

ericxiao251 commented on code in PR #22438: URL: https://github.com/apache/flink/pull/22438#discussion_r1179247666 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java: ## @@ -283,6 +283,27 @@ public void testTransformati

[GitHub] [flink] sigalite commented on pull request #22393: FLINK-28171 [flink-kubernates] enable add appProtocol via the configuration and verify it is not overridden by Default port defintion

sigalite commented on PR #22393: URL: https://github.com/apache/flink/pull/22393#issuecomment-1525791232 added unit tests. thanks -- 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 comm

[GitHub] [flink] ericxiao251 commented on a diff in pull request #22438: [FLINK-31873] Add method setMaxParallelism to DataStreamSink.

ericxiao251 commented on code in PR #22438: URL: https://github.com/apache/flink/pull/22438#discussion_r1179231832 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java: ## @@ -180,6 +180,18 @@ public DataStreamSink setParallelism(in

[GitHub] [flink] flinkbot commented on pull request #22494: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.

flinkbot commented on PR #22494: URL: https://github.com/apache/flink/pull/22494#issuecomment-1525707627 ## CI report: * 0443bcca5bc44abebcfd1659d9f73301525005f1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] xishuaidelin closed pull request #22494: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.

xishuaidelin closed pull request #22494: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan. URL: https://github.com/apache/flink/pull/22494 -- 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

[jira] [Updated] (FLINK-31952) Support 'EXPLAIN' statement for CompiledPlan

[ https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31952: --- Labels: pull-request-available (was: ) > Support 'EXPLAIN' statement for CompiledPlan > ---

[GitHub] [flink] xishuaidelin opened a new pull request, #22494: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.

xishuaidelin opened a new pull request, #22494: URL: https://github.com/apache/flink/pull/22494 ## What is the purpose of the change * This pull request support 'EXPLAIN' statement for CompiledPlan which contributes to the FLINK-31791.* ## Brief change log

[GitHub] [flink] TanYuxin-tyx commented on pull request #22427: [FLINK-30815][tests] Migrate BatchAbstractTestBase and BatchTestBase to junit5

TanYuxin-tyx commented on PR #22427: URL: https://github.com/apache/flink/pull/22427#issuecomment-1525612113 @godfreyhe Thanks for helping review the change. I have updated the code according to the comments. I add 3 methods in `BatchAbstractTestBase`, `createTempFolder`, `createTempFil

[jira] [Closed] (FLINK-31911) Bad address construction in SqlClientTest

[ https://issues.apache.org/jira/browse/FLINK-31911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-31911. Resolution: Fixed master: 146847e53f10967dc2133cfdee6adbc57bccdd38 > Bad address construc

[GitHub] [flink] zentol merged pull request #22473: [FLINK-31911][sql][tests] Fix address construction

zentol merged PR #22473: URL: https://github.com/apache/flink/pull/22473 -- 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: issues-unsubscr...@flink.apache

[jira] [Updated] (FLINK-31911) Bad address construction in SqlClientTest

[ https://issues.apache.org/jira/browse/FLINK-31911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31911: --- Labels: pull-request-available (was: ) > Bad address construction in SqlClientTest > --

[GitHub] [flink] zentol commented on pull request #22473: [FLINK-31911][sql][tests] Fix address construction

zentol commented on PR #22473: URL: https://github.com/apache/flink/pull/22473#issuecomment-1525589562 This should be FLINK-31911. -- 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 com

[GitHub] [flink] luoyuxia commented on pull request #22488: [FLINK-31882][sql-client] Fix sql client can't show result for DELETE statement when delete is pushed down

luoyuxia commented on PR #22488: URL: https://github.com/apache/flink/pull/22488#issuecomment-1525581073 @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 comment.

[GitHub] [flink] xintongsong commented on a diff in pull request #22330: [FLINK-31635][network] Support writing records to the new tiered store architecture

xintongsong commented on code in PR #22330: URL: https://github.com/apache/flink/pull/22330#discussion_r1170781624 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/common/TieredStorageUtils.java: ## @@ -0,0 +1,56 @@ +/* + * Licensed to t

[GitHub] [flink] LadyForest commented on pull request #22492: [FLINK-31950][table-planner] Introduce StateMetadata and support operator-level state TTL configuration via Compiled Plan

LadyForest commented on PR #22492: URL: https://github.com/apache/flink/pull/22492#issuecomment-1525542072 @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 comment

[GitHub] [flink] LadyForest commented on pull request #22478: [FLINK-31917][table-planner] Fix the idempotence lost in JsonSerDe round trip for AggregateCall and RexNode

LadyForest commented on PR #22478: URL: https://github.com/apache/flink/pull/22478#issuecomment-1525541392 @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 commen

  1   2   >