[GitHub] [flink] huwh commented on pull request #22686: [FLINK-32225][Runtime] Executions in same Job use a shared TaskDeploymentDescriptorFactory.

2023-06-14 Thread via GitHub
huwh commented on PR #22686: URL: https://github.com/apache/flink/pull/22686#issuecomment-1592415971 @Thesharing, do you have any recommendations or concerns? I'd like to merge this so I can continue working on https://github.com/apache/flink/pull/22674. -- This is an automated

[GitHub] [flink-connector-jdbc] snuyanzin opened a new pull request, #60: [hotfix] Set fork count to 1 for IT cases

2023-06-14 Thread via GitHub
snuyanzin opened a new pull request, #60: URL: https://github.com/apache/flink-connector-jdbc/pull/60 By default it inherints `flink.forkCountITCase` == 2 from flink. The PR sets it to 1 it looks sqlserver container has issues with starting in several surefire forks... Based on

[GitHub] [flink] fredia commented on a diff in pull request #22744: [FLINK-29802][state] Changelog supports native savepoint

2023-06-14 Thread via GitHub
fredia commented on code in PR #22744: URL: https://github.com/apache/flink/pull/22744#discussion_r1230401732 ## flink-tests/src/test/java/org/apache/flink/test/state/ChangelogCompatibilityITCase.java: ## @@ -169,18 +160,32 @@ private String tryCheckpointAndStop(JobGraph

[GitHub] [flink] fredia commented on a diff in pull request #22744: [FLINK-29802][state] Changelog supports native savepoint

2023-06-14 Thread via GitHub
fredia commented on code in PR #22744: URL: https://github.com/apache/flink/pull/22744#discussion_r1230394122 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java: ## @@ -375,6 +378,49 @@ public

[GitHub] [flink] Tartarus0zm commented on a diff in pull request #22344: [FLINK-31721][core] Move JobStatusHook to flink-core module

2023-06-14 Thread via GitHub
Tartarus0zm commented on code in PR #22344: URL: https://github.com/apache/flink/pull/22344#discussion_r1230400637 ## flink-core/src/main/java/org/apache/flink/core/execution/JobStatusHook.java: ## @@ -16,7 +16,7 @@ * limitations under the License. */ -package

[GitHub] [flink] link3280 commented on pull request #19798: [FLINK-27299][Runtime/Configuration] flink parsing parameter bug fixed.

2023-06-14 Thread via GitHub
link3280 commented on PR #19798: URL: https://github.com/apache/flink/pull/19798#issuecomment-1592254363 I think we have a good reason to consider it as a bug: pyflink uses `#` as a separator in the configurations (e.g.

[jira] [Comment Edited] (FLINK-32341) Fix resource requirements rest API response empty result

2023-06-14 Thread chenyuexin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732625#comment-17732625 ] chenyuexin edited comment on FLINK-32341 at 6/15/23 2:32 AM: - I submitting

[GitHub] [flink] flinkbot commented on pull request #22785: [FLINK-32259]-table-Add-ARRAY_JOIN-function

2023-06-14 Thread via GitHub
flinkbot commented on PR #22785: URL: https://github.com/apache/flink/pull/22785#issuecomment-1592173099 ## CI report: * 7ab91efe41ee1acc9ac984d58f275efe830fe046 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32259) Add ARRAY_JOIN support in SQL & Table API

2023-06-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32259: --- Labels: pull-request-available (was: ) > Add ARRAY_JOIN support in SQL & Table API >

[GitHub] [flink] hanyuzheng7 opened a new pull request, #22785: [FLINK-32259]-table-Add-ARRAY_JOIN-function

2023-06-14 Thread via GitHub
hanyuzheng7 opened a new pull request, #22785: URL: https://github.com/apache/flink/pull/22785 ## What is the purpose of the change This is an implementation of ARRAY_JOIN ## Brief change log Returns a string that represents the concatenation of the elements in the given

[jira] [Closed] (FLINK-31233) no error should be logged when retrieving the task manager's stdout if it does not exist

2023-06-14 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-31233. -- Resolution: Fixed > no error should be logged when retrieving the task manager's stdout if it >

[jira] [Commented] (FLINK-31233) no error should be logged when retrieving the task manager's stdout if it does not exist

2023-06-14 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732803#comment-17732803 ] Yangze Guo commented on FLINK-31233: master: c418b57870aaf5b4f4f9d0f69a70366b583ae166

[GitHub] [flink] KarmaGYZ merged pull request #22137: [FLINK-31233][Rest] Return 404 when task manager stdout/log files not exist.

2023-06-14 Thread via GitHub
KarmaGYZ merged PR #22137: URL: https://github.com/apache/flink/pull/22137 -- 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:

[jira] [Comment Edited] (FLINK-32319) flink can't the partition of network after restart

2023-06-14 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732799#comment-17732799 ] wgcn edited comment on FLINK-32319 at 6/14/23 11:26 PM: Hi~[~Wencong Liu],I

[jira] [Commented] (FLINK-32319) flink can't the partition of network after restart

2023-06-14 Thread wgcn (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732799#comment-17732799 ] wgcn commented on FLINK-32319: -- Hi~[~Wencong Liu],I Increased taskmanager.network.request-backoff.max to

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

2023-06-14 Thread via GitHub
becketqin commented on code in PR #22509: URL: https://github.com/apache/flink/pull/22509#discussion_r1230258326 ## flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java: ## @@ -231,6 +231,27 @@ public class YarnConfigOptions {

[GitHub] [flink-connector-kafka] dependabot[bot] opened a new pull request, #33: Bump guava from 30.1.1-jre to 32.0.0-jre in /flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka

2023-06-14 Thread via GitHub
dependabot[bot] opened a new pull request, #33: URL: https://github.com/apache/flink-connector-kafka/pull/33 Bumps [guava](https://github.com/google/guava) from 30.1.1-jre to 32.0.0-jre. Release notes Sourced from https://github.com/google/guava/releases;>guava's releases.

[GitHub] [flink-connector-aws] dependabot[bot] opened a new pull request, #79: Bump guava from 29.0-jre to 32.0.0-jre

2023-06-14 Thread via GitHub
dependabot[bot] opened a new pull request, #79: URL: https://github.com/apache/flink-connector-aws/pull/79 Bumps [guava](https://github.com/google/guava) from 29.0-jre to 32.0.0-jre. Release notes Sourced from https://github.com/google/guava/releases;>guava's releases.

[GitHub] [flink-connector-hbase] ferenc-csaky opened a new pull request, #12: [FLINK-30349] Sync missing HBase e2e tests to external repo

2023-06-14 Thread via GitHub
ferenc-csaky opened a new pull request, #12: URL: https://github.com/apache/flink-connector-hbase/pull/12 Currently, the `hbase-1.4` connector test fails, cause the CP is messed up, but I need to track that down. There is room for improvement in the test setup, but Junit 5 does not allow

[GitHub] [flink] flinkbot commented on pull request #22784: Bump guava from 27.0.1-jre to 32.0.0-jre in /flink-formats/flink-orc

2023-06-14 Thread via GitHub
flinkbot commented on PR #22784: URL: https://github.com/apache/flink/pull/22784#issuecomment-1592076213 ## CI report: * 23140c38ebec878824e1d8cee4c7fbedbf7d9f94 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #22783: Bump guava from 27.0.1-jre to 32.0.0-jre in /flink-formats/flink-parquet

2023-06-14 Thread via GitHub
flinkbot commented on PR #22783: URL: https://github.com/apache/flink/pull/22783#issuecomment-1592072115 ## CI report: * 1fab531a76de8724103ecfc521f2ae64a7cf01ca UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dependabot[bot] opened a new pull request, #22784: Bump guava from 27.0.1-jre to 32.0.0-jre in /flink-formats/flink-orc

2023-06-14 Thread via GitHub
dependabot[bot] opened a new pull request, #22784: URL: https://github.com/apache/flink/pull/22784 Bumps [guava](https://github.com/google/guava) from 27.0.1-jre to 32.0.0-jre. Release notes Sourced from https://github.com/google/guava/releases;>guava's releases. 32.0.0

[GitHub] [flink] dependabot[bot] opened a new pull request, #22783: Bump guava from 27.0.1-jre to 32.0.0-jre in /flink-formats/flink-parquet

2023-06-14 Thread via GitHub
dependabot[bot] opened a new pull request, #22783: URL: https://github.com/apache/flink/pull/22783 Bumps [guava](https://github.com/google/guava) from 27.0.1-jre to 32.0.0-jre. Release notes Sourced from https://github.com/google/guava/releases;>guava's releases. 32.0.0

[GitHub] [flink] ColtenP commented on pull request #22782: [FLINK-32034][python] Updated GET_SITE_PACKAGES_SCRIPT to remove distutils dependency

2023-06-14 Thread via GitHub
ColtenP commented on PR #22782: URL: https://github.com/apache/flink/pull/22782#issuecomment-1592058741 @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] flinkbot commented on pull request #22782: [FLINK-32034][python] Updated GET_SITE_PACKAGES_SCRIPT to remove distutils dependency

2023-06-14 Thread via GitHub
flinkbot commented on PR #22782: URL: https://github.com/apache/flink/pull/22782#issuecomment-1591930074 ## CI report: * 481b4232b1e1fa4bdc4aa0874e9887b01918528c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2023-06-14 Thread Colten Pilgreen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732746#comment-17732746 ] Colten Pilgreen commented on FLINK-32034: - [~dianfu] -

[GitHub] [flink] ColtenP commented on pull request #22782: [FLINK-32034][python] Updated GET_SITE_PACKAGES_SCRIPT to remove distutils dependency

2023-06-14 Thread via GitHub
ColtenP commented on PR #22782: URL: https://github.com/apache/flink/pull/22782#issuecomment-1591923753 @dianfu - Here is the request to fix the reported issue [FLINK-32034](https://issues.apache.org/jira/browse/FLINK-32034). -- This is an automated message from the Apache Git Service.

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

2023-06-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32034: --- Labels: pull-request-available (was: ) > Python's DistUtils is deprecated as of 3.10 >

[GitHub] [flink] ColtenP opened a new pull request, #22782: [FLINK-32034][python] Updated GET_SITE_PACKAGES_SCRIPT to remove distutils dependency

2023-06-14 Thread via GitHub
ColtenP opened a new pull request, #22782: URL: https://github.com/apache/flink/pull/22782 ## What is the purpose of the change Distutils is deprecated in pythons version 3.10 and above, this script provides the same functionality and works with all the supported python version of

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

2023-06-14 Thread Colten Pilgreen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732731#comment-17732731 ] Colten Pilgreen commented on FLINK-32034: - [~dianfu] - Yep, I sure can do that. PR incoming

[GitHub] [flink] StefanRRichter merged pull request #22771: [FLINK-32326][state] Disable WAL in RocksDBWriteBatchWrapper by default.

2023-06-14 Thread via GitHub
StefanRRichter merged PR #22771: URL: https://github.com/apache/flink/pull/22771 -- 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:

[jira] [Commented] (FLINK-32341) Fix resource requirements rest API response empty result

2023-06-14 Thread chenyuexin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732625#comment-17732625 ] chenyuexin commented on FLINK-32341: I submitting the official example demo job by standalone

[jira] [Commented] (FLINK-32341) Fix resource requirements rest API response empty result

2023-06-14 Thread chenyuexin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732620#comment-17732620 ] chenyuexin commented on FLINK-32341: I submitting the official example demo job by standalone

[jira] (FLINK-32341) Fix resource requirements rest API response empty result

2023-06-14 Thread chenyuexin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32341 ] chenyuexin deleted comment on FLINK-32341: was (Author: JIRAUSER295713): I submitting the official example demo job by standalone deployment, the start shell commands for JM and TM are as

[jira] [Comment Edited] (FLINK-32341) Fix resource requirements rest API response empty result

2023-06-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732611#comment-17732611 ] Chesnay Schepler edited comment on FLINK-32341 at 6/14/23 4:24 PM: ---

[jira] [Commented] (FLINK-32341) Fix resource requirements rest API response empty result

2023-06-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732611#comment-17732611 ] Chesnay Schepler commented on FLINK-32341: -- What kind of job are you submitting? I'm reasonable

[GitHub] [flink] flinkbot commented on pull request #22781: [FLINK-32341] [Runtime / REST] Fix resource requirements rest API response empty result

2023-06-14 Thread via GitHub
flinkbot commented on PR #22781: URL: https://github.com/apache/flink/pull/22781#issuecomment-1591559680 ## CI report: * 128d74698093146bbb385715c0866a0fb1d335a6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32341) Fix resource requirements rest API response empty result

2023-06-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32341: --- Labels: pull-request-available (was: ) > Fix resource requirements rest API response

[GitHub] [flink] chachae opened a new pull request, #22781: [FLINK-32341] [Runtime / REST] Fix resource requirements rest API response empty result

2023-06-14 Thread via GitHub
chachae opened a new pull request, #22781: URL: https://github.com/apache/flink/pull/22781 link to [FLINK-32341](https://issues.apache.org/jira/browse/FLINK-32341) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Created] (FLINK-32341) Fix resource requirements rest API response empty result

2023-06-14 Thread chenyuexin (Jira)
chenyuexin created FLINK-32341: -- Summary: Fix resource requirements rest API response empty result Key: FLINK-32341 URL: https://issues.apache.org/jira/browse/FLINK-32341 Project: Flink Issue

[jira] [Updated] (FLINK-32340) NPE in K8s operator which brakes current and subsequent deployments

2023-06-14 Thread Sergii Nazarov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergii Nazarov updated FLINK-32340: --- Description: Prerequisites: * Deployment via Apache Flink Kubernetes operator with version

[GitHub] [flink] hanyuzheng7 commented on pull request #22717: [FLINK-31665] [table] Add ARRAY_CONCAT function

2023-06-14 Thread via GitHub
hanyuzheng7 commented on PR #22717: URL: https://github.com/apache/flink/pull/22717#issuecomment-1591459045 @snuyanzin Do you think it is ok for merge now? -- 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

[GitHub] [flink] hanyuzheng7 commented on pull request #22717: [FLINK-31665] [table] Add ARRAY_CONCAT function

2023-06-14 Thread via GitHub
hanyuzheng7 commented on PR #22717: URL: https://github.com/apache/flink/pull/22717#issuecomment-1591455480 Hi, @snuyanzin. Thank you for your comments. As first PR, thank you for your help, and let learn a lot. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] hanyuzheng7 commented on pull request #22717: [FLINK-31665] [table] Add ARRAY_CONCAT function

2023-06-14 Thread via GitHub
hanyuzheng7 commented on PR #22717: URL: https://github.com/apache/flink/pull/22717#issuecomment-1591424654 @snuyanzin Thank you for your help, I have already fixed it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-32340) NPE in K8s operator which brakes current and subsequent deployments

2023-06-14 Thread Sergii Nazarov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergii Nazarov updated FLINK-32340: --- Description: Prerequisites: * Deployment via Apache Flink Kubernetes operator with version

[jira] [Created] (FLINK-32340) NPE in K8s operator which brakes current and subsequent deployments

2023-06-14 Thread Sergii Nazarov (Jira)
Sergii Nazarov created FLINK-32340: -- Summary: NPE in K8s operator which brakes current and subsequent deployments Key: FLINK-32340 URL: https://issues.apache.org/jira/browse/FLINK-32340 Project:

[jira] [Updated] (FLINK-31782) Make DefaultLeaderElectionService implement MultipleComponentLeaderElectionService.Listener

2023-06-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31782: --- Labels: pull-request-available (was: ) > Make DefaultLeaderElectionService implement >

[GitHub] [flink] XComp commented on pull request #22640: [FLINK-31782][runtime] Makes DefaultLeaderElectionService implement MultipleComponentLeaderElectionDriver.Listener

2023-06-14 Thread via GitHub
XComp commented on PR #22640: URL: https://github.com/apache/flink/pull/22640#issuecomment-1591349303 > I don't really follow the UUID change. If the multiCLES got by without it so far, what do we need it for now? > > the HA backend should be the owner of the session ID: Theoretically,

[GitHub] [flink] WencongLiu commented on pull request #22733: [FLINK-31642][network] Introduce the MemoryTierConsumerAgent

2023-06-14 Thread via GitHub
WencongLiu commented on PR #22733: URL: https://github.com/apache/flink/pull/22733#issuecomment-1591241912 Thanks for the carefully review. I've updated the `TieredStorageNettyServiceImpl`. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] zentol commented on a diff in pull request #22601: [FLINK-31781][runtime] Introduces the contender ID to the LeaderElectionService interface

2023-06-14 Thread via GitHub
zentol commented on code in PR #22601: URL: https://github.com/apache/flink/pull/22601#discussion_r1229632471 ## flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java: ## @@ -247,7 +247,7 @@ private LeaderElection

[jira] [Closed] (FLINK-32331) Print JVM thread dumps when Github Actions workflow gets cancelled/times out

2023-06-14 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32331. -- Resolution: Fixed Fixed in apache/flink-connector-shared-utils@ci_utils:

[GitHub] [flink-connector-shared-utils] MartijnVisser merged pull request #15: [FLINK-32331][Build System] Enable printing of thread dumps in the CI

2023-06-14 Thread via GitHub
MartijnVisser merged PR #15: URL: https://github.com/apache/flink-connector-shared-utils/pull/15 -- 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:

[jira] [Commented] (FLINK-31856) Add support for Opensearch Connector REST client customization

2023-06-14 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732537#comment-17732537 ] Andriy Redko commented on FLINK-31856: -- Thanks [~mhjtrifork] , made it in, should be easier to

[jira] [Closed] (FLINK-24881) When the Source is back pressured, the checkpoint interval may not take effect

2023-06-14 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24881. -- Resolution: Not A Bug Hi, sorry for a late response, I have just stumbled across this ticket.

[jira] [Updated] (FLINK-32040) The WatermarkStrategy defined with the Function(with_idleness) report an error

2023-06-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-32040: Affects Version/s: 1.17.0 1.16.0 > The WatermarkStrategy defined with the

[jira] [Commented] (FLINK-32040) The WatermarkStrategy defined with the Function(with_idleness) report an error

2023-06-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732524#comment-17732524 ] Dian Fu commented on FLINK-32040: - Good catch! I think you are right that this is a bug. cc [~Juntao Hu] 

[GitHub] [flink] XComp commented on pull request #22642: [FLINK-32177][runtime] Refactors MultipleComponentLeaderElectionDriver.Listener.notifyAllKnownLeaderInformation signature

2023-06-14 Thread via GitHub
XComp commented on PR #22642: URL: https://github.com/apache/flink/pull/22642#issuecomment-1591155371 Rebased on FLINK-31781 to include the libssl fix from master and the format fix -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-32177) Refactor MultipleComponentLeaderElectionDriver.Listener.notifyAllKnownLeaderInformation(Collection)

2023-06-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32177: --- Labels: pull-request-available (was: ) > Refactor >

[jira] [Updated] (FLINK-32040) The WatermarkStrategy defined with the Function(with_idleness) report an error

2023-06-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-32040: Priority: Major (was: Blocker) > The WatermarkStrategy defined with the Function(with_idleness) report

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

2023-06-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732518#comment-17732518 ] Dian Fu commented on FLINK-32034: - [~coltenp] Thanks for reporting this issue and the finding. Would you

[jira] [Closed] (FLINK-32207) Error import Pyflink.table.descriptors due to python3.10 version mismatch

2023-06-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-32207. --- Resolution: Duplicate > Error import Pyflink.table.descriptors due to python3.10 version mismatch >

[jira] [Commented] (FLINK-32207) Error import Pyflink.table.descriptors due to python3.10 version mismatch

2023-06-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732515#comment-17732515 ] Dian Fu commented on FLINK-32207: - This seems duplicate with FLINK-32206. Closing this ticket~. Feel

[GitHub] [flink] XComp commented on a diff in pull request #22601: [FLINK-31781][runtime] Introduces the contender ID to the LeaderElectionService interface

2023-06-14 Thread via GitHub
XComp commented on code in PR #22601: URL: https://github.com/apache/flink/pull/22601#discussion_r1229545380 ## flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java: ## @@ -247,7 +247,7 @@ private LeaderElection

[jira] [Commented] (FLINK-32206) ModuleNotFoundError for Pyflink.table.descriptors wheel version mismatch

2023-06-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732513#comment-17732513 ] Dian Fu commented on FLINK-32206: -  'Kafka' has already been removed from 'pyflink.table.descriptors'. I

[GitHub] [flink] huwh commented on pull request #22137: [FLINK-31233][Rest] Return 404 when task manager stdout/log files not exist.

2023-06-14 Thread via GitHub
huwh commented on PR #22137: URL: https://github.com/apache/flink/pull/22137#issuecomment-1591105458 @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. To

[jira] [Resolved] (FLINK-31916) Python API only respects deprecated env.java.opts key

2023-06-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu resolved FLINK-31916. - Resolution: Fixed Merged to master via 626d70d86d3bee944edf548606b38042f31e09b6 > Python API only

[GitHub] [flink] dianfu merged pull request #22776: [FLINK-31916][python] Respect 'env.java.opts.all'

2023-06-14 Thread via GitHub
dianfu merged PR #22776: URL: https://github.com/apache/flink/pull/22776 -- 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:

[GitHub] [flink] XComp commented on a diff in pull request #22601: [FLINK-31781][runtime] Introduces the contender ID to the LeaderElectionService interface

2023-06-14 Thread via GitHub
XComp commented on code in PR #22601: URL: https://github.com/apache/flink/pull/22601#discussion_r1229512559 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/AbstractLeaderElectionService.java: ## @@ -27,29 +27,37 @@ public abstract class

[GitHub] [flink] XComp commented on a diff in pull request #22601: [FLINK-31781][runtime] Introduces the contender ID to the LeaderElectionService interface

2023-06-14 Thread via GitHub
XComp commented on code in PR #22601: URL: https://github.com/apache/flink/pull/22601#discussion_r1229501119 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/AbstractLeaderElectionService.java: ## @@ -27,29 +27,37 @@ public abstract class

[GitHub] [flink-kubernetes-operator] ashangit opened a new pull request, #621: [FLINK-32334] Also check if no taskmanager are running while waiting for cluster shutdown

2023-06-14 Thread via GitHub
ashangit opened a new pull request, #621: URL: https://github.com/apache/flink-kubernetes-operator/pull/621 ## What is the purpose of the change This pull request add a check to ensure that no TaskManager pods are running while waiting for cluster shutdown. With standalone

[jira] [Updated] (FLINK-32334) Operator failed to create taskmanager deployment because it already exist

2023-06-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32334: --- Labels: pull-request-available (was: ) > Operator failed to create taskmanager deployment

[GitHub] [flink] XComp commented on pull request #22404: [FLINK-31797][runtime] Moves LeaderElection creation into HighAvailabilityServices

2023-06-14 Thread via GitHub
XComp commented on PR #22404: URL: https://github.com/apache/flink/pull/22404#issuecomment-1591051518 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 comment. To

[jira] [Commented] (FLINK-32339) Align lock usage in DefaultLeaderElectionService

2023-06-14 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732495#comment-17732495 ] Matthias Pohl commented on FLINK-32339: --- But I'm still not 100% sure whether it will help: The

[GitHub] [flink] huwh commented on pull request #22137: [FLINK-31233][Rest] Return 404 when task manager stdout/log files not exist.

2023-06-14 Thread via GitHub
huwh commented on PR #22137: URL: https://github.com/apache/flink/pull/22137#issuecomment-1591025199 Thanks, unit tests have been fixed. `testStdoutFileHandlerHandleFileNotFoundException` failed because `TestingChannelHandlerContext#write` return an unfinished future. Since we

[jira] [Updated] (FLINK-32339) Align lock usage in DefaultLeaderElectionService

2023-06-14 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32339: -- Description: {{DefaultLeaderElectionService}} uses sequential execution through a single

[GitHub] [flink] flinkbot commented on pull request #22780: [FLINK-32338][build] Add FailsOnJava17 annotation

2023-06-14 Thread via GitHub
flinkbot commented on PR #22780: URL: https://github.com/apache/flink/pull/22780#issuecomment-1591022893 ## CI report: * 0fb564b8cdda9468405bdbc24f2e0f9ee5e0bbf8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-32339) Align lock usage in DefaultLeaderElectionService

2023-06-14 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32339: - Summary: Align lock usage in DefaultLeaderElectionService Key: FLINK-32339 URL: https://issues.apache.org/jira/browse/FLINK-32339 Project: Flink Issue

[jira] [Updated] (FLINK-32338) Add FailsOnJava17 annotation

2023-06-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32338: --- Labels: pull-request-available (was: ) > Add FailsOnJava17 annotation >

[GitHub] [flink] zentol opened a new pull request, #22780: [FLINK-32338][build] Add FailsOnJava17 annotation

2023-06-14 Thread via GitHub
zentol opened a new pull request, #22780: URL: https://github.com/apache/flink/pull/22780 Adds an annotation for disabling tests on Java 17, similar to `FailsOnJava11`, and sets up the test exclusion in maven. This annotation won't be used that much; probably only a 1 or 2 tests will

[GitHub] [flink] flinkbot commented on pull request #22779: [FLINK-32337][table] ARRAY_UNION's element getter should respect not only first arg's nullability

2023-06-14 Thread via GitHub
flinkbot commented on PR #22779: URL: https://github.com/apache/flink/pull/22779#issuecomment-1591006718 ## CI report: * 8d44eec94d767591d3bf968db5582da3543681f6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-31878) Fix the wrong name of PauseOrResumeSplitsTask#toString in connector fetcher

2023-06-14 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732491#comment-17732491 ] Matthias Pohl edited comment on FLINK-31878 at 6/14/23 11:23 AM: - I

[jira] [Commented] (FLINK-31878) Fix the wrong name of PauseOrResumeSplitsTask#toString in connector fetcher

2023-06-14 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732491#comment-17732491 ] Matthias Pohl commented on FLINK-31878: --- I accidentally added FLINK-31878 as the Jira issue to a

[GitHub] [flink] snuyanzin opened a new pull request, #22779: [FLINK-32337][table] ARRAY_UNION's element getter should respect not only first arg's nullability

2023-06-14 Thread via GitHub
snuyanzin opened a new pull request, #22779: URL: https://github.com/apache/flink/pull/22779 ## What is the purpose of the change The problem case for `array_union` is ```sql SELECT array_union(ARRAY[CAST(NULL AS INT)], ARRAY[1]); -- returns [NULL, 1], this is OK SELECT

[jira] [Updated] (FLINK-32337) SQL array_union could return wrong result

2023-06-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32337: --- Labels: pull-request-available (was: ) > SQL array_union could return wrong result >

[jira] [Created] (FLINK-32338) Add FailsOnJava17 annotation

2023-06-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32338: Summary: Add FailsOnJava17 annotation Key: FLINK-32338 URL: https://issues.apache.org/jira/browse/FLINK-32338 Project: Flink Issue Type: Sub-task

[GitHub] [flink] zentol commented on pull request #22738: [FLINK-32290][dist] Enable -XX:+IgnoreUnrecognizedVMOptions

2023-06-14 Thread via GitHub
zentol commented on PR #22738: URL: https://github.com/apache/flink/pull/22738#issuecomment-1590991638 > Ok, with that one I'm wondering how you identified all the places where the parameter should be set. For Java 17 we have to add `add-opens/add-exports` JVM arguments for any

[jira] [Created] (FLINK-32337) SQL array_union could return wrong result

2023-06-14 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32337: --- Summary: SQL array_union could return wrong result Key: FLINK-32337 URL: https://issues.apache.org/jira/browse/FLINK-32337 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #22778: [FLINK-32336][tests] PartitionITCase#ComparablePojo now public

2023-06-14 Thread via GitHub
flinkbot commented on PR #22778: URL: https://github.com/apache/flink/pull/22778#issuecomment-1590984725 ## CI report: * a6d7491c7fdaffe98afc964c4d08e7952bd8abf2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32336) PartitionITCase#ComparablePojo should be public

2023-06-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32336: --- Labels: pull-request-available (was: ) > PartitionITCase#ComparablePojo should be public >

[GitHub] [flink] zentol opened a new pull request, #22778: [FLINK-32336][tests] PartitionITCase#ComparablePojo now public

2023-06-14 Thread via GitHub
zentol opened a new pull request, #22778: URL: https://github.com/apache/flink/pull/22778 POJOs should be public so they are serialized with the pojo serializer. The modification to the `MinMaxSelector` is necessary because by being treated as a pojo the partitioning is being

[jira] [Created] (FLINK-32336) PartitionITCase#ComparablePojo should be public

2023-06-14 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-32336: Summary: PartitionITCase#ComparablePojo should be public Key: FLINK-32336 URL: https://issues.apache.org/jira/browse/FLINK-32336 Project: Flink

[jira] [Assigned] (FLINK-32334) Operator failed to create taskmanager deployment because it already exist

2023-06-14 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-32334: -- Assignee: Nicolas Fraison > Operator failed to create taskmanager deployment because it

[GitHub] [flink] snuyanzin commented on pull request #22717: [FLINK-31665] [table] Add ARRAY_CONCAT function

2023-06-14 Thread via GitHub
snuyanzin commented on PR #22717: URL: https://github.com/apache/flink/pull/22717#issuecomment-1590918465 ```sql SELECT array_concat(ARRAY[CAST(NULL AS INT)], ARRAY[1]); -- returns [NULL, 1], this is OK SELECT array_concat(ARRAY[1], ARRAY[CAST(NULL AS INT)]); -- returns [1, 0], this

[GitHub] [flink-connector-shared-utils] MartijnVisser commented on pull request #15: [FLINK-32331][Build System] Enable printing of thread dumps in the CI

2023-06-14 Thread via GitHub
MartijnVisser commented on PR #15: URL: https://github.com/apache/flink-connector-shared-utils/pull/15#issuecomment-1590864111 > to sleep eternally and reduce the CI timeout to some reasonably low value? Yes, but that will mean that CI will always fail for these tests, right? For

[jira] [Commented] (FLINK-32334) Operator failed to create taskmanager deployment because it already exist

2023-06-14 Thread Nicolas Fraison (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732475#comment-17732475 ] Nicolas Fraison commented on FLINK-32334: - I can see in the log that we have wait once and then

[jira] [Closed] (FLINK-24998) SIGSEGV in Kryo / C2 CompilerThread on Java 17

2023-06-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24998. Fix Version/s: 1.18.0 Resolution: Fixed > SIGSEGV in Kryo / C2 CompilerThread on

[jira] [Commented] (FLINK-24998) SIGSEGV in Kryo / C2 CompilerThread on Java 17

2023-06-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732473#comment-17732473 ] Chesnay Schepler commented on FLINK-24998: -- CI image updated on master:

[jira] [Reopened] (FLINK-24998) SIGSEGV in Kryo / C2 CompilerThread on Java 17

2023-06-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-24998: -- > SIGSEGV in Kryo / C2 CompilerThread on Java 17 >

[jira] [Comment Edited] (FLINK-24998) SIGSEGV in Kryo / C2 CompilerThread on Java 17

2023-06-14 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732473#comment-17732473 ] Chesnay Schepler edited comment on FLINK-24998 at 6/14/23 9:44 AM: ---

[GitHub] [flink] zentol merged pull request #22737: [FLINK-24998] Update CI image

2023-06-14 Thread via GitHub
zentol merged PR #22737: URL: https://github.com/apache/flink/pull/22737 -- 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:

  1   2   >