[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=17720791#comment-17720791 ] hanjie edited comment on FLINK-32009 at 5/9/23 5:54 AM: Hi [~wanglijie] This is

[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=17720791#comment-17720791 ] hanjie commented on FLINK-32009: Hi [~wanglijie]  > Slot request bulk is not fulfillable! Could not

[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=17720791#comment-17720791 ] hanjie edited comment on FLINK-32009 at 5/9/23 5:53 AM: Hi [~wanglijie]

[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=17720790#comment-17720790 ] hanjie commented on FLINK-32009: [^taskmanager.log] > Slot request bulk is not fulfillable! Could not

[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

[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

[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

[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

[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=17720777#comment-17720777 ] Weijie Guo commented on FLINK-32027: Marked this as blocker as this has a probability of causing

[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

[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=17720776#comment-17720776 ] Yanfei Lei commented on FLINK-31970: After triggering “stop with savepoint”, are there some

[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) {

[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

[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 @@

[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

[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

[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

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

[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

[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

[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=17720736#comment-17720736 ] Feifan Wang commented on FLINK-31743: - Thanks [~yunta] , I submit a new

[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 @@

[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

[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

[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

[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

[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=17720687#comment-17720687 ] Mingliang Liu commented on FLINK-30081: --- I checked again and found we have already been logging

[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

[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

[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=17720681#comment-17720681 ] Sergey Nuyanzin commented on FLINK-32036: - // cc [~dianfu], [~hxbks2ks] >

[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=17720678#comment-17720678 ] Sergey Nuyanzin commented on FLINK-32006: -

[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

[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

[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=17720654#comment-17720654 ] Jayme Howard commented on FLINK-31860: -- [~rmetzger] That looks awesome!  Thank you for sharing it!

[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

[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

[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

[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

[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

[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 

[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

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

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

[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

[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 @@

[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=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=17720610#comment-17720610 ] Piotr Nowojski commented on FLINK-31963: Additionally to what [~srichter] asked. [~tanee.kim],

[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=17720596#comment-17720596 ] Stefan Richter commented on FLINK-31963: Hi, just to clarify: when you say a checkpoint that

[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

[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

[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

[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

[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=17720534#comment-17720534 ] Colten Pilgreen commented on FLINK-32034: - After digging into the code, and taking a couple of

[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

[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

[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

[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

[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

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

[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

[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

[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

[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

[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

[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

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

2023-05-08 Thread via GitHub
tweise commented on PR #22540: URL: https://github.com/apache/flink/pull/22540#issuecomment-1538435948 And glad to see that fabric8 is already relocated to `org.apache.flink.kubernetes.shaded.io.fabric8` -- This is an automated message from the Apache Git Service. To respond to the

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

2023-05-08 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-32033: -- Summary: Resource lifecycle state shows stable even if application deployment goes missing Key: FLINK-32033 URL: https://issues.apache.org/jira/browse/FLINK-32033

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

2023-05-08 Thread via GitHub
tweise commented on PR #22540: URL: https://github.com/apache/flink/pull/22540#issuecomment-1538433412 Thanks for taking this up! -- 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] [Closed] (FLINK-31660) flink-connectors-kafka ITCases are not runnable in the IDE

2023-05-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-31660. Fix Version/s: 1.17.1 Resolution: Fixed 1.17:

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

2023-05-08 Thread via GitHub
zentol commented on PR #22359: URL: https://github.com/apache/flink/pull/22359#issuecomment-1538424658 Oh wow it did actually merge it before but failed to close the PR :facepalm: -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

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

2023-05-08 Thread via GitHub
zentol commented on PR #22359: URL: https://github.com/apache/flink/pull/22359#issuecomment-1538423656 Good god what is github doing. First it breaks on the merge, now it arbitrarily closes the PR. -- This is an automated message from the Apache Git Service. To respond to the message,

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

2023-05-08 Thread via GitHub
zentol closed pull request #22359: [FLINK-31660][table] add jayway json path dependency to table-planner URL: https://github.com/apache/flink/pull/22359 -- 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-28744) Upgrade Calcite version to 1.31

2023-05-08 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720516#comment-17720516 ] Sergey Nuyanzin commented on FLINK-28744: - regarding {{NodeTypeHintPredicate}} it can not be

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

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

[GitHub] [flink-benchmarks] dependabot[bot] closed pull request #62: Bump protobuf-java from 3.11.4 to 3.16.3

2023-05-08 Thread via GitHub
dependabot[bot] closed pull request #62: Bump protobuf-java from 3.11.4 to 3.16.3 URL: https://github.com/apache/flink-benchmarks/pull/62 -- 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

[GitHub] [flink-benchmarks] dependabot[bot] closed pull request #61: Bump junit from 4.12 to 4.13.1

2023-05-08 Thread via GitHub
dependabot[bot] closed pull request #61: Bump junit from 4.12 to 4.13.1 URL: https://github.com/apache/flink-benchmarks/pull/61 -- 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-benchmarks] dependabot[bot] commented on pull request #61: Bump junit from 4.12 to 4.13.1

2023-05-08 Thread via GitHub
dependabot[bot] commented on PR #61: URL: https://github.com/apache/flink-benchmarks/pull/61#issuecomment-1538402838 Looks like junit:junit is up-to-date now, so this is no longer needed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-benchmarks] dependabot[bot] commented on pull request #62: Bump protobuf-java from 3.11.4 to 3.16.3

2023-05-08 Thread via GitHub
dependabot[bot] commented on PR #62: URL: https://github.com/apache/flink-benchmarks/pull/62#issuecomment-1538403226 Looks like com.google.protobuf:protobuf-java is up-to-date now, so this is no longer needed. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-benchmarks] dependabot[bot] commented on pull request #62: Bump protobuf-java from 3.11.4 to 3.16.3

2023-05-08 Thread via GitHub
dependabot[bot] commented on PR #62: URL: https://github.com/apache/flink-benchmarks/pull/62#issuecomment-1538403021 Looks like com.google.protobuf:protobuf-java is up-to-date now, so this is no longer needed. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-benchmarks] MartijnVisser commented on pull request #61: Bump junit from 4.12 to 4.13.1

2023-05-08 Thread via GitHub
MartijnVisser commented on PR #61: URL: https://github.com/apache/flink-benchmarks/pull/61#issuecomment-1538402386 @dependabot rebase -- 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

[GitHub] [flink-benchmarks] MartijnVisser commented on pull request #60: Bump libthrift from 0.13.0 to 0.14.0

2023-05-08 Thread via GitHub
MartijnVisser commented on PR #60: URL: https://github.com/apache/flink-benchmarks/pull/60#issuecomment-1538402620 @dependabot rebase -- 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

[GitHub] [flink-benchmarks] MartijnVisser commented on pull request #62: Bump protobuf-java from 3.11.4 to 3.16.3

2023-05-08 Thread via GitHub
MartijnVisser commented on PR #62: URL: https://github.com/apache/flink-benchmarks/pull/62#issuecomment-1538402180 @dependabot rebase -- 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

  1   2   >