[jira] [Commented] (FLINK-34357) IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814229#comment-17814229 ] Matthias Pohl commented on FLINK-34357: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34357) IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814230#comment-17814230 ] Matthias Pohl commented on FLINK-34357: --- https://github.com/apache/flink/actions/r

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

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814232#comment-17814232 ] Matthias Pohl commented on FLINK-26644: --- https://github.com/apache/flink/actions/r

[jira] [Closed] (FLINK-34359) "Kerberized YARN per-job on Docker test (default input)" failed due to IllegalStateException

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-34359. - Resolution: Duplicate I'm closing this one in favor of FLINK-34357. it looks like there is some

[jira] [Created] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34360: - Summary: GHA e2e test failure due to no space left on device error Key: FLINK-34360 URL: https://issues.apache.org/jira/browse/FLINK-34360 Project: Flink I

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814235#comment-17814235 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Updated] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34360: -- Description: https://github.com/apache/flink/actions/runs/7763815214 {code} AdaptiveScheduler

[jira] [Updated] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34360: -- Affects Version/s: 1.18.1 1.19.0 > GHA e2e test failure due to no space

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814237#comment-17814237 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814238#comment-17814238 ] Matthias Pohl commented on FLINK-34360: --- here we also see it in the {{misc}} stage

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814243#comment-17814243 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814242#comment-17814242 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814244#comment-17814244 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814245#comment-17814245 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814240#comment-17814240 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814246#comment-17814246 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Created] (FLINK-34361) PyFlink end-to-end test fails in GHA

2024-02-05 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34361: - Summary: PyFlink end-to-end test fails in GHA Key: FLINK-34361 URL: https://issues.apache.org/jira/browse/FLINK-34361 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-34361) PyFlink end-to-end test fails in GHA

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34361: -- Labels: github-actions test-stability (was: ) > PyFlink end-to-end test fails in GHA > --

[jira] [Commented] (FLINK-33958) Implement restore tests for IntervalJoin node

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814251#comment-17814251 ] Matthias Pohl commented on FLINK-33958: --- https://github.com/apache/flink/actions/r

[jira] [Comment Edited] (FLINK-33958) Implement restore tests for IntervalJoin node

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814251#comment-17814251 ] Matthias Pohl edited comment on FLINK-33958 at 2/5/24 8:22 AM: ---

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814252#comment-17814252 ] Matthias Pohl commented on FLINK-22765: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34357) IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814253#comment-17814253 ] Matthias Pohl commented on FLINK-34357: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34357) IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814255#comment-17814255 ] Matthias Pohl commented on FLINK-34357: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814256#comment-17814256 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34357) IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814260#comment-17814260 ] Matthias Pohl commented on FLINK-34357: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814259#comment-17814259 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814261#comment-17814261 ] Matthias Pohl commented on FLINK-26974: --- https://github.com/apache/flink/actions/r

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

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814263#comment-17814263 ] Matthias Pohl commented on FLINK-33900: --- https://github.com/apache/flink/actions/r

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

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814263#comment-17814263 ] Matthias Pohl edited comment on FLINK-33900 at 2/5/24 8:32 AM: ---

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814265#comment-17814265 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-33958) Implement restore tests for IntervalJoin node

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814267#comment-17814267 ] Matthias Pohl commented on FLINK-33958: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814268#comment-17814268 ] Matthias Pohl commented on FLINK-22765: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-33958) Implement restore tests for IntervalJoin node

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814266#comment-17814266 ] Matthias Pohl commented on FLINK-33958: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814269#comment-17814269 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

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

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814271#comment-17814271 ] Matthias Pohl commented on FLINK-33900: --- 1.18: https://github.com/apache/flink/ac

[jira] [Commented] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814270#comment-17814270 ] Matthias Pohl commented on FLINK-26974: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34360) GHA e2e test failure due to no space left on device error

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814272#comment-17814272 ] Matthias Pohl commented on FLINK-34360: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34357) IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814274#comment-17814274 ] Matthias Pohl commented on FLINK-34357: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34357) IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814275#comment-17814275 ] Matthias Pohl commented on FLINK-34357: --- These failures are also most likely cause

[jira] [Commented] (FLINK-33958) Implement restore tests for IntervalJoin node

2024-02-05 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814300#comment-17814300 ] Dawid Wysakowicz commented on FLINK-33958: -- [~bvarghese] Did you have time to l

Re: [PR] [FLINK-33958] Fix IntervalJoin restore test flakiness [flink]

2024-02-05 Thread via GitHub
dawidwys commented on PR #24196: URL: https://github.com/apache/flink/pull/24196#issuecomment-1926604671 @bvarghese1 Could you please explain how does this improve the test reliability? -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[jira] [Created] (FLINK-34362) Add argument to reuse connector docs cache in setup_docs.sh to improve build times

2024-02-05 Thread Jane Chan (Jira)
Jane Chan created FLINK-34362: - Summary: Add argument to reuse connector docs cache in setup_docs.sh to improve build times Key: FLINK-34362 URL: https://issues.apache.org/jira/browse/FLINK-34362 Project:

[jira] [Commented] (FLINK-34362) Add argument to reuse connector docs cache in setup_docs.sh to improve build times

2024-02-05 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814310#comment-17814310 ] Jane Chan commented on FLINK-34362: --- Cc [~martijnvisser], I'd like to hear your opinio

Re: [PR] [FLINK-34337][core] Sink.InitContextWrapper should implement metadataConsumer method [flink]

2024-02-05 Thread via GitHub
Jiabao-Sun commented on PR #24249: URL: https://github.com/apache/flink/pull/24249#issuecomment-1926664315 Hi @pvary, could you help review it again? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[jira] [Commented] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

2024-02-05 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814312#comment-17814312 ] Stefan Richter commented on FLINK-34050: Just one idea: since the current propos

Re: [PR] [FLINK-34247][doc] Fix the wrong zh link for flink-configuration-file and repeated flink configuration file [flink]

2024-02-05 Thread via GitHub
1996fanrui merged PR #24266: URL: https://github.com/apache/flink/pull/24266 -- 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.ap

[jira] [Comment Edited] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

2024-02-05 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814312#comment-17814312 ] Stefan Richter edited comment on FLINK-34050 at 2/5/24 10:41 AM: -

Re: [PR] [FLINK-21949][table] Support ARRAY_AGG aggregate function [flink]

2024-02-05 Thread via GitHub
dawidwys commented on code in PR #23411: URL: https://github.com/apache/flink/pull/23411#discussion_r1477969162 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/ArrayAggFunctionITCase.java: ## @@ -0,0 +1,95 @@ +/* + * Licensed to the Apac

[jira] [Commented] (FLINK-34247) Document FLIP-366: Support standard YAML for FLINK configuration

2024-02-05 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814313#comment-17814313 ] Rui Fan commented on FLINK-34247: - Extra commit(1.19): d44e940e9d28518115cf6e8d5ba4f963f

Re: [PR] [FLINK-33739][doc] Document FLIP-364: Improve the exponential-delay restart-strategy [flink]

2024-02-05 Thread via GitHub
1996fanrui commented on PR #24263: URL: https://github.com/apache/flink/pull/24263#issuecomment-1926705845 Thanks @zhuzhurk for the quick review, I have addressed all your comments, and finished the English documentation. -- This is an automated message from the Apache Git Service. To res

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

2024-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814316#comment-17814316 ] Matthias Pohl commented on FLINK-30719: --- https://dev.azure.com/apache-flink/apache

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-05 Thread via GitHub
mxm commented on code in PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1478006171 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -106,7 +107,13 @@ public void scale(Context ctx) throws Excepti

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-05 Thread via GitHub
mxm commented on code in PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1478007838 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesScalingRealizer.java: ## @@ -43,6 +53,32 @@ public voi

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-05 Thread via GitHub
gyfora commented on code in PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1478008644 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -106,7 +107,13 @@ public void scale(Context ctx) throws Exce

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-05 Thread via GitHub
mxm commented on code in PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1478010245 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/MemoryTuningUtils.java: ## @@ -0,0 +1,203 @@ +/* + * Licensed to the Apache Software Fo

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-05 Thread via GitHub
mxm commented on code in PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1478016552 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/MemoryTuningUtils.java: ## @@ -0,0 +1,203 @@ +/* + * Licensed to the Apache Software Fo

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-05 Thread via GitHub
mxm commented on PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#issuecomment-1926743545 > The memory tuning logic looks good 👍 > > I think we should unify the storing / application of parallelism and other overrides. In this PR we introduced a bunch of new

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

2024-02-05 Thread via GitHub
echauchot commented on code in PR #24237: URL: https://github.com/apache/flink/pull/24237#discussion_r1477979041 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java: ## @@ -88,7 +88,7 @@ class Executing extends StateWithExecutionGraph implem

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-05 Thread via GitHub
mxm commented on code in PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1478026324 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/state/AutoScalerStateStore.java: ## @@ -69,6 +70,13 @@ void storeParallelismOverrides(Context

[jira] [Created] (FLINK-34363) Connectors release utils should allow to not specify flink version in stage_jars.sh

2024-02-05 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-34363: Summary: Connectors release utils should allow to not specify flink version in stage_jars.sh Key: FLINK-34363 URL: https://issues.apache.org/jira/browse/FLINK-34363

[jira] [Created] (FLINK-34364) stage_source_release.sh should exclude tools/release directory from the source release

2024-02-05 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-34364: Summary: stage_source_release.sh should exclude tools/release directory from the source release Key: FLINK-34364 URL: https://issues.apache.org/jira/browse/FLINK-34364

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-05 Thread via GitHub
mxm commented on code in PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1478049230 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -106,7 +107,13 @@ public void scale(Context ctx) throws Excepti

Re: [PR] [FLINK-34343][rpc] Use actor path when rejecting early messages [flink]

2024-02-05 Thread via GitHub
zentol merged PR #24258: URL: https://github.com/apache/flink/pull/24258 -- 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

Re: [PR] [FLINK-34343][rpc] Use actor path when rejecting early messages [flink]

2024-02-05 Thread via GitHub
zentol commented on PR #24258: URL: https://github.com/apache/flink/pull/24258#issuecomment-1926796077 > I guess that's worth creating 1.18 and 1.17 backports. Will do. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[jira] [Closed] (FLINK-34343) ResourceManager registration is not completed when registering the JobMaster

2024-02-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-34343. Fix Version/s: 1.19.0 1.17.3 1.18.2 Resolution

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-05 Thread via GitHub
mxm commented on code in PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1478084592 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesScalingRealizer.java: ## @@ -43,6 +53,32 @@ public voi

Re: [PR] [FLINK-34200][test] Fix the bug that AutoRescalingITCase.testCheckpointRescalingInKeyedState fails occasionally [flink]

2024-02-05 Thread via GitHub
XComp commented on code in PR #24246: URL: https://github.com/apache/flink/pull/24246#discussion_r1478141469 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java: ## @@ -411,7 +413,7 @@ public void testCheckpointRescalingWithKeyedAndNonParti

[jira] [Commented] (FLINK-34362) Add argument to reuse connector docs cache in setup_docs.sh to improve build times

2024-02-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814351#comment-17814351 ] Martijn Visser commented on FLINK-34362: [~qingyue] That makes sense to me, I do

Re: [PR] [FLINK-33441] Move Union restore tests [flink]

2024-02-05 Thread via GitHub
dawidwys merged PR #24110: URL: https://github.com/apache/flink/pull/24110 -- 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.apac

Re: [PR] [FLINK-33517] Implement restore tests for Values node [flink]

2024-02-05 Thread via GitHub
dawidwys commented on code in PR #24114: URL: https://github.com/apache/flink/pull/24114#discussion_r1478261465 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/ValuesTestPrograms.java: ## @@ -0,0 +1,38 @@ +/* + * Licensed to

Re: [PR] [FLINK-34118] Implement restore tests for Sort node [flink]

2024-02-05 Thread via GitHub
dawidwys commented on code in PR #24109: URL: https://github.com/apache/flink/pull/24109#discussion_r1478265588 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/SortTestPrograms.java: ## @@ -123,4 +125,66 @@ public class Sort

Re: [PR] [FLINK-33739][doc] Document FLIP-364: Improve the exponential-delay restart-strategy [flink]

2024-02-05 Thread via GitHub
zhuzhurk commented on code in PR #24263: URL: https://github.com/apache/flink/pull/24263#discussion_r1478238605 ## docs/content/docs/ops/state/task_failure_recovery.md: ## @@ -204,6 +203,47 @@ Still not supported in Python API. {{< /tab >}} {{< /tabs >}} + Example + +Her

[jira] [Created] (FLINK-34365) [docs] Delete repeated pages in Chinese Flink website and correct the Paimon url

2024-02-05 Thread Waterking (Jira)
Waterking created FLINK-34365: - Summary: [docs] Delete repeated pages in Chinese Flink website and correct the Paimon url Key: FLINK-34365 URL: https://issues.apache.org/jira/browse/FLINK-34365 Project: F

[jira] [Commented] (FLINK-34365) [docs] Delete repeated pages in Chinese Flink website and correct the Paimon url

2024-02-05 Thread Waterking (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814365#comment-17814365 ] Waterking commented on FLINK-34365: --- This is my first open source contribution to Flin

Re: [PR] [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes [flink]

2024-02-05 Thread via GitHub
XComp commented on code in PR #24248: URL: https://github.com/apache/flink/pull/24248#discussion_r1478245157 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java: ## @@ -337,7 +337,7 @@ public void testCheckpointRescalingNonPartitionedStateC

[jira] [Created] (FLINK-34366) Add support to group rows by column ordinals

2024-02-05 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34366: -- Summary: Add support to group rows by column ordinals Key: FLINK-34366 URL: https://issues.apache.org/jira/browse/FLINK-34366 Project: Flink Issue Type:

[jira] [Closed] (FLINK-34304) Release Testing Instructions: Verify FLINK-34219 Introduce a new join operator to support minibatch

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34304. --- Resolution: Fixed [~xu_shuai_] Thanks for your updates! > Release Testing Instructions: Verify FLIN

[jira] [Assigned] (FLINK-34266) Output ratios should be computed over the whole metric window instead of averaged

2024-02-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-34266: -- Assignee: Gyula Fora > Output ratios should be computed over the whole metric window instead

[jira] [Updated] (FLINK-34288) Release Testing Instructions: Verify FLINK-33735 Improve the exponential-delay restart-strategy

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34288: Attachment: screenshot-1.png > Release Testing Instructions: Verify FLINK-33735 Improve the > exp

[jira] [Closed] (FLINK-34311) Do not change min resource requirements when rescaling for adaptive scheduler

2024-02-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-34311. -- Resolution: Fixed merged to main 4342636cdb2c3439389e83cb4fe4366156edfbd7 > Do not change min resourc

Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink]

2024-02-05 Thread via GitHub
MartijnVisser commented on PR #24224: URL: https://github.com/apache/flink/pull/24224#issuecomment-1927146693 @AlanConfluent Can you look at @twalthr comments, so we can include this before the 1.19.0 release goes out? -- This is an automated message from the Apache Git Service. To respo

[jira] [Updated] (FLINK-34027) Introduce AsyncScalarFunction as a new UDF type

2024-02-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-34027: --- Fix Version/s: 1.19.0 > Introduce AsyncScalarFunction as a new UDF type > --

[jira] [Commented] (FLINK-34027) Introduce AsyncScalarFunction as a new UDF type

2024-02-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814380#comment-17814380 ] Martijn Visser commented on FLINK-34027: Added missing fixVersion number > Intr

[jira] [Updated] (FLINK-34094) Document new AsyncScalarFunction

2024-02-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-34094: --- Fix Version/s: 1.19.0 > Document new AsyncScalarFunction >

Re: [PR] [DRAFT] FLIP-376 DISTRIBUTED BY [flink]

2024-02-05 Thread via GitHub
twalthr commented on PR #24073: URL: https://github.com/apache/flink/pull/24073#issuecomment-1927148744 Replaced by #24155. -- 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] [DRAFT] FLIP-376 DISTRIBUTED BY [flink]

2024-02-05 Thread via GitHub
twalthr closed pull request #24073: [DRAFT] FLIP-376 DISTRIBUTED BY URL: https://github.com/apache/flink/pull/24073 -- 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 unsubscri

[jira] [Commented] (FLINK-34288) Release Testing Instructions: Verify FLINK-33735 Improve the exponential-delay restart-strategy

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814381#comment-17814381 ] lincoln lee commented on FLINK-34288: - [~fanrui] Can you help confirm if this featur

[jira] [Updated] (FLINK-34289) Release Testing Instructions: Verify FLINK-33695 Introduce TraceReporter and use it to create checkpointing and recovery traces

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34289: Attachment: screenshot-1.png > Release Testing Instructions: Verify FLINK-33695 Introduce TraceRep

[jira] [Updated] (FLINK-34294) Release Testing Instructions: Verify FLINK-33297 Support standard YAML for FLINK configuration

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34294: Attachment: screenshot-1.png > Release Testing Instructions: Verify FLINK-33297 Support standard Y

[jira] [Commented] (FLINK-34294) Release Testing Instructions: Verify FLINK-33297 Support standard YAML for FLINK configuration

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814383#comment-17814383 ] lincoln lee commented on FLINK-34294: - [~JunRuiLi] Can you help confirm if this feat

[jira] [Commented] (FLINK-34289) Release Testing Instructions: Verify FLINK-33695 Introduce TraceReporter and use it to create checkpointing and recovery traces

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814382#comment-17814382 ] lincoln lee commented on FLINK-34289: - [~pnowojski] Can you help confirm if this fea

[jira] [Updated] (FLINK-34302) Release Testing Instructions: Verify FLINK-33644 Make QueryOperations SQL serializable

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34302: Attachment: screenshot-1.png > Release Testing Instructions: Verify FLINK-33644 Make QueryOperatio

[jira] [Commented] (FLINK-34302) Release Testing Instructions: Verify FLINK-33644 Make QueryOperations SQL serializable

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814384#comment-17814384 ] lincoln lee commented on FLINK-34302: - [~dwysakowicz] Can you help confirm if this f

[jira] [Updated] (FLINK-34306) Release Testing Instructions: Verify FLINK-25857 Add committer metrics to track the status of committables

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34306: Attachment: screenshot-1.png > Release Testing Instructions: Verify FLINK-25857 Add committer metr

[jira] [Commented] (FLINK-34306) Release Testing Instructions: Verify FLINK-25857 Add committer metrics to track the status of committables

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814386#comment-17814386 ] lincoln lee commented on FLINK-34306: - [~pvary] Can you help confirm if this feature

[jira] [Comment Edited] (FLINK-34306) Release Testing Instructions: Verify FLINK-25857 Add committer metrics to track the status of committables

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814386#comment-17814386 ] lincoln lee edited comment on FLINK-34306 at 2/5/24 2:44 PM: -

[jira] [Comment Edited] (FLINK-34288) Release Testing Instructions: Verify FLINK-33735 Improve the exponential-delay restart-strategy

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814381#comment-17814381 ] lincoln lee edited comment on FLINK-34288 at 2/5/24 2:45 PM: -

[jira] [Updated] (FLINK-34310) Release Testing Instructions: Verify FLINK-33325 Built-in cross-platform powerful java profiler

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34310: Attachment: screenshot-1.png > Release Testing Instructions: Verify FLINK-33325 Built-in cross-pla

[jira] [Updated] (FLINK-34309) Release Testing Instructions: Verify FLINK-33315 Optimize memory usage of large StreamOperator

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34309: Summary: Release Testing Instructions: Verify FLINK-33315 Optimize memory usage of large StreamOpe

[jira] [Commented] (FLINK-34310) Release Testing Instructions: Verify FLINK-33325 Built-in cross-platform powerful java profiler

2024-02-05 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814389#comment-17814389 ] lincoln lee commented on FLINK-34310: - [~Yu Chen] Can you help confirm if this featu

  1   2   3   4   >