[jira] [Updated] (FLINK-32039) ExecutorServiceResource and ExecutorServiceExtension's shutdown mechanism doesn't include a forced shutdown

2023-05-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32039: --- Labels: pull-request-available (was: ) > ExecutorServiceResource and ExecutorServiceExtensi

[GitHub] [flink] XComp opened a new pull request, #22548: [FLINK-32039][test] Adds graceful shutdown to TestExecutorExtension and TestExecutorResource

2023-05-08 Thread via GitHub
XComp opened a new pull request, #22548: URL: https://github.com/apache/flink/pull/22548 ## What is the purpose of the change The shutdown of the `executorService` is triggered but no check for hanging threads is done. This PR adds the graceful shutdown and forces threads to be cance

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

2023-05-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31965. -- Resolution: Fixed Fixed in master: c038bf3f83c56230c6e621373160d0215af0e256 > Fix ClassNotFou

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

2023-05-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-31965: -- Assignee: Paul Lin > Fix ClassNotFoundException in benchmarks > -

[jira] [Commented] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

2023-05-08 Thread Pritam Agarwala (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720807#comment-17720807 ] Pritam Agarwala commented on FLINK-32038: - [~martijnvisser]  I have already gone

[GitHub] [flink-benchmarks] MartijnVisser merged pull request #70: [FLINK-31965] Fix ClassNotFoundException in benchmarks

2023-05-08 Thread via GitHub
MartijnVisser merged PR #70: URL: https://github.com/apache/flink-benchmarks/pull/70 -- 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...@

[GitHub] [flink] XComp commented on pull request #22544: [FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException

2023-05-08 Thread via GitHub
XComp commented on PR #22544: URL: https://github.com/apache/flink/pull/22544#issuecomment-1539552187 I dropped the Executor shutdown commit (this one is moved to FLINK-32039) and rebased the branch. Thanks for your review, @pgaref -- This is an automated message from the Apache Git Serv

[GitHub] [flink] XComp commented on a diff in pull request #22544: [FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException

2023-05-08 Thread via GitHub
XComp commented on code in PR #22544: URL: https://github.com/apache/flink/pull/22544#discussion_r1188199816 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/executor/TestExecutorResource.java: ## @@ -47,6 +55,20 @@ public T getExecutor(

[GitHub] [flink] XComp commented on a diff in pull request #22544: [FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException

2023-05-08 Thread via GitHub
XComp commented on code in PR #22544: URL: https://github.com/apache/flink/pull/22544#discussion_r1188199532 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/executor/TestExecutorExtension.java: ## @@ -49,6 +58,20 @@ public T getExecutor

[jira] [Closed] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

2023-05-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32038. -- Resolution: Information Provided OffsetCommitModes is an Internal implementation and shouldn't

[jira] [Commented] (FLINK-32009) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

2023-05-08 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720799#comment-17720799 ] Weihua Hu commented on FLINK-32009: --- [~baibaiwuchang]  The "OOM" Exception was thrown

[GitHub] [flink] MartijnVisser commented on pull request #22546: [FLINK-32032] Upgrade to flink-shaded 17.0

2023-05-08 Thread via GitHub
MartijnVisser commented on PR #22546: URL: https://github.com/apache/flink/pull/22546#issuecomment-1539541455 @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 comm

[jira] [Updated] (FLINK-32039) ExecutorServiceResource and ExecutorServiceExtension's shutdown mechanism doesn't include a forced shutdown

2023-05-08 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32039: -- Description: {{ExecutorServiceResource}} and {{ExecutorServiceExtension}}'s shutdown mechanis

[jira] [Updated] (FLINK-32039) ExecutorServiceResource and ExecutorServiceExtension's shutdown mechanism doesn't include a forced shutdown

2023-05-08 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32039: -- Component/s: Runtime / Coordination > ExecutorServiceResource and ExecutorServiceExtension's s

[jira] [Created] (FLINK-32039) ExecutorServiceResource and ExecutorServiceExtension's shutdown mechanism doesn't include a forced shutdown

2023-05-08 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32039: - Summary: ExecutorServiceResource and ExecutorServiceExtension's shutdown mechanism doesn't include a forced shutdown Key: FLINK-32039 URL: https://issues.apache.org/jira/browse/

[jira] [Updated] (FLINK-32039) ExecutorServiceResource and ExecutorServiceExtension's shutdown mechanism doesn't include a forced shutdown

2023-05-08 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32039: -- Affects Version/s: 1.16.1 1.17.0 1.18.0 > Execut

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #587: [FLINK-31717] Fix unit tests using local kube config

2023-05-08 Thread via GitHub
gyfora commented on PR #587: URL: https://github.com/apache/flink-kubernetes-operator/pull/587#issuecomment-1539505864 @mateczagany seems like we are losing some test coverage by simply deleting the operator itcase. Why did you decide to delete it? -- This is an automated message from th

[jira] [Comment Edited] (FLINK-32009) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

2023-05-08 Thread hanjie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720791#comment-17720791 ] hanjie edited comment on FLINK-32009 at 5/9/23 5:54 AM: Hi [~wan

[jira] [Commented] (FLINK-32009) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

2023-05-08 Thread hanjie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720791#comment-17720791 ] hanjie commented on FLINK-32009: Hi [~wanglijie]  > Slot request bulk is not fulfillabl

[jira] [Comment Edited] (FLINK-32009) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

2023-05-08 Thread hanjie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720791#comment-17720791 ] hanjie edited comment on FLINK-32009 at 5/9/23 5:53 AM: Hi [~wan

[jira] [Commented] (FLINK-32009) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

2023-05-08 Thread hanjie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720790#comment-17720790 ] hanjie commented on FLINK-32009: [^taskmanager.log] > Slot request bulk is not fulfilla

[jira] [Updated] (FLINK-32009) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

2023-05-08 Thread hanjie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hanjie updated FLINK-32009: --- Attachment: taskmanager.log > Slot request bulk is not fulfillable! Could not allocate the required slot >

[jira] (FLINK-32009) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

2023-05-08 Thread hanjie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32009 ] hanjie deleted comment on FLINK-32009: was (Author: baibaiwuchang): [^taskmanager.log] > Slot request bulk is not fulfillable! Could not allocate the required slot > within slot request timeout

[jira] [Updated] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

2023-05-08 Thread Pritam Agarwala (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pritam Agarwala updated FLINK-32038: Affects Version/s: 1.14.6 > OffsetCommitMode.Kafka_periodic with checkpointing enabled >

[jira] [Updated] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

2023-05-08 Thread Pritam Agarwala (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pritam Agarwala updated FLINK-32038: Description: I need to get kafka-lag to prepare a graph and its dependent on kafka committ

[jira] [Updated] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

2023-05-08 Thread Pritam Agarwala (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pritam Agarwala updated FLINK-32038: Description: I need to get kafka-lag to prepare a graph and its dependent on kafka committ

[jira] [Updated] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

2023-05-08 Thread Pritam Agarwala (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pritam Agarwala updated FLINK-32038: Component/s: Connectors / Kafka > OffsetCommitMode.Kafka_periodic with checkpointing enabl

[jira] [Updated] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

2023-05-08 Thread Pritam Agarwala (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pritam Agarwala updated FLINK-32038: Component/s: Runtime / Checkpointing > OffsetCommitMode.Kafka_periodic with checkpointing

[jira] [Created] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

2023-05-08 Thread Pritam Agarwala (Jira)
Pritam Agarwala created FLINK-32038: --- Summary: OffsetCommitMode.Kafka_periodic with checkpointing enabled Key: FLINK-32038 URL: https://issues.apache.org/jira/browse/FLINK-32038 Project: Flink

[jira] [Commented] (FLINK-32027) Batch jobs could hang at shuffle phase when max parallelism is really large

2023-05-08 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720777#comment-17720777 ] Weijie Guo commented on FLINK-32027: Marked this as blocker as this has a probabilit

[jira] [Updated] (FLINK-32027) Batch jobs could hang at shuffle phase when max parallelism is really large

2023-05-08 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32027: --- Priority: Blocker (was: Critical) > Batch jobs could hang at shuffle phase when max parallelism is

[jira] (FLINK-31970) "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction

2023-05-08 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31970 ] Yanfei Lei deleted comment on FLINK-31970: was (Author: yanfei lei): After triggering “stop with savepoint”, are there some savepoint files generated? Could you share the detailed stack trac

[jira] [Commented] (FLINK-31970) "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction

2023-05-08 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720776#comment-17720776 ] Yanfei Lei commented on FLINK-31970: After triggering “stop with savepoint”, are the

[GitHub] [flink-kubernetes-operator] X-czh commented on a diff in pull request #581: [FLINK-31936] Support setting scale up max factor

2023-05-08 Thread via GitHub
X-czh commented on code in PR #581: URL: https://github.com/apache/flink-kubernetes-operator/pull/581#discussion_r1188110764 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java: ## @@ -98,6 +98,13 @

[GitHub] [flink] pgaref commented on a diff in pull request #22506: [FLINK-31890][runtime] Introduce JobMaster per-task failure enrichment/labeling

2023-05-08 Thread via GitHub
pgaref commented on code in PR #22506: URL: https://github.com/apache/flink/pull/22506#discussion_r1188101108 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -473,26 +500,50 @@ public CompletableFuture cancel(Time timeout) { @Overrid

[GitHub] [flink-kubernetes-operator] X-czh commented on a diff in pull request #581: [FLINK-31936] Support setting scale up max factor

2023-05-08 Thread via GitHub
X-czh commented on code in PR #581: URL: https://github.com/apache/flink-kubernetes-operator/pull/581#discussion_r1188100551 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java: ## @@ -98,6 +98,13 @

[GitHub] [flink-kubernetes-operator] X-czh commented on a diff in pull request #581: [FLINK-31936] Support setting scale up max factor

2023-05-08 Thread via GitHub
X-czh commented on code in PR #581: URL: https://github.com/apache/flink-kubernetes-operator/pull/581#discussion_r1188100551 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java: ## @@ -98,6 +98,13 @

[GitHub] [flink] venkata91 commented on a diff in pull request #22509: [FLINK-31983] Add yarn Acls capability to Flink containers

2023-05-08 Thread via GitHub
venkata91 commented on code in PR #22509: URL: https://github.com/apache/flink/pull/22509#discussion_r1188097816 ## flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java: ## @@ -620,4 +623,30 @@ public static YarnConfiguration getYarnConfiguration( return yarnConf

[GitHub] [flink] fredia commented on a diff in pull request #22457: [FLINK-31876][QS] Migrate flink-queryable-state-runtime tests to JUnit5

2023-05-08 Thread via GitHub
fredia commented on code in PR #22457: URL: https://github.com/apache/flink/pull/22457#discussion_r1188095891 ## flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/KvStateClientHandlerTest.java: ## @@ -93,28 +92,66 @@ public

[GitHub] [flink] fredia commented on a diff in pull request #22457: [FLINK-31876][QS] Migrate flink-queryable-state-runtime tests to JUnit5

2023-05-08 Thread via GitHub
fredia commented on code in PR #22457: URL: https://github.com/apache/flink/pull/22457#discussion_r1188095522 ## flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateFsBackendITCase.java: ## @@ -48,31 +48,33

[GitHub] [flink-playgrounds] alpinegizmo commented on pull request #42: Create flink_data volume for operations playground.

2023-05-08 Thread via GitHub
alpinegizmo commented on PR #42: URL: https://github.com/apache/flink-playgrounds/pull/42#issuecomment-1539347464 The reason that the checkpoint and savepoint directories are exposed in the host file system is so that you can easily use the checkpoints and savepoints for restarting and resc

[jira] [Updated] (FLINK-32037) The edge on Web UI is wrong after parallelism changes via parallelism overrides or AdaptiveScheduler

2023-05-08 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-32037: -- Description: *Background* After FLINK-30213, in case of parallelism changes to the JobGraph,

[jira] [Updated] (FLINK-32037) The edge on Web UI is wrong after parallelism changes via parallelism overrides or AdaptiveScheduler

2023-05-08 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-32037: -- Issue Type: Bug (was: Improvement) > The edge on Web UI is wrong after parallelism changes vi

[jira] [Updated] (FLINK-32037) The edge on Web UI is wrong after parallelism changes via parallelism overrides or AdaptiveScheduler

2023-05-08 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-32037: -- Description: *Background* After FLINK-30213, in case of parallelism changes to the JobGraph,

[jira] [Created] (FLINK-32037) The edge on Web UI is wrong after parallelism changes via parallelism overrides or AdaptiveScheduler

2023-05-08 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-32037: - Summary: The edge on Web UI is wrong after parallelism changes via parallelism overrides or AdaptiveScheduler Key: FLINK-32037 URL: https://issues.apache.org/jira/browse/FLINK-

[GitHub] [flink] pgaref commented on a diff in pull request #22544: [FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException

2023-05-08 Thread via GitHub
pgaref commented on code in PR #22544: URL: https://github.com/apache/flink/pull/22544#discussion_r1188052161 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/executor/TestExecutorExtension.java: ## @@ -49,6 +58,20 @@ public T getExecuto

[GitHub] [flink] pgaref commented on a diff in pull request #22544: [FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException

2023-05-08 Thread via GitHub
pgaref commented on code in PR #22544: URL: https://github.com/apache/flink/pull/22544#discussion_r1188052161 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/executor/TestExecutorExtension.java: ## @@ -49,6 +58,20 @@ public T getExecuto

[jira] [Commented] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

2023-05-08 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720736#comment-17720736 ] Feifan Wang commented on FLINK-31743: - Thanks [~yunta] , I submit a new [PR|https:/

[GitHub] [flink] zoltar9264 commented on a diff in pull request #22458: [FLINK-31743][statebackend/rocksdb] disable rocksdb log relocating wh…

2023-05-08 Thread via GitHub
zoltar9264 commented on code in PR #22458: URL: https://github.com/apache/flink/pull/22458#discussion_r1188033528 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java: ## @@ -82,34 +88,42 @@ publi

[GitHub] [flink] architgyl commented on a diff in pull request #22509: [FLINK-31983] Add yarn Acls capability to Flink containers

2023-05-08 Thread via GitHub
architgyl commented on code in PR #22509: URL: https://github.com/apache/flink/pull/22509#discussion_r1187759775 ## docs/layouts/shortcodes/generated/yarn_config_configuration.html: ## @@ -182,5 +182,15 @@ String Specify YARN node label for the Flink Ta

[GitHub] [flink-connector-kafka] Gerrrr commented on pull request #7: [FLINK-31408] Add support for EOS delivery-guarantee in upsert-kafka

2023-05-08 Thread via GitHub
Ge commented on PR #7: URL: https://github.com/apache/flink-connector-kafka/pull/7#issuecomment-1539219023 @tzulitai This PR is ready for review. Can you please take a look when you get a chance? -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-connector-jdbc] liuml07 commented on a diff in pull request #4: [FLINK-29750][Connector/JDBC] Improve PostgresCatalog#listTables() by reusing resources

2023-05-08 Thread via GitHub
liuml07 commented on code in PR #4: URL: https://github.com/apache/flink-connector-jdbc/pull/4#discussion_r1187972768 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java: ## @@ -522,6 +509,25 @@ protected List extractColumnValu

[GitHub] [flink] flinkbot commented on pull request #22547: [FLINK-30081][runtime] Reset jvm-overhead.min/max for local executor

2023-05-08 Thread via GitHub
flinkbot commented on PR #22547: URL: https://github.com/apache/flink/pull/22547#issuecomment-1539107735 ## CI report: * 0dd28cbeb4a737d4d7af14a444f257c9812dcd25 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuml07 commented on a diff in pull request #22547: [FLINK-30081][runtime] Reset jvm-overhead.min/max for local executor

2023-05-08 Thread via GitHub
liuml07 commented on code in PR #22547: URL: https://github.com/apache/flink/pull/22547#discussion_r1187931609 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorResourceUtils.java: ## @@ -250,7 +251,7 @@ private static void warnOptionHasNoEffectIf

[GitHub] [flink] liuml07 commented on pull request #22547: [FLINK-30081][runtime] Reset jvm-overhead.min/max for local executor

2023-05-08 Thread via GitHub
liuml07 commented on PR #22547: URL: https://github.com/apache/flink/pull/22547#issuecomment-1539106446 CC: @xintongsong for review. 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 sp

[jira] [Commented] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

2023-05-08 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720687#comment-17720687 ] Mingliang Liu commented on FLINK-30081: --- I checked again and found we have already

[jira] [Updated] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

2023-05-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30081: --- Labels: pull-request-available (was: ) > Local executor can not accept different jvm-overhe

[GitHub] [flink] liuml07 opened a new pull request, #22547: [FLINK-30081][runtime] Reset jvm-overhead.min/max for local executor

2023-05-08 Thread via GitHub
liuml07 opened a new pull request, #22547: URL: https://github.com/apache/flink/pull/22547 ## What is the purpose of the change https://issues.apache.org/jira/browse/FLINK-30081 In local executor, it's not possible to set different values for `taskmanager.memory.jvm-overhead.ma

[jira] [Commented] (FLINK-32036) TableEnvironmentTest.test_explain is unstable on azure ci

2023-05-08 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720681#comment-17720681 ] Sergey Nuyanzin commented on FLINK-32036: - // cc [~dianfu], [~hxbks2ks] > Table

[jira] [Created] (FLINK-32036) TableEnvironmentTest.test_explain is unstable on azure ci

2023-05-08 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32036: --- Summary: TableEnvironmentTest.test_explain is unstable on azure ci Key: FLINK-32036 URL: https://issues.apache.org/jira/browse/FLINK-32036 Project: Flink

[jira] [Commented] (FLINK-32006) AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry times out on Azure

2023-05-08 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720678#comment-17720678 ] Sergey Nuyanzin commented on FLINK-32006: - https://dev.azure.com/apache-flink/ap

[GitHub] [flink-connector-jdbc] dhruva1995 commented on a diff in pull request #4: [FLINK-29750][Connector/JDBC] Improve PostgresCatalog#listTables() by reusing resources

2023-05-08 Thread via GitHub
dhruva1995 commented on code in PR #4: URL: https://github.com/apache/flink-connector-jdbc/pull/4#discussion_r1187885272 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java: ## @@ -522,6 +509,25 @@ protected List extractColumnV

[GitHub] [flink-connector-jdbc] dhruva1995 commented on a diff in pull request #4: [FLINK-29750][Connector/JDBC] Improve PostgresCatalog#listTables() by reusing resources

2023-05-08 Thread via GitHub
dhruva1995 commented on code in PR #4: URL: https://github.com/apache/flink-connector-jdbc/pull/4#discussion_r1187884474 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java: ## @@ -522,6 +509,25 @@ protected List extractColumnV

[jira] [Commented] (FLINK-31860) FlinkDeployments never finalize when namespace is deleted

2023-05-08 Thread Jayme Howard (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720654#comment-17720654 ] Jayme Howard commented on FLINK-31860: -- [~rmetzger] That looks awesome!  Thank you

[GitHub] [flink] architgyl commented on a diff in pull request #22509: [FLINK-31983] Add yarn Acls capability to Flink containers

2023-05-08 Thread via GitHub
architgyl commented on code in PR #22509: URL: https://github.com/apache/flink/pull/22509#discussion_r1187759775 ## docs/layouts/shortcodes/generated/yarn_config_configuration.html: ## @@ -182,5 +182,15 @@ String Specify YARN node label for the Flink Ta

[GitHub] [flink] architgyl commented on a diff in pull request #22509: [FLINK-31983] Add yarn Acls capability to Flink containers

2023-05-08 Thread via GitHub
architgyl commented on code in PR #22509: URL: https://github.com/apache/flink/pull/22509#discussion_r1187756546 ## docs/layouts/shortcodes/generated/yarn_config_configuration.html: ## @@ -182,5 +182,15 @@ String Specify YARN node label for the Flink Ta

[GitHub] [flink] architgyl commented on a diff in pull request #22509: [FLINK-31983] Add yarn Acls capability to Flink containers

2023-05-08 Thread via GitHub
architgyl commented on code in PR #22509: URL: https://github.com/apache/flink/pull/22509#discussion_r1187755439 ## flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java: ## @@ -620,4 +623,30 @@ public static YarnConfiguration getYarnConfiguration( return yarnConf

[jira] [Updated] (FLINK-32030) SQL Client gateway mode should accept URLs

2023-05-08 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32030: -- Description: Currently, the _--endpoint_ parameter has to be specified in the _InetSo

[jira] [Updated] (FLINK-32035) SQL Client should support HTTPS with built-in JDK certificates

2023-05-08 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32035: -- Description: Related to FLINK-32030  Internally SQL Client uses  Flink’s _RestClient_

[jira] [Updated] (FLINK-32035) SQL Client should support HTTPS with built-in JDK certificates

2023-05-08 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32035: -- Description: Another related issue is that internally SQL Client uses   Flink’s _RestCl

[jira] [Updated] (FLINK-32035) SQL Client should support HTTPS with built-in JDK certificates

2023-05-08 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32035: -- Affects Version/s: 1.17.0 > SQL Client should support HTTPS with built-in JDK certific

[jira] [Created] (FLINK-32035) SQL Client should support HTTPS with built-in JDK certificates

2023-05-08 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32035: - Summary: SQL Client should support HTTPS with built-in JDK certificates Key: FLINK-32035 URL: https://issues.apache.org/jira/browse/FLINK-32035 Project: Fli

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #581: [FLINK-31936] Support setting scale up max factor

2023-05-08 Thread via GitHub
mxm commented on code in PR #581: URL: https://github.com/apache/flink-kubernetes-operator/pull/581#discussion_r1187695299 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java: ## @@ -98,6 +98,13 @@

[GitHub] [flink-connector-jdbc] reswqa commented on a diff in pull request #45: [hotfix] Fix incorrect sql_url in jdbc.yml.

2023-05-08 Thread via GitHub
reswqa commented on code in PR #45: URL: https://github.com/apache/flink-connector-jdbc/pull/45#discussion_r1187683258 ## docs/data/jdbc.yml: ## @@ -18,4 +18,4 @@ variants: - maven: flink-connector-jdbc -sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/

[GitHub] [flink] reswqa commented on a diff in pull request #22457: [FLINK-31876][QS] Migrate flink-queryable-state-runtime tests to JUnit5

2023-05-08 Thread via GitHub
reswqa commented on code in PR #22457: URL: https://github.com/apache/flink/pull/22457#discussion_r1187679033 ## flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAQueryableStateFsBackendITCase.java: ## @@ -48,31 +48,33

[GitHub] [flink] reswqa commented on a diff in pull request #22457: [FLINK-31876][QS] Migrate flink-queryable-state-runtime tests to JUnit5

2023-05-08 Thread via GitHub
reswqa commented on code in PR #22457: URL: https://github.com/apache/flink/pull/22457#discussion_r1187645751 ## flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/KvStateClientHandlerTest.java: ## @@ -93,28 +92,66 @@ public

[jira] [Comment Edited] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scaling down with unaligned checkpoints

2023-05-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720610#comment-17720610 ] Piotr Nowojski edited comment on FLINK-31963 at 5/8/23 5:03 PM: --

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scaling down with unaligned checkpoints

2023-05-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720610#comment-17720610 ] Piotr Nowojski commented on FLINK-31963: Additionally to what [~srichter] asked.

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scaling down with unaligned checkpoints

2023-05-08 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720596#comment-17720596 ] Stefan Richter commented on FLINK-31963: Hi, just to clarify: when you say a che

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #586: [FLINK-32002] Adjust autoscaler defaults for release

2023-05-08 Thread via GitHub
mxm commented on code in PR #586: URL: https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1187646391 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java: ## @@ -68,15 +68,16 @@

[jira] [Assigned] (FLINK-32033) Resource lifecycle state shows stable even if application deployment goes missing

2023-05-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-32033: -- Assignee: Clara Xiong > Resource lifecycle state shows stable even if application deployment

[jira] [Updated] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

2023-05-08 Thread Colten Pilgreen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colten Pilgreen updated FLINK-32034: Attachment: get_site_packages_path_script_shortened.py get_site_packages_pa

[jira] [Updated] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

2023-05-08 Thread Colten Pilgreen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colten Pilgreen updated FLINK-32034: Attachment: (was: get_site_packages_path_script_shortened.py) > Python's DistUtils is

[jira] [Updated] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

2023-05-08 Thread Colten Pilgreen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colten Pilgreen updated FLINK-32034: Attachment: (was: get_site_packages_path_script.py) > Python's DistUtils is deprecated

[GitHub] [flink] zentol commented on a diff in pull request #21349: [FLINK-28203] Support Maven 3.3+

2023-05-08 Thread via GitHub
zentol commented on code in PR #21349: URL: https://github.com/apache/flink/pull/21349#discussion_r1187563240 ## tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/optional/ShadeOptionalChecker.java: ## @@ -0,0 +1,206 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [flink] zentol commented on a diff in pull request #21349: [FLINK-28203] Support Maven 3.3+

2023-05-08 Thread via GitHub
zentol commented on code in PR #21349: URL: https://github.com/apache/flink/pull/21349#discussion_r1187556938 ## tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/optional/ShadeOptionalChecker.java: ## @@ -0,0 +1,206 @@ +/* + * Licensed to the Apache Software Found

[jira] [Commented] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

2023-05-08 Thread Colten Pilgreen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720534#comment-17720534 ] Colten Pilgreen commented on FLINK-32034: - After digging into the code, and taki

[jira] [Updated] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

2023-05-08 Thread Colten Pilgreen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colten Pilgreen updated FLINK-32034: Attachment: get_site_packages_path_script_shortened.py get_site_packages_pa

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #588: [hotfix] Update CRD compat check to 1.4.0

2023-05-08 Thread via GitHub
gyfora opened a new pull request, #588: URL: https://github.com/apache/flink-kubernetes-operator/pull/588 ## What is the purpose of the change Update the CRD compatibility check to reference the most recent stable version and remove older versions from the check as the checks should b

[jira] [Updated] (FLINK-31717) Unit tests running with local kube config

2023-05-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31717: --- Labels: pull-request-available (was: ) > Unit tests running with local kube config > --

[GitHub] [flink-kubernetes-operator] mateczagany opened a new pull request, #587: [FLINK-31717] Fix unit tests using local kube config

2023-05-08 Thread via GitHub
mateczagany opened a new pull request, #587: URL: https://github.com/apache/flink-kubernetes-operator/pull/587 ## What is the purpose of the change Fix unit tests trying to access the Kubernetes cluster found in `~/.kube/config` as this might be dangerous if there's a production serve

[GitHub] [flink] xintongsong closed pull request #22541: [BP-1.16][FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective

2023-05-08 Thread via GitHub
xintongsong closed pull request #22541: [BP-1.16][FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective URL: https://github.com/apache/flink/pull/22541 -- This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink] xintongsong commented on pull request #22541: [BP-1.16][FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective

2023-05-08 Thread via GitHub
xintongsong commented on PR #22541: URL: https://github.com/apache/flink/pull/22541#issuecomment-1538462515 68a79a05155d4a43395ad51589d9a2cae740bea5 -- 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 t

[jira] [Closed] (FLINK-31984) Savepoint on S3 should be relocatable if entropy injection is not effective

2023-05-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-31984. Resolution: Fixed release-1.17: 9d31efe7e4ec358a64f79ca5e8ff516cabea0cce release-1.16: 68a79a05155

[GitHub] [flink] xintongsong closed pull request #22522: [BP-1.17][FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective

2023-05-08 Thread via GitHub
xintongsong closed pull request #22522: [BP-1.17][FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective URL: https://github.com/apache/flink/pull/22522 -- This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink] xintongsong commented on pull request #22522: [BP-1.17][FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective

2023-05-08 Thread via GitHub
xintongsong commented on PR #22522: URL: https://github.com/apache/flink/pull/22522#issuecomment-1538459268 9d31efe7e4ec358a64f79ca5e8ff516cabea0cce -- 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 t

[jira] [Updated] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

2023-05-08 Thread Colten Pilgreen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colten Pilgreen updated FLINK-32034: Description: I have recent just went through an upgrade from 1.13 to 1.17, along with that

[jira] [Updated] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

2023-05-08 Thread Colten Pilgreen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colten Pilgreen updated FLINK-32034: Description: I have recent just went through an upgrade from 1.13 to 1.17, along with that

[jira] [Created] (FLINK-32034) Python's DistUtils is deprecated as of 3.10

2023-05-08 Thread Colten Pilgreen (Jira)
Colten Pilgreen created FLINK-32034: --- Summary: Python's DistUtils is deprecated as of 3.10 Key: FLINK-32034 URL: https://issues.apache.org/jira/browse/FLINK-32034 Project: Flink Issue Type:

[GitHub] [flink] gyfora commented on pull request #22540: [FLINK-31997] Upgrade to fabric8 6.5.1

2023-05-08 Thread via GitHub
gyfora commented on PR #22540: URL: https://github.com/apache/flink/pull/22540#issuecomment-1538441380 There seems to be some error in the e2e-s I need to investigate: ``` Caused by: org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.KubernetesClientException: The okhttp

  1   2   >