[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 2be1ea801cf616d0d0a827

[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&focusedCommentId=17813090#comment-17813090 ] Gyula Fora commented on FLINK-34329: I don't know the reason yet but the test fails

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 abo

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

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 t

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 speci

[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&focusedCommentId=17813079#comment-17813079 ] Matthias Pohl commented on FLINK-34273: --- https://dev.azure.com/apache-flink/apache

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

[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&focusedCommentId=17813077#comment-17813077 ] Rui Fan commented on FLINK-34329: - Thanks [~gyfora] reporting this issue.   I don't un

[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&focusedCommentId=17813078#comment-17813078 ] Matthias Pohl commented on FLINK-34200: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17813075#comment-17813075 ] Matthias Pohl commented on FLINK-34272: --- The following build does not contain the

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

[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&focusedCommentId=17813074#comment-17813074 ] Gyula Fora edited comment on FLINK-34329 at 2/1/24 7:28 AM:

[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&focusedCommentId=17813074#comment-17813074 ] Gyula Fora commented on FLINK-34329: cc @fanrui > ScalingReport format tests fail l

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

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

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 clas

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 clas

[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&focusedCommentId=17813042#comment-17813042 ] Zhanghao Chen commented on FLINK-33575: --- [~mason6345] Hi, we also need this featur

[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&focusedCommentId=17813038#comment-17813038 ] Rui Fan commented on FLINK-33092: - Thank you all for the lively discussion. {quote} * Re

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&focusedCommentId=17813031#comment-17813031 ] Shengkai Fang commented on FLINK-33358: --- Merged into master: fa364c7c668ec2a87bcbf

[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: issues-unsubscr...@flink.apache

[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&focusedCommentId=17813026#comment-17813026 ] Zhanghao Chen commented on FLINK-34328: --- It needs cross-team testing. [~lincoln.86

[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: https://issues.apache.org/jira/browse/FLIN

[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&focusedCommentId=17813025#comment-17813025 ] Zhanghao Chen commented on FLINK-34305: --- [~sudewei.sdw] Could you help prepare a t

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 us

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

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

[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 98e1d079f6e0689652b418b3ce2e271fc84bb55e

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 Operator

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 to

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

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

[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&focusedCommentId=17813005#comment-17813005 ] David Morávek commented on FLINK-34272: --- master: 8e11b6005c954791879f8cfdc5d08daaa

[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&focusedCommentId=17813004#comment-17813004 ] David Morávek commented on FLINK-34272: --- [~xuyangzhong] the CI run doesn't seem to

[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&focusedCommentId=17813003#comment-17813003 ] Fang Yong commented on FLINK-31275: --- Hi [~mobuchowski] [~ZhenqiuHuang], I feel that th

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 WindowTa

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

[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&focusedCommentId=17813001#comment-17813001 ] xuyang commented on FLINK-34272: https://dev.azure.com/apache-flink/apache-flink/_build/

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 Gi

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 https://square.github.io/o

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 java

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 shouldContinueRe

[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. To

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 ja

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 defini

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: issues-unsubscr...@flink.apache.o

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 t

[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 triggering-310124-

[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&focusedCommentId=17812797#comment-17812797 ] David Morávek commented on FLINK-33092: --- I've attached some notes I had (not very

[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&focusedCommentId=17812796#comment-17812796 ] David Morávek commented on FLINK-33092: --- This is something we've discussed interna

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 inst

[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&focusedCommentId=17812778#comment-17812778 ] Maximilian Michels commented on FLINK-33092: +1 waiting on resources in the

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

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&focusedCommentId=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: issues-unsubscr...@

[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&focusedCommentId=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&focusedCommentId=17812760#comment-17812760 ] Alexis Sarda-Espinosa commented on FLINK-34325: --- I just did a quick test w

[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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=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&focusedCommentId=17812754#comment-17812754 ] Matthias Pohl commented on FLINK-34272: --- https://github.com/apache/flink/actions/r

[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&focusedCommentId=17812753#comment-17812753 ] Matthias Pohl commented on FLINK-26644: --- https://github.com/apache/flink/actions/r

[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&focusedCommentId=17812752#comment-17812752 ] Alexis Sarda-Espinosa commented on FLINK-34325: --- I had interpreted that as

[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&focusedCommentId=17812749#comment-17812749 ] Martijn Visser commented on FLINK-34325: With regards to 2, isn't this as docume

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 me

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

[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&focusedCommentId=17812740#comment-17812740 ] Matthias Pohl commented on FLINK-34272: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17812739#comment-17812739 ] Matthias Pohl commented on FLINK-34272: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17812738#comment-17812738 ] Matthias Pohl commented on FLINK-34200: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17812736#comment-17812736 ] Matthias Pohl commented on FLINK-34273: --- https://dev.azure.com/apache-flink/apache

[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): https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=57100&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb

[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&focusedCommentId=17812734#comment-17812734 ] Matthias Pohl commented on FLINK-22040: --- https://dev.azure.com/apache-flink/apache

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

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 l

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: issues-unsubscr

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 setLastRescale(Instan

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 (si

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

[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 setLastRescale(Instan

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 in

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

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 ScalarFunctionsTest

[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 ### Limit

  1   2   >