[jira] [Closed] (FLINK-34126) Correct the description of jobmanager.scheduler

2024-01-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-34126. --- Fix Version/s: 1.19.0 Assignee: Junrui Li Resolution: Fixed Fixed via

[jira] [Commented] (FLINK-34329) ScalingReport format tests fail locally on decimal format

2024-01-31 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813090#comment-17813090 ] Gyula Fora commented on FLINK-34329: I don't know the reason yet but the test fails constantly on my

Re: [PR] [FLINK-34206][runtime][test] Fix potential job failure with simultaneous global failover and task finish [flink]

2024-01-31 Thread via GitHub
zhuzhurk commented on PR #24223: URL: https://github.com/apache/flink/pull/24223#issuecomment-1920711900 My bad for not approving the PR before merging it. -- 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] [FLINK-34126][configuration] Correct the description of jobmanager.scheduler [flink]

2024-01-31 Thread via GitHub
zhuzhurk closed pull request #24112: [FLINK-34126][configuration] Correct the description of jobmanager.scheduler URL: https://github.com/apache/flink/pull/24112 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Closed] (FLINK-34206) CacheITCase.testRetryOnCorruptedClusterDataset(Path) failed

2024-01-31 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-34206. --- Fix Version/s: 1.19.0 Resolution: Fixed Fixed via b737b71859672e8020881ce2abf998735ee98abb >

Re: [PR] [FLINK-34206][runtime][test] Fix potential job failure with simultaneous global failover and task finish [flink]

2024-01-31 Thread via GitHub
zhuzhurk closed pull request #24223: [FLINK-34206][runtime][test] Fix potential job failure with simultaneous global failover and task finish URL: https://github.com/apache/flink/pull/24223 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-26369][doc-zh] Translate the part zh-page mixed with not be translated. [flink]

2024-01-31 Thread via GitHub
GOODBOY008 commented on PR #20340: URL: https://github.com/apache/flink/pull/20340#issuecomment-1920692120 @leonardBang PTAL , Thank you~ -- 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-34273) git fetch fails

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

[jira] [Updated] (FLINK-34329) ScalingReport format tests fail locally on decimal format

2024-01-31 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34329: Fix Version/s: kubernetes-operator-1.8.0 > ScalingReport format tests fail locally on decimal format >

[jira] [Updated] (FLINK-34200) AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

2024-01-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34200: -- Priority: Critical (was: Major) > AutoRescalingITCase#testCheckpointRescalingInKeyedState

[jira] [Commented] (FLINK-34329) ScalingReport format tests fail locally on decimal format

2024-01-31 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813077#comment-17813077 ] Rui Fan commented on FLINK-34329: - Thanks [~gyfora] reporting this issue.   I don't understand why

[jira] [Commented] (FLINK-34200) AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

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

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

2024-01-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813075#comment-17813075 ] Matthias Pohl commented on FLINK-34272: --- The following build does not contain the fix

[jira] [Updated] (FLINK-34329) ScalingReport format tests fail locally on decimal format

2024-01-31 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34329: Affects Version/s: kubernetes-operator-1.8.0 > ScalingReport format tests fail locally on decimal format

Re: [PR] [FLINK-34088] [hotfix] fix the problems with special table name characters of postgres and oracle  and sqlserver. [flink-connector-jdbc]

2024-01-31 Thread via GitHub
snuyanzin commented on PR #89: URL: https://github.com/apache/flink-connector-jdbc/pull/89#issuecomment-1920669676 yep, may be it is a point to see whether we could adapt it or not btw I haven't found any test reproducing the issue, can you add one? Also I would say the issue is

[jira] [Comment Edited] (FLINK-34329) ScalingReport format tests fail locally on decimal format

2024-01-31 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813074#comment-17813074 ] Gyula Fora edited comment on FLINK-34329 at 2/1/24 7:28 AM: cc [~fanrui] 

[jira] [Commented] (FLINK-34329) ScalingReport format tests fail locally on decimal format

2024-01-31 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813074#comment-17813074 ] Gyula Fora commented on FLINK-34329: cc @fanrui > ScalingReport format tests fail locally on

[jira] [Created] (FLINK-34329) ScalingReport format tests fail locally on decimal format

2024-01-31 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-34329: -- Summary: ScalingReport format tests fail locally on decimal format Key: FLINK-34329 URL: https://issues.apache.org/jira/browse/FLINK-34329 Project: Flink Issue

Re: [PR] [FLINK-33668] Decoupling Shuffle network memory and job topology [flink]

2024-01-31 Thread via GitHub
jiangxin369 commented on code in PR #23851: URL: https://github.com/apache/flink/pull/23851#discussion_r1473868814 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageMemoryManagerImpl.java: ## @@ -244,18 +246,8 @@

Re: [PR] [FLINK-33668] Decoupling Shuffle network memory and job topology [flink]

2024-01-31 Thread via GitHub
jiangxin369 commented on code in PR #23851: URL: https://github.com/apache/flink/pull/23851#discussion_r1473848488 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/common/TieredStorageConfiguration.java: ## @@ -37,8 +37,16 @@ public

Re: [PR] [FLINK-33668] Decoupling Shuffle network memory and job topology [flink]

2024-01-31 Thread via GitHub
jiangxin369 commented on code in PR #23851: URL: https://github.com/apache/flink/pull/23851#discussion_r1473848488 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/common/TieredStorageConfiguration.java: ## @@ -37,8 +37,16 @@ public

[jira] [Commented] (FLINK-33575) FLIP-394: Add Metrics for Connector Agnostic Autoscaling

2024-01-31 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813042#comment-17813042 ] Zhanghao Chen commented on FLINK-33575: --- [~mason6345] Hi, we also need this feature, what are the

[jira] [Commented] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

2024-01-31 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813038#comment-17813038 ] Rui Fan commented on FLINK-33092: - Thank you all for the lively discussion. {quote} * Redefine how

Re: [PR] [FLINK-33358][sql] Fix Flink SQL Client fail to start in Flink on YARN [flink]

2024-01-31 Thread via GitHub
PrabhuJoseph commented on PR #23629: URL: https://github.com/apache/flink/pull/23629#issuecomment-1920497139 Thanks @fsk119 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Assigned] (FLINK-33358) Flink SQL Client fails to start in Flink on YARN

2024-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-33358: - Assignee: Prabhu Joseph > Flink SQL Client fails to start in Flink on YARN >

[jira] [Commented] (FLINK-33358) Flink SQL Client fails to start in Flink on YARN

2024-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813031#comment-17813031 ] Shengkai Fang commented on FLINK-33358: --- Merged into master:

[jira] [Closed] (FLINK-33358) Flink SQL Client fails to start in Flink on YARN

2024-01-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-33358. - Resolution: Fixed > Flink SQL Client fails to start in Flink on YARN >

Re: [PR] [FLINK-33358][sql] Fix Flink SQL Client fail to start in Flink on YARN [flink]

2024-01-31 Thread via GitHub
fsk119 merged PR #23629: URL: https://github.com/apache/flink/pull/23629 -- 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-34328) Release Testing Instructions: Verify FLINK-34037 Improve Serialization Configuration And Usage In Flink

2024-01-31 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813026#comment-17813026 ] Zhanghao Chen commented on FLINK-34328: --- It needs cross-team testing. [~lincoln.86xy] Could you

[jira] [Created] (FLINK-34328) Release Testing Instructions: Verify FLINK-34037 Improve Serialization Configuration And Usage In Flink

2024-01-31 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-34328: - Summary: Release Testing Instructions: Verify FLINK-34037 Improve Serialization Configuration And Usage In Flink Key: FLINK-34328 URL:

[jira] [Commented] (FLINK-34305) Release Testing Instructions: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

2024-01-31 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813025#comment-17813025 ] Zhanghao Chen commented on FLINK-34305: --- [~sudewei.sdw] Could you help prepare a testing

Re: [PR] [FLINK-34206][runtime][test] Fix potential job failure with simultaneous global failover and task finish [flink]

2024-01-31 Thread via GitHub
SinBex commented on PR #24223: URL: https://github.com/apache/flink/pull/24223#issuecomment-1920400936 @zhuzhurk Thanks for reviewing the pr, I have fix the comment, PTAL~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-34298) Release Testing Instructions: Verify FLINK-33397 Support Configuring Different State TTLs using SQL Hint

2024-01-31 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-34298: -- Description: This ticket aims to verify FLINK-33397: Support Configuring Different State TTLs using

[jira] [Resolved] (FLINK-33261) FLIP-367: Support Setting Parallelism for Table/SQL Sources

2024-01-31 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li resolved FLINK-33261. Resolution: Fixed Marking the umbrella issue "resolved" since all the subtasks has been finished.

Re: [PR] [FLINK-34260][Connectors/AWS] Update flink-connector-aws to be compatible with updated SinkV2 interfaces [flink-connector-aws]

2024-01-31 Thread via GitHub
z3d1k commented on code in PR #127: URL: https://github.com/apache/flink-connector-aws/pull/127#discussion_r1473727909 ## pom.xml: ## @@ -58,7 +58,7 @@ under the License. 4.1.86.Final 1.17.0 2.14.3 -1.1.14 +1.1.18 Review Comment:

[jira] [Resolved] (FLINK-34270) Update connector developer-facing doc for FLIP-367 & 146

2024-01-31 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li resolved FLINK-34270. Assignee: Zhanghao Chen Resolution: Fixed Fixed via

Re: [PR] [FLINK-34312][table] Improve the handling of default node types for named parameters [flink]

2024-01-31 Thread via GitHub
fsk119 commented on code in PR #24235: URL: https://github.com/apache/flink/pull/24235#discussion_r1473714147 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference/OperatorBindingCallContext.java: ## @@ -59,7 +59,7 @@ public

Re: [PR] [FLINK-34270][docs] Update doc for the new Table source & sink interfaces introduced in FLIP-146 & 367 [flink]

2024-01-31 Thread via GitHub
libenchao closed pull request #24234: [FLINK-34270][docs] Update doc for the new Table source & sink interfaces introduced in FLIP-146 & 367 URL: https://github.com/apache/flink/pull/24234 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[PR] [FLINK-34260][Connectors/AWS] Update flink-connector-aws to be compatible with updated SinkV2 interfaces [flink-connector-aws]

2024-01-31 Thread via GitHub
z3d1k opened a new pull request, #127: URL: https://github.com/apache/flink-connector-aws/pull/127 ## Purpose of the change - Update DynamoDBSink, KinesisFirehoseSink, and KinesisStreamsSink to be compatible with updated SinkV2 interfaces - Resolve dependency convergence

[jira] [Updated] (FLINK-34126) Correct the description of jobmanager.scheduler

2024-01-31 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-34126: -- Component/s: Documentation (was: Runtime / Configuration) > Correct the

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

2024-01-31 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813005#comment-17813005 ] David Morávek commented on FLINK-34272: --- master: 8e11b6005c954791879f8cfdc5d08daaaba95945 >

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

2024-01-31 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813004#comment-17813004 ] David Morávek commented on FLINK-34272: --- [~xuyangzhong] the CI run doesn't seem to be up to date

[jira] [Resolved] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

2024-01-31 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-34272. --- Fix Version/s: 1.19.0 Resolution: Fixed > AdaptiveSchedulerClusterITCase failure due

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2024-01-31 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813003#comment-17813003 ] Fang Yong commented on FLINK-31275: --- Hi [~mobuchowski] [~ZhenqiuHuang], I feel that there are many

Re: [PR] [FLINK-34323][table-planner] Fix param name in session window tvf when using named params [flink]

2024-01-31 Thread via GitHub
hackergin commented on code in PR #24243: URL: https://github.com/apache/flink/pull/24243#discussion_r1473706753 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/WindowTableFunctionTest.scala: ## @@ -257,4 +257,48 @@ class

[jira] [Updated] (FLINK-34317) Cleanup pending Flink CDC issues on GitHub

2024-01-31 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34317: -- Description: Until 01/30/2024, there are 744 open and 865 closed issues on GitHub. Outdated

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

2024-01-31 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813001#comment-17813001 ] xuyang commented on FLINK-34272:

Re: [PR] [FLINK-34323][table-planner] Fix param name in session window tvf when using named params [flink]

2024-01-31 Thread via GitHub
xuyangzhong commented on PR #24243: URL: https://github.com/apache/flink/pull/24243#issuecomment-1920348461 The failure is caused by https://issues.apache.org/jira/browse/FLINK-34272 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [FLINK-34319] Bump okhttp version to 4.12.0 [flink-kubernetes-operator]

2024-01-31 Thread via GitHub
czy006 commented on PR #766: URL: https://github.com/apache/flink-kubernetes-operator/pull/766#issuecomment-1920346016 > Is there some known vulnerability / issue that we are aiming to fix here? None, only updates and fixes problems with okhttp itself

Re: [PR] [FLINK-33396][table-planner] clear table alias in subquery [flink]

2024-01-31 Thread via GitHub
xuyangzhong commented on code in PR #24239: URL: https://github.com/apache/flink/pull/24239#discussion_r1473697827 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/ClearQueryBlockAliasResolver.java: ## @@ -31,22 +31,19 @@ import

Re: [PR] [FLINK-33668] Decoupling Shuffle network memory and job topology [flink]

2024-01-31 Thread via GitHub
TanYuxin-tyx commented on code in PR #23851: URL: https://github.com/apache/flink/pull/23851#discussion_r1472472085 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java: ## @@ -132,16 +134,44 @@ private boolean

[jira] [Created] (FLINK-34327) Use maven wrapper in operator build

2024-01-31 Thread Mason Chen (Jira)
Mason Chen created FLINK-34327: -- Summary: Use maven wrapper in operator build Key: FLINK-34327 URL: https://issues.apache.org/jira/browse/FLINK-34327 Project: Flink Issue Type: Improvement

Re: [PR] [FLINK-34270][docs] Update doc for the new Table source & sink interfaces introduced in FLIP-146 & 367 [flink]

2024-01-31 Thread via GitHub
X-czh commented on PR #24234: URL: https://github.com/apache/flink/pull/24234#issuecomment-1920309192 @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.

Re: [PR] [FLINK-33396][table-planner] clear table alias in subquery [flink]

2024-01-31 Thread via GitHub
jeyhunkarimov commented on code in PR #24239: URL: https://github.com/apache/flink/pull/24239#discussion_r1473486396 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/ClearQueryBlockAliasResolver.java: ## @@ -31,22 +31,19 @@ import

Re: [PR] [FLINK-33089] Clean up 1.13 and 1.14 references from docs and code [flink-kubernetes-operator]

2024-01-31 Thread via GitHub
gyfora commented on code in PR #768: URL: https://github.com/apache/flink-kubernetes-operator/pull/768#discussion_r1473216424 ## docs/content/docs/custom-resource/reference.md: ## @@ -78,8 +78,6 @@ This page serves as a full reference for FlinkDeployment custom resource

Re: [PR] [FLINK-33089] Clean up 1.13 and 1.14 references from docs and code [flink-kubernetes-operator]

2024-01-31 Thread via GitHub
mxm commented on code in PR #768: URL: https://github.com/apache/flink-kubernetes-operator/pull/768#discussion_r1473197963 ## docs/content/docs/custom-resource/reference.md: ## @@ -78,8 +78,6 @@ This page serves as a full reference for FlinkDeployment custom resource definit

Re: [PR] [FLINK-34272][runtime] ExecutingState should never transition during … [flink]

2024-01-31 Thread via GitHub
dmvk merged PR #24237: URL: https://github.com/apache/flink/pull/24237 -- 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-34272][runtime] ExecutingState should never transition during … [flink]

2024-01-31 Thread via GitHub
dmvk commented on PR #24237: URL: https://github.com/apache/flink/pull/24237#issuecomment-1919495970 > ut it would be interesting to know whether you see the same behavior when running all tests from ExecutingTest within the IDE. it fails in IDE as well, but I delegate all test runs

[jira] [Updated] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

2024-01-31 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-33092: -- Attachment: FLINK-FLIP-XXX_ Refining AdaptiveScheduler timeouts and rescale

[jira] [Commented] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

2024-01-31 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812797#comment-17812797 ] David Morávek commented on FLINK-33092: --- I've attached some notes I had (not very structured) to

[jira] [Commented] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

2024-01-31 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812796#comment-17812796 ] David Morávek commented on FLINK-33092: --- This is something we've discussed internally as well. I

Re: [PR] [FLINK-34270][docs] Update doc for the new Table source & sink interfaces introduced in FLIP-146 & 367 [flink]

2024-01-31 Thread via GitHub
X-czh commented on code in PR #24234: URL: https://github.com/apache/flink/pull/24234#discussion_r1473109910 ## docs/content/docs/dev/table/sourcesSinks.md: ## @@ -197,10 +197,16 @@ A table source can implement further ability interfaces such as `SupportsProject mutate an

[jira] [Commented] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

2024-01-31 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812778#comment-17812778 ] Maximilian Michels commented on FLINK-33092: +1 waiting on resources in the Executing state.

[jira] [Updated] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError

2024-01-31 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-34325: -- Summary: Inconsistent state with data loss after OutOfMemoryError (was:

Re: [PR] Add JDBC 3.1.2 connector [flink-web]

2024-01-31 Thread via GitHub
snuyanzin commented on code in PR #707: URL: https://github.com/apache/flink-web/pull/707#discussion_r1472905348 ## docs/data/flink_connectors.yml: ## @@ -44,11 +44,11 @@ gcp-pubsub: compatibility: ["1.16.x", "1.17.x"] jdbc: - name: "Apache Flink JDBC Connector 3.1.1" -

[jira] [Comment Edited] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

2024-01-31 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812760#comment-17812760 ] Alexis Sarda-Espinosa edited comment on FLINK-34325 at 1/31/24 3:46 PM:

Re: [PR] [hotfix] Use 1.16.x as minimum supported version in pom [flink-connector-jdbc]

2024-01-31 Thread via GitHub
snuyanzin merged PR #99: URL: https://github.com/apache/flink-connector-jdbc/pull/99 -- 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-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

2024-01-31 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812760#comment-17812760 ] Alexis Sarda-Espinosa edited comment on FLINK-34325 at 1/31/24 3:41 PM:

[jira] [Commented] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

2024-01-31 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812760#comment-17812760 ] Alexis Sarda-Espinosa commented on FLINK-34325: --- I just did a quick test where I increased

[jira] [Comment Edited] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

2024-01-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812754#comment-17812754 ] Matthias Pohl edited comment on FLINK-34272 at 1/31/24 3:34 PM:

[jira] [Comment Edited] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

2024-01-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812754#comment-17812754 ] Matthias Pohl edited comment on FLINK-34272 at 1/31/24 3:34 PM:

[jira] [Comment Edited] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

2024-01-31 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812752#comment-17812752 ] Alexis Sarda-Espinosa edited comment on FLINK-34325 at 1/31/24 3:33 PM:

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

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

[jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

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

[jira] [Commented] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

2024-01-31 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812752#comment-17812752 ] Alexis Sarda-Espinosa commented on FLINK-34325: --- I had interpreted that as "kept in task

[jira] [Commented] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

2024-01-31 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17812749#comment-17812749 ] Martijn Visser commented on FLINK-34325: With regards to 2, isn't this as documented as

Re: [PR] [hotfix] Use 1.16.x as minimum supported version in pom [flink-connector-jdbc]

2024-01-31 Thread via GitHub
snuyanzin commented on code in PR #99: URL: https://github.com/apache/flink-connector-jdbc/pull/99#discussion_r1472980737 ## pom.xml: ## @@ -47,7 +47,7 @@ under the License. -1.17.0 +1.16.3 Review Comment: I changed to 1.16.0, thanks will

[jira] [Created] (FLINK-34326) Add Slack integration

2024-01-31 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34326: - Summary: Add Slack integration Key: FLINK-34326 URL: https://issues.apache.org/jira/browse/FLINK-34326 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

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

[jira] [Commented] (FLINK-34272) AdaptiveSchedulerClusterITCase failure due to MiniCluster not running

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

[jira] [Commented] (FLINK-34200) AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

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

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

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

[jira] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

2024-01-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22040 ] Matthias Pohl deleted comment on FLINK-22040: --- was (Author: mapohl):

[jira] [Commented] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

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

[jira] [Closed] (FLINK-34207) org.apache.flink:flink-shaded-jackson:jar:2.15.3-18.0 couldn't be downloaded

2024-01-31 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-34207. - Resolution: Cannot Reproduce > org.apache.flink:flink-shaded-jackson:jar:2.15.3-18.0 couldn't

Re: [PR] [FLINK-34319] Bump okhttp version to 4.12.0 [flink-kubernetes-operator]

2024-01-31 Thread via GitHub
gyfora commented on PR #766: URL: https://github.com/apache/flink-kubernetes-operator/pull/766#issuecomment-1919284656 Is there some known vulnerability / issue that we are aiming to fix here? -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] [FLINK-34311] Do not change min resource requirements when rescaling with adaptive scheduler [flink-kubernetes-operator]

2024-01-31 Thread via GitHub
gyfora merged PR #763: URL: https://github.com/apache/flink-kubernetes-operator/pull/763 -- 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-34272][runtime] ExecutingState should never transition during … [flink]

2024-01-31 Thread via GitHub
XComp commented on code in PR #24237: URL: https://github.com/apache/flink/pull/24237#discussion_r1472934138 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java: ## @@ -634,17 +628,23 @@ public ExecutingStateBuilder

Re: [PR] [hotfix] Use 1.16.x as minimum supported version in pom [flink-connector-jdbc]

2024-01-31 Thread via GitHub
MartijnVisser commented on code in PR #99: URL: https://github.com/apache/flink-connector-jdbc/pull/99#discussion_r1472931287 ## pom.xml: ## @@ -47,7 +47,7 @@ under the License. -1.17.0 +1.16.3 Review Comment: We could even set it to 1.16.0

Re: [PR] [hotfix] Update high-availability configs to newer syntax [flink-kubernetes-operator]

2024-01-31 Thread via GitHub
mxm commented on code in PR #764: URL: https://github.com/apache/flink-kubernetes-operator/pull/764#discussion_r1472927239 ## docs/content/docs/custom-resource/job-management.md: ## @@ -117,7 +117,7 @@ spec: taskmanager.numberOfTaskSlots: "2" state.savepoints.dir:

[jira] [Created] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

2024-01-31 Thread Alexis Sarda-Espinosa (Jira)
Alexis Sarda-Espinosa created FLINK-34325: - Summary: Inconsistent state with data loss after OutOfMemoryError in Job Manager Key: FLINK-34325 URL: https://issues.apache.org/jira/browse/FLINK-34325

Re: [PR] [FLINK-34272][runtime] ExecutingState should never transition during … [flink]

2024-01-31 Thread via GitHub
XComp commented on code in PR #24237: URL: https://github.com/apache/flink/pull/24237#discussion_r1472915149 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java: ## @@ -634,17 +628,23 @@ public ExecutingStateBuilder

Re: [PR] Add JDBC 3.1.2 connector [flink-web]

2024-01-31 Thread via GitHub
snuyanzin commented on code in PR #707: URL: https://github.com/apache/flink-web/pull/707#discussion_r1472905348 ## docs/data/flink_connectors.yml: ## @@ -44,11 +44,11 @@ gcp-pubsub: compatibility: ["1.16.x", "1.17.x"] jdbc: - name: "Apache Flink JDBC Connector 3.1.1" -

Re: [PR] [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location [flink]

2024-01-31 Thread via GitHub
flinkbot commented on PR #24244: URL: https://github.com/apache/flink/pull/24244#issuecomment-1919180871 ## CI report: * 8bf09a9c3c67b9561ebe461f130f3aebb2eb908a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34324) s3_setup is called in test_file_sink.sh even if the common_s3.sh is not sourced

2024-01-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34324: --- Labels: pull-request-available test-stability (was: test-stability) > s3_setup is called

[PR] [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location [flink]

2024-01-31 Thread via GitHub
XComp opened a new pull request, #24244: URL: https://github.com/apache/flink/pull/24244 ## What is the purpose of the change * Fixes error message in test execution * unifies S3-related code in one location ## Brief change log * Moves the entire s3-related logic into

Re: [PR] [FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function [flink]

2024-01-31 Thread via GitHub
JingGe commented on code in PR #24156: URL: https://github.com/apache/flink/pull/24156#discussion_r1472765262 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/ScalarFunctionsTest.scala: ## @@ -604,6 +604,20 @@ class

Re: [PR] [FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function [flink]

2024-01-31 Thread via GitHub
JingGe commented on code in PR #24156: URL: https://github.com/apache/flink/pull/24156#discussion_r1472765262 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/ScalarFunctionsTest.scala: ## @@ -604,6 +604,20 @@ class

[PR] [hotfix] Use 1.16.x as minimum supported version in pom [flink-connector-jdbc]

2024-01-31 Thread via GitHub
snuyanzin opened a new pull request, #99: URL: https://github.com/apache/flink-connector-jdbc/pull/99 As it was identified at https://github.com/apache/flink-web/pull/707#discussion_r1472769071 there should be minimum Flink version in pom and in push pr as well -- This is an automated

Re: [PR] [FLINK-34132][runtime] Correct the error message and doc of AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE. [flink]

2024-01-31 Thread via GitHub
zhuzhurk commented on code in PR #24118: URL: https://github.com/apache/flink/pull/24118#discussion_r1472843285 ## docs/content/docs/deployment/elastic_scaling.md: ## @@ -238,7 +238,7 @@ In addition, there are several related configuration options that may need adjus ###

  1   2   >