[jira] [Commented] (FLINK-34273) git fetch fails

2024-03-25 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830798#comment-17830798 ] Weijie Guo commented on FLINK-34273:

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-03-25 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830797#comment-17830797 ] Weijie Guo commented on FLINK-34643:

Re: [PR] [FLINK-33982][core] Introduce new config options for Batch Job Recovery [flink]

2024-03-25 Thread via GitHub
zhuzhurk commented on code in PR #24026: URL: https://github.com/apache/flink/pull/24026#discussion_r1538557863 ## flink-core/src/main/java/org/apache/flink/configuration/BatchExecutionOptions.java: ## @@ -148,6 +148,30 @@ public class BatchExecutionOptions {

[jira] [Commented] (FLINK-34925) FlinkCDC 3.0 for extracting data from sqlserver, errors occur

2024-03-25 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830794#comment-17830794 ] 宇宙先生 commented on FLINK-34925: -- [~loserwang1024] Maybe,I dont konw how to resolve it, and why.if u have any 

[jira] [Updated] (FLINK-34935) TIMESTAMP_LTZ type Unsupported when using JdbcCatalog to read from Postgres

2024-03-25 Thread Du Yuzhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Du Yuzhou updated FLINK-34935: -- Description: When I use JdbcCatalog to select from postgres table, it throw Exception: {code:java}

[jira] [Created] (FLINK-34935) TIMESTAMP_LTZ type Unsupported when using JdbcCatalog to read from Postgres

2024-03-25 Thread Du Yuzhou (Jira)
Du Yuzhou created FLINK-34935: - Summary: TIMESTAMP_LTZ type Unsupported when using JdbcCatalog to read from Postgres Key: FLINK-34935 URL: https://issues.apache.org/jira/browse/FLINK-34935 Project: Flink

Re: [PR] [FLINK-34537] Autoscaler JDBC Support HikariPool [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
1996fanrui commented on code in PR #785: URL: https://github.com/apache/flink-kubernetes-operator/pull/785#discussion_r1538587604 ## flink-autoscaler/pom.xml: ## @@ -57,6 +57,18 @@ under the License. org.quartz-scheduler quartz

Re: [PR] [FLINK-34668][checkpoint] Report state handle of file merging directory to JM [flink]

2024-03-25 Thread via GitHub
fredia commented on code in PR #24513: URL: https://github.com/apache/flink/pull/24513#discussion_r1538563101 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/filemerging/EmptyFileMergingOperatorStreamStateHandle.java: ## @@ -0,0 +1,64 @@ +/* + * Licensed to the

Re: [PR] [FLINK-34668][checkpoint] Report state handle of file merging directory to JM [flink]

2024-03-25 Thread via GitHub
fredia commented on code in PR #24513: URL: https://github.com/apache/flink/pull/24513#discussion_r1538560216 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackendSnapshotStrategy.java: ## @@ -204,7 +217,17 @@ public SnapshotResultSupplier

[jira] [Assigned] (FLINK-33984) Introduce SupportsBatchSnapshot for operator coordinator

2024-03-25 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-33984: --- Assignee: Junrui Li > Introduce SupportsBatchSnapshot for operator coordinator >

[jira] [Assigned] (FLINK-33985) Support obtain all partitions existing in cluster through ShuffleMaster.

2024-03-25 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-33985: --- Assignee: Junrui Li > Support obtain all partitions existing in cluster through ShuffleMaster. >

[jira] [Assigned] (FLINK-33982) Introduce new config options for Batch Job Recovery

2024-03-25 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-33982: --- Assignee: Junrui Li > Introduce new config options for Batch Job Recovery >

[jira] [Updated] (FLINK-33892) FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs

2024-03-25 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-33892: Summary: FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs (was: FLIP-383: Support

Re: [PR] [FLINK-34934] Translation Flink-Kubernetes-Operator document framework construction [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
caicancai commented on PR #805: URL: https://github.com/apache/flink-kubernetes-operator/pull/805#issuecomment-2019328144 > Thanks @caicancai for the contribution! > > This PR didn't add the Chinese version and English version in this PR, right? > >

[jira] [Assigned] (FLINK-34934) Translation Flink-Kubernetes-Operator document framework construction

2024-03-25 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34934: --- Assignee: Caican Cai > Translation Flink-Kubernetes-Operator document framework construction >

Re: [PR] [FLINK-34934] Translation Flink-Kubernetes-Operator document framework construction [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
1996fanrui commented on PR #805: URL: https://github.com/apache/flink-kubernetes-operator/pull/805#issuecomment-2019311986 Thanks @caicancai for the contribution! This PR didn't add the Chinese version and English version in this PR, right?

Re: [PR] [FLINK-34934] Translation Flink-Kubernetes-Operator document framework construction [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
caicancai commented on PR #805: URL: https://github.com/apache/flink-kubernetes-operator/pull/805#issuecomment-2019292942 cc @1996fanrui -- 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

Re: [PR] [FLINK-34537] Autoscaler JDBC Support HikariPool [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
czy006 commented on code in PR #785: URL: https://github.com/apache/flink-kubernetes-operator/pull/785#discussion_r1538521734 ## flink-autoscaler-standalone/pom.xml: ## @@ -133,6 +133,12 @@ under the License. ${log4j.version} + +

Re: [PR] [FLINK-34537] Autoscaler JDBC Support HikariPool [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
czy006 commented on code in PR #785: URL: https://github.com/apache/flink-kubernetes-operator/pull/785#discussion_r1538520848 ## flink-autoscaler/pom.xml: ## @@ -57,6 +57,18 @@ under the License. org.quartz-scheduler quartz

Re: [PR] [FLINK-34934] Translation Flink-Kubernetes-Operator document framework construction [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
caicancai commented on PR #805: URL: https://github.com/apache/flink-kubernetes-operator/pull/805#issuecomment-2019285783 This is a PR to build a translation framework. After the subsequent merger, I will translate the documents one by one. Thank you. -- This is an automated message

Re: [PR] [FLINK-34668][checkpoint] Report state handle of file merging directory to JM [flink]

2024-03-25 Thread via GitHub
Zakelly commented on code in PR #24513: URL: https://github.com/apache/flink/pull/24513#discussion_r1538512841 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackendSnapshotStrategy.java: ## @@ -204,7 +217,17 @@ public SnapshotResultSupplier

Re: [PR] [FLINK-34927] Translate concepts of Flink-Kubernetes-Operator documentation [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
caicancai closed pull request #804: [FLINK-34927] Translate concepts of Flink-Kubernetes-Operator documentation URL: https://github.com/apache/flink-kubernetes-operator/pull/804 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-34934) Translation Flink-Kubernetes-Operator document framework construction

2024-03-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34934: --- Labels: pull-request-available (was: ) > Translation Flink-Kubernetes-Operator document

[PR] [FLINK-34934] Translation Flink-Kubernetes-Operator document framework construction [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
caicancai opened a new pull request, #805: URL: https://github.com/apache/flink-kubernetes-operator/pull/805 …k construction ## What is the purpose of the change *(For example: This pull request adds a new feature to periodically create and maintain savepoints through

[jira] [Created] (FLINK-34934) Translation Flink-Kubernetes-Operator document framework construction

2024-03-25 Thread Caican Cai (Jira)
Caican Cai created FLINK-34934: -- Summary: Translation Flink-Kubernetes-Operator document framework construction Key: FLINK-34934 URL: https://issues.apache.org/jira/browse/FLINK-34934 Project: Flink

Re: [PR] [FLINK-34537] Autoscaler JDBC Support HikariPool [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
1996fanrui commented on code in PR #785: URL: https://github.com/apache/flink-kubernetes-operator/pull/785#discussion_r1538509399 ## flink-autoscaler/pom.xml: ## @@ -57,6 +57,18 @@ under the License. org.quartz-scheduler quartz

[jira] [Commented] (FLINK-34925) FlinkCDC 3.0 for extracting data from sqlserver, errors occur

2024-03-25 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830759#comment-17830759 ] Hongshun Wang commented on FLINK-34925: --- [~gongzhongqiang] , CC, I am not familiar with Sqlserver.

[jira] [Commented] (FLINK-34925) FlinkCDC 3.0 for extracting data from sqlserver, errors occur

2024-03-25 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830750#comment-17830750 ] 宇宙先生 commented on FLINK-34925: --   thanks for ur replay again.  my table  DDL sql is     SET ANSI_NULLS ON

Re: [PR] [FLINK-34903][MySQL][Feature] Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables [flink-cdc]

2024-03-25 Thread via GitHub
laglangyue commented on code in PR #3186: URL: https://github.com/apache/flink-cdc/pull/3186#discussion_r1538466758 ## docs/content.zh/docs/connectors/mysql.md: ## @@ -202,6 +202,15 @@ pipeline: Integer 连接池大小。 + + table.exclude.list Review Comment:

Re: [PR] [FLINK-34903][MySQL][Feature] Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables [flink-cdc]

2024-03-25 Thread via GitHub
laglangyue commented on code in PR #3186: URL: https://github.com/apache/flink-cdc/pull/3186#discussion_r1538466758 ## docs/content.zh/docs/connectors/mysql.md: ## @@ -202,6 +202,15 @@ pipeline: Integer 连接池大小。 + + table.exclude.list Review Comment:

Re: [PR] [FLINK-34903][MySQL][Feature] Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables [flink-cdc]

2024-03-25 Thread via GitHub
laglangyue commented on code in PR #3186: URL: https://github.com/apache/flink-cdc/pull/3186#discussion_r1538466605 ##

Re: [PR] [FLINK-33805] Implement restore tests for OverAggregate node [flink]

2024-03-25 Thread via GitHub
flinkbot commented on PR #24565: URL: https://github.com/apache/flink/pull/24565#issuecomment-2019100691 ## CI report: * 770cbd0e97c522818154361555862d4ef59f1bbf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33805) Implement restore tests for OverAggregate node

2024-03-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33805: --- Labels: pull-request-available (was: ) > Implement restore tests for OverAggregate node >

[PR] [FLINK-33805] Implement restore tests for OverAggregate node [flink]

2024-03-25 Thread via GitHub
jnh5y opened a new pull request, #24565: URL: https://github.com/apache/flink/pull/24565 ## What is the purpose of the change Implement restore tests for OverAggregate node. ## Verifying this change This change added tests and can be verified as follows: * Added

[jira] [Assigned] (FLINK-32198) Enforce single maxExceptions query parameter

2024-03-25 Thread Panagiotis Garefalakis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Panagiotis Garefalakis reassigned FLINK-32198: -- Assignee: Panagiotis Garefalakis > Enforce single maxExceptions

[jira] [Updated] (FLINK-33121) Failed precondition in JobExceptionsHandler due to concurrent global failures

2024-03-25 Thread Panagiotis Garefalakis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Panagiotis Garefalakis updated FLINK-33121: --- Description: We make the assumption that Global Failures (with null Task

Re: [PR] [FLINK-34924][table] Support partition pushdown for join queries [flink]

2024-03-25 Thread via GitHub
jeyhunkarimov commented on PR #24559: URL: https://github.com/apache/flink/pull/24559#issuecomment-2018931477 Hi @libenchao could you please review this PR in you available time? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-34633][table] Support unnesting array constants [flink]

2024-03-25 Thread via GitHub
jeyhunkarimov commented on PR #24510: URL: https://github.com/apache/flink/pull/24510#issuecomment-2018929843 Hi @LadyForest can you please review this PR? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [FLINK-34444] Initial implementation of JM operator metric rest api [flink]

2024-03-25 Thread via GitHub
flinkbot commented on PR #24564: URL: https://github.com/apache/flink/pull/24564#issuecomment-2018770217 ## CI report: * e9242629510a491852239ece44a546d3ffbffd85 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

2024-03-25 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830674#comment-17830674 ] Mason Chen commented on FLINK-34445: [~ruanhang1993] I believe you expressed some interest in this

Re: [PR] [FLINK-34444] Initial implementation of JM operator metric rest api [flink]

2024-03-25 Thread via GitHub
mas-chen commented on PR #24564: URL: https://github.com/apache/flink/pull/24564#issuecomment-2018765151 cc: @ruanhang1993 @afedulov @mxm would you like to take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-34444) Add new endpoint handler to flink

2024-03-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3: --- Labels: pull-request-available (was: ) > Add new endpoint handler to flink >

[PR] [FLINK-34444] Initial implementation of JM operator metric rest api [flink]

2024-03-25 Thread via GitHub
mas-chen opened a new pull request, #24564: URL: https://github.com/apache/flink/pull/24564 ## What is the purpose of the change Expose JobmanagerOperatorMetrics via REST API:

[jira] [Commented] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails

2024-03-25 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830640#comment-17830640 ] Jim Hughes commented on FLINK-34513: >From looking at this quickly, here are some notes: First,

Re: [PR] [FLINK-33376][coordination] Extend ZooKeeper Curator configurations [flink]

2024-03-25 Thread via GitHub
flinkbot commented on PR #24563: URL: https://github.com/apache/flink/pull/24563#issuecomment-2018447222 ## CI report: * 1bd4705526fd452c4e793bef4e9bfa2557641d7e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Closed] (FLINK-33900) Multiple failures in WindowRankITCase due to NoResourceAvailableException

2024-03-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-33900. - Resolution: Duplicate I checked for the failures where the logs were not removed yet that it's

[jira] [Updated] (FLINK-33376) Extend Curator config option for Zookeeper configuration

2024-03-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33376: --- Labels: pull-request-available (was: ) > Extend Curator config option for Zookeeper

[PR] [FLINK-33376][coordination] Extend ZooKeeper Curator configurations [flink]

2024-03-25 Thread via GitHub
JTaky opened a new pull request, #24563: URL: https://github.com/apache/flink/pull/24563 ## What is the purpose of the change This PR introduces new configuration options for Flink and Curator configurations, such as: * authorization - option which expose to allow

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-03-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830581#comment-17830581 ] Matthias Pohl commented on FLINK-34227: ---

[jira] [Assigned] (FLINK-33521) Implement restore tests for PythonCalc node

2024-03-25 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-33521: -- Assignee: (was: Jim Hughes) > Implement restore tests for PythonCalc node >

[jira] [Commented] (FLINK-34273) git fetch fails

2024-03-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830565#comment-17830565 ] Matthias Pohl commented on FLINK-34273: ---

[jira] [Commented] (FLINK-30719) flink-runtime-web failed due to a corrupted nodejs dependency

2024-03-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830562#comment-17830562 ] Matthias Pohl commented on FLINK-30719: ---

[jira] [Commented] (FLINK-21450) Add local recovery support to adaptive scheduler

2024-03-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830558#comment-17830558 ] Matthias Pohl commented on FLINK-21450: --- Enabling the tests for AdaptiveScheduler (see

[jira] [Commented] (FLINK-21535) UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space"

2024-03-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830557#comment-17830557 ] Matthias Pohl commented on FLINK-21535: --- Enabling the tests for the AdaptiveScheduler (see

[jira] [Commented] (FLINK-21400) Attempt numbers are not maintained across restarts

2024-03-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830556#comment-17830556 ] Matthias Pohl commented on FLINK-21400: --- Enabling the tests for AdaptiveScheduler (see

[jira] [Updated] (FLINK-33376) Extend Curator config option for Zookeeper configuration

2024-03-25 Thread Oleksandr Nitavskyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-33376: Component/s: Runtime / Coordination > Extend Curator config option for Zookeeper

[jira] [Resolved] (FLINK-34409) Increase test coverage for AdaptiveScheduler

2024-03-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-34409. --- Fix Version/s: 1.18.2 1.20.0 1.19.1 Resolution:

[jira] [Commented] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging

2024-03-25 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830552#comment-17830552 ] Robert Metzger commented on FLINK-34470: [~renqs] can you take a look at this? > Transactional

Re: [PR] [BP-1.18][FLINK-34409][ci] Enables (most) tests that were disabled for the AdaptiveScheduler due to missing features [flink]

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

Re: [PR] [BP-1.19][FLINK-34409][ci] Enables (most) tests that were disabled for the AdaptiveScheduler due to missing features [flink]

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

Re: [PR] [FLINK-34409][ci] Enables (most) tests that were disabled for the AdaptiveScheduler due to missing features [flink]

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

Re: [PR] [FLINK-34933][test] Fixes JobMasterServiceLeadershipRunnerTest#testResultFutureCompletionOfOutdatedLeaderIsIgnored [flink]

2024-03-25 Thread via GitHub
flinkbot commented on PR #24562: URL: https://github.com/apache/flink/pull/24562#issuecomment-2018360524 ## CI report: * 6761fcb9af9efe341ef3a8b9474c359d46c66186 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34694) Delete num of associations for streaming outer join

2024-03-25 Thread Roman Boyko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Boyko updated FLINK-34694: Affects Version/s: (was: 1.16.3) (was: 1.17.2)

Re: [PR] [FLINK-34743][autoscaler] Memory tuning takes effect even if the parallelism isn't changed [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
mxm commented on PR #799: URL: https://github.com/apache/flink-kubernetes-operator/pull/799#issuecomment-2018354267 > Also, do you have any other specific concerns if we allow `memory tuning takes effect even if the parallelism isn't changed`? I could try to solve all of them in this PR.

Re: [PR] [FLINK-34672][runtime] Fixes deadlock risk in DefaultLeaderElectionService [flink]

2024-03-25 Thread via GitHub
flinkbot commented on PR #24561: URL: https://github.com/apache/flink/pull/24561#issuecomment-2018347961 ## CI report: * aa7b47e1c33105b2f1a242dd96ce723cca648f8e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34933) JobMasterServiceLeadershipRunnerTest#testResultFutureCompletionOfOutdatedLeaderIsIgnored isn't implemented properly

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

[PR] [FLINK-34933][test] Fixes JobMasterServiceLeadershipRunnerTest#testResultFutureCompletionOfOutdatedLeaderIsIgnored [flink]

2024-03-25 Thread via GitHub
XComp opened a new pull request, #24562: URL: https://github.com/apache/flink/pull/24562 ## What is the purpose of the change See FLINK-34933 for motivation ## Brief change log * Adds default implementation for `TestingJobMasterServiceProcess#closeAsync` returning a

[jira] [Assigned] (FLINK-34933) JobMasterServiceLeadershipRunnerTest#testResultFutureCompletionOfOutdatedLeaderIsIgnored isn't implemented properly

2024-03-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-34933: - Assignee: Matthias Pohl >

[jira] [Updated] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService

2024-03-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34672: --- Labels: pull-request-available (was: ) > HA deadlock between

[PR] [FLINK-34672][runtime] Fixes deadlock risk in DefaultLeaderElectionService [flink]

2024-03-25 Thread via GitHub
XComp opened a new pull request, #24561: URL: https://github.com/apache/flink/pull/24561 ## What is the purpose of the change There is a risk of the leader election running into deadlocks due to nested locking. One of these cases was reported in FLINK-34672. The cause of this

[jira] [Created] (FLINK-34933) JobMasterServiceLeadershipRunnerTest#testResultFutureCompletionOfOutdatedLeaderIsIgnored isn't implemented properly

2024-03-25 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34933: - Summary: JobMasterServiceLeadershipRunnerTest#testResultFutureCompletionOfOutdatedLeaderIsIgnored isn't implemented properly Key: FLINK-34933 URL:

Re: [PR] [FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework [flink]

2024-03-25 Thread via GitHub
affo commented on PR #24471: URL: https://github.com/apache/flink/pull/24471#issuecomment-2018234458 @XComp everything should be ok 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 to go to the

Re: [PR] [FLINK-34927] Translate concepts of Flink-Kubernetes-Operator documentation [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
caicancai commented on PR #804: URL: https://github.com/apache/flink-kubernetes-operator/pull/804#issuecomment-2018155840 You can skip the review now. I will complete the translation and verification of this part in the next two days. Thank you. -- This is an automated message from the

[PR] [FLINK-34927] Translate concepts of Flink-Kubernetes-Operator documen… [flink-kubernetes-operator]

2024-03-25 Thread via GitHub
caicancai opened a new pull request, #804: URL: https://github.com/apache/flink-kubernetes-operator/pull/804 …tation ## What is the purpose of the change *(For example: This pull request adds a new feature to periodically create and maintain savepoints through the

[jira] [Updated] (FLINK-34927) Translate flink-kubernetes-operator documentation

2024-03-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34927: --- Labels: pull-request-available (was: ) > Translate flink-kubernetes-operator documentation

[jira] [Updated] (FLINK-34932) Translate concepts of Flink-Kubernetes-Operator documentation

2024-03-25 Thread Caican Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caican Cai updated FLINK-34932: --- Component/s: Kubernetes Operator Fix Version/s: 1.9.0 (was: 2.0.0) >

[jira] [Updated] (FLINK-34932) Translate concepts of Flink-Kubernetes-Operator documentation

2024-03-25 Thread Caican Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caican Cai updated FLINK-34932: --- Affects Version/s: 1.9.0 (was: 1.19.0) > Translate concepts of

[jira] [Created] (FLINK-34932) Translate concepts of Flink-Kubernetes-Operator documentation

2024-03-25 Thread Caican Cai (Jira)
Caican Cai created FLINK-34932: -- Summary: Translate concepts of Flink-Kubernetes-Operator documentation Key: FLINK-34932 URL: https://issues.apache.org/jira/browse/FLINK-34932 Project: Flink

[jira] [Commented] (FLINK-33595) StreamDependencyTests.test_set_requirements_with_cached_directory failed with ModuleNotFoundError

2024-03-25 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830515#comment-17830515 ] Ryan Skraba commented on FLINK-33595: - There might be a bit more happening here in the stack treace:

[jira] [Commented] (FLINK-34919) WebMonitorEndpointTest.cleansUpExpiredExecutionGraphs fails starting REST server

2024-03-25 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830511#comment-17830511 ] Ryan Skraba commented on FLINK-34919: - 1.19

[jira] [Comment Edited] (FLINK-33595) StreamDependencyTests.test_set_requirements_with_cached_directory failed with ModuleNotFoundError

2024-03-25 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830515#comment-17830515 ] Ryan Skraba edited comment on FLINK-33595 at 3/25/24 2:24 PM: -- There might

[jira] [Commented] (FLINK-33900) Multiple failures in WindowRankITCase due to NoResourceAvailableException

2024-03-25 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830513#comment-17830513 ] Ryan Skraba commented on FLINK-33900: - 1.18 with GroupWindowTableAggregateITCase

[jira] [Commented] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

2024-03-25 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830512#comment-17830512 ] Ryan Skraba commented on FLINK-26515: - 1.19

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-03-25 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830509#comment-17830509 ] Ryan Skraba commented on FLINK-34643: - *

[jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239)

2024-03-25 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830510#comment-17830510 ] Ryan Skraba commented on FLINK-34427: - 1.19

[jira] [Updated] (FLINK-34918) Introduce comment support for Catalog

2024-03-25 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-34918: - Summary: Introduce comment support for Catalog (was: Introduce the support of Catalog for comments) >

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

2024-03-25 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830472#comment-17830472 ] Feifan Wang commented on FLINK-33734: - Kindly ping [~Zakelly] , [~roman] . > Merge unaligned

Re: [PR] [release] Adjust website for Kubernetes operator 1.8.0 release [flink-web]

2024-03-25 Thread via GitHub
mxm commented on PR #726: URL: https://github.com/apache/flink-web/pull/726#issuecomment-2017946724 Of course! For reference, follow-up PR is here: #728 -- 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

Re: [PR] Add standalone autoscaler notes to operator release blog post [flink-web]

2024-03-25 Thread via GitHub
mxm merged PR #728: URL: https://github.com/apache/flink-web/pull/728 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [cdc-cli][cdc-composer] Applying 'flink-config' for pipeline yaml [flink-cdc]

2024-03-25 Thread via GitHub
lvyanquan commented on code in PR #3187: URL: https://github.com/apache/flink-cdc/pull/3187#discussion_r1537533397 ## flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliExecutor.java: ## @@ -69,10 +69,10 @@ public PipelineExecution.ExecutionInfo run() throws Exception {

Re: [PR] [cdc-cli][cdc-composer] Applying 'flink-config' for pipeline yaml [flink-cdc]

2024-03-25 Thread via GitHub
lvyanquan commented on code in PR #3187: URL: https://github.com/apache/flink-cdc/pull/3187#discussion_r1537533397 ## flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliExecutor.java: ## @@ -69,10 +69,10 @@ public PipelineExecution.ExecutionInfo run() throws Exception {

[jira] [Created] (FLINK-34931) Update Kudu connector DataStream Source/Sink implementation

2024-03-25 Thread Ferenc Csaky (Jira)
Ferenc Csaky created FLINK-34931: Summary: Update Kudu connector DataStream Source/Sink implementation Key: FLINK-34931 URL: https://issues.apache.org/jira/browse/FLINK-34931 Project: Flink

[jira] [Updated] (FLINK-34930) Move existing Kudu connector code from Bahir repo to dedicated repo

2024-03-25 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-34930: - Description: Move the existing Kudu connector code from the Bahir [1] repository to the

[jira] [Created] (FLINK-34930) Move existing Kudu connector code from Bahir repo to dedicated repo

2024-03-25 Thread Ferenc Csaky (Jira)
Ferenc Csaky created FLINK-34930: Summary: Move existing Kudu connector code from Bahir repo to dedicated repo Key: FLINK-34930 URL: https://issues.apache.org/jira/browse/FLINK-34930 Project: Flink

[jira] [Created] (FLINK-34929) Create "flink-connector-kudu" repository

2024-03-25 Thread Ferenc Csaky (Jira)
Ferenc Csaky created FLINK-34929: Summary: Create "flink-connector-kudu" repository Key: FLINK-34929 URL: https://issues.apache.org/jira/browse/FLINK-34929 Project: Flink Issue Type:

[jira] [Created] (FLINK-34928) FLIP-439: Externalize Kudu Connector from Bahir

2024-03-25 Thread Ferenc Csaky (Jira)
Ferenc Csaky created FLINK-34928: Summary: FLIP-439: Externalize Kudu Connector from Bahir Key: FLINK-34928 URL: https://issues.apache.org/jira/browse/FLINK-34928 Project: Flink Issue Type:

[jira] [Commented] (FLINK-34925) FlinkCDC 3.0 for extracting data from sqlserver, errors occur

2024-03-25 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830464#comment-17830464 ] Hongshun Wang commented on FLINK-34925: --- This  

Re: [PR] [FLINK-28693][table] Fix janino compile failed because the code generated refers the class in table-planner [flink]

2024-03-25 Thread via GitHub
xuyangzhong commented on PR #24280: URL: https://github.com/apache/flink/pull/24280#issuecomment-2017861678 Hi, @snuyanzin . I have added the test in `flink-end-to-end-tests`. I would appreciate it if you have time to review it. -- This is an automated message from the Apache Git

[PR] Add standalone autoscaler notes to operator release blog post [flink-web]

2024-03-25 Thread via GitHub
mxm opened a new pull request, #728: URL: https://github.com/apache/flink-web/pull/728 See fc6d398dcf993f8b4cdbe172ab66afedd0122f9a for the additions to the blog post. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-34903) Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables

2024-03-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34903: --- Labels: cdc pull-request-available (was: cdc) > Add mysql-pipeline-connector with

  1   2   >