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

2025-02-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924495#comment-17924495 ] Matthias Pohl commented on FLINK-34227: --- * master (2.1) ** [aae92a02372b4c316bfd7

[jira] [Created] (FLINK-37259) StreamCheckpointingITCase times out

2025-02-05 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-37259: - Summary: StreamCheckpointingITCase times out Key: FLINK-37259 URL: https://issues.apache.org/jira/browse/FLINK-37259 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-37258) Order Flink Job list in Flink UI with start time

2025-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-37258: -- Fix Version/s: (was: 2.1.0) > Order Flink Job list in Flink UI with start time > -

[jira] [Updated] (FLINK-37258) Order Flink Job list in Flink UI with start time

2025-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-37258: -- Affects Version/s: 1.20.0 > Order Flink Job list in Flink UI with start time > ---

[jira] [Updated] (FLINK-37258) Order Flink Job list in Flink UI with start time

2025-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-37258: -- Affects Version/s: 2.0.0 > Order Flink Job list in Flink UI with start time >

[jira] [Assigned] (FLINK-37258) Order Flink Job list in Flink UI with start time

2025-02-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37258: - Assignee: Ahmed Hamdy > Order Flink Job list in Flink UI with start time >

[jira] [Resolved] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side

2025-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-37232. --- Fix Version/s: 2.0.0 2.1.0 Resolution: Fixed > FLIP-272 breaks som

[jira] [Comment Edited] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side

2025-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923772#comment-17923772 ] Matthias Pohl edited comment on FLINK-37232 at 2/5/25 7:25 AM: ---

[jira] [Comment Edited] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side

2025-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923772#comment-17923772 ] Matthias Pohl edited comment on FLINK-37232 at 2/5/25 7:24 AM: ---

[jira] [Comment Edited] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side

2025-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923772#comment-17923772 ] Matthias Pohl edited comment on FLINK-37232 at 2/4/25 6:32 PM: ---

[jira] [Commented] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side

2025-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923772#comment-17923772 ] Matthias Pohl commented on FLINK-37232: --- master: [5b1d0081b47a05fdd67b2ed89e1cc85

[jira] [Resolved] (FLINK-37214) Refactor TaskSlotTableImplTest away from using the test thread as the main thread

2025-01-29 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-37214. --- Fix Version/s: 2.1.0 Resolution: Fixed master: [750d96c269afbba6ae6dd64d1f27edc8ede2

[jira] [Assigned] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side

2025-01-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37232: - Assignee: Zdenek Tison (was: Matthias Pohl) > FLIP-272 breaks some synchronization ass

[jira] [Assigned] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side

2025-01-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37232: - Assignee: Matthias Pohl > FLIP-272 breaks some synchronization assumption on the Adapti

[jira] [Assigned] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads

2025-01-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37220: - Assignee: Matthias Pohl > GuavaRateLimiter creates an ExecutorService without shutting

[jira] [Assigned] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads

2025-01-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37220: - Assignee: (was: Matthias Pohl) > GuavaRateLimiter creates an ExecutorService withou

[jira] [Assigned] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads

2025-01-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37220: - Assignee: (was: Matthias Pohl) > GuavaRateLimiter creates an ExecutorService withou

[jira] [Created] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side

2025-01-28 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-37232: - Summary: FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side Key: FLINK-37232 URL: https://issues.apache.org/jira/browse/FLINK-37232 Pro

[jira] [Resolved] (FLINK-37170) Disable 1.18 CI

2025-01-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-37170. --- Resolution: Fixed master: [ac4248e62cf40c4e7e7dc9849aed708c19080a83|https://github.com/apac

[jira] [Assigned] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads

2025-01-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37220: - Assignee: Matthias Pohl > GuavaRateLimiter creates an ExecutorService without shutting

[jira] [Updated] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads

2025-01-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-37220: -- Affects Version/s: 2.0-preview 1.19.1 1.20.0 > G

[jira] [Created] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads

2025-01-24 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-37220: - Summary: GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads Key: FLINK-37220 URL: https://issues.apache.org/jira/browse/FLINK-37220

[jira] [Updated] (FLINK-37214) Refactor TaskSlotTableImplTest away from using the test thread as the main thread

2025-01-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-37214: -- Fix Version/s: (was: 2.0.0) > Refactor TaskSlotTableImplTest away from using the test thre

[jira] [Reopened] (FLINK-37214) Refactor TaskSlotTableImplTest away from using the test thread as the main thread

2025-01-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-37214: --- > Refactor TaskSlotTableImplTest away from using the test thread as the main > thread > ---

[jira] [Resolved] (FLINK-37215) SlotAllocationException throwing can be moved from TaskExecutor#allocateSlot to TaskSlotTableImpl#allocateSlot

2025-01-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-37215. --- Fix Version/s: 2.0.0 Resolution: Fixed master: [3b7d3d6e513a94f504423fa1d4dcdb3b77ad

[jira] (FLINK-37214) Refactor TaskSlotTableImplTest away from using the test thread as the main thread

2025-01-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37214 ] Matthias Pohl deleted comment on FLINK-37214: --- was (Author: mapohl): master: [3b7d3d6e513a94f504423fa1d4dcdb3b77adf273|https://github.com/apache/flink/commit/3b7d3d6e513a94f504423fa1d4dcdb

[jira] [Resolved] (FLINK-37214) Refactor TaskSlotTableImplTest away from using the test thread as the main thread

2025-01-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-37214. --- Fix Version/s: 2.0.0 Resolution: Fixed master: [3b7d3d6e513a94f504423fa1d4dcdb3b77ad

[jira] [Updated] (FLINK-37214) Refactor TaskSlotTableImplTest away from using the test thread as the main thread

2025-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-37214: -- Summary: Refactor TaskSlotTableImplTest away from using the test thread as the main thread (w

[jira] [Assigned] (FLINK-37215) SlotAllocationException throwing can be moved from TaskExecutor#allocateSlot to TaskSlotTableImpl#allocateSlot

2025-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37215: - Assignee: Matthias Pohl > SlotAllocationException throwing can be moved from TaskExecut

[jira] [Created] (FLINK-37215) SlotAllocationException throwing can be moved from TaskExecutor#allocateSlot to TaskSlotTableImpl#allocateSlot

2025-01-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-37215: - Summary: SlotAllocationException throwing can be moved from TaskExecutor#allocateSlot to TaskSlotTableImpl#allocateSlot Key: FLINK-37215 URL: https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-37214) Migrate TaskSlotTableImplTest from using the test thread as the main thread

2025-01-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-37214: - Summary: Migrate TaskSlotTableImplTest from using the test thread as the main thread Key: FLINK-37214 URL: https://issues.apache.org/jira/browse/FLINK-37214 Project

[jira] [Assigned] (FLINK-37214) Migrate TaskSlotTableImplTest from using the test thread as the main thread

2025-01-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37214: - Assignee: Matthias Pohl > Migrate TaskSlotTableImplTest from using the test thread as t

[jira] [Updated] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2025-01-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36451: -- Fix Version/s: 2.0.0 1.19.2 1.20.1 > Kubernetes Applicat

[jira] [Updated] (FLINK-14068) Use Java's Duration instead of Flink's Time

2025-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-14068: -- Release Note: The Flink-internal Time classes are replaced by Java's Duration class. All Flink

[jira] [Assigned] (FLINK-37170) Disable 1.18 CI

2025-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-37170: - Assignee: Matthias Pohl > Disable 1.18 CI > --- > > Key: FL

[jira] [Created] (FLINK-37170) Disable 1.18 CI

2025-01-19 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-37170: - Summary: Disable 1.18 CI Key: FLINK-37170 URL: https://issues.apache.org/jira/browse/FLINK-37170 Project: Flink Issue Type: Technical Debt Compon

[jira] [Closed] (FLINK-37127) BuiltInAggregateFunctionTestBase failed on AZP

2025-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-37127. - Resolution: Duplicate Closing this one in favor of FLINK-36324 > BuiltInAggregateFunctionTestBa

[jira] [Commented] (FLINK-36324) MiscAggFunctionITCase expected to raise Throwable

2025-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17914479#comment-17914479 ] Matthias Pohl commented on FLINK-36324: --- Transitioned over from FLINK-37127: https

[jira] [Resolved] (FLINK-28091) Thread leak in CheckpointResourcesCleanupRunnerTest#testCancellationAfterStart

2025-01-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-28091. --- Fix Version/s: 2.0.0 1.19.2 1.20.1 Resolution: F

[jira] [Assigned] (FLINK-28091) Thread leak in CheckpointResourcesCleanupRunnerTest#testCancellationAfterStart

2025-01-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-28091: - Assignee: Matthias Pohl > Thread leak in CheckpointResourcesCleanupRunnerTest#testCance

[jira] [Updated] (FLINK-34194) Upgrade Flink CI Docker container to Ubuntu 22.04

2025-01-03 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34194: -- Fix Version/s: 1.20.1 > Upgrade Flink CI Docker container to Ubuntu 22.04 > --

[jira] [Commented] (FLINK-34194) Upgrade Flink CI Docker container to Ubuntu 22.04

2025-01-03 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909588#comment-17909588 ] Matthias Pohl commented on FLINK-34194: --- Updated merge history after merging the b

[jira] [Commented] (FLINK-36510) Upgrade Pekko from 1.0.1 to 1.1.2

2024-12-29 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17908704#comment-17908704 ] Matthias Pohl commented on FLINK-36510: --- I created FLINK-36979 as a release blocke

[jira] [Assigned] (FLINK-36979) Revert netty bump for 1.20 and 1.19

2024-12-29 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-36979: - Assignee: Matthias Pohl > Revert netty bump for 1.20 and 1.19 > ---

[jira] [Created] (FLINK-36979) Revert netty bump for 1.20 and 1.19

2024-12-29 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-36979: - Summary: Revert netty bump for 1.20 and 1.19 Key: FLINK-36979 URL: https://issues.apache.org/jira/browse/FLINK-36979 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-36912) Shaded Hadoop S3A with credentials provider failed on AZP

2024-12-17 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-36912. --- Resolution: Fixed I'm closing this one. Feel free to open it again if you think that it's no

[jira] [Commented] (FLINK-36912) Shaded Hadoop S3A with credentials provider failed on AZP

2024-12-17 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17906322#comment-17906322 ] Matthias Pohl commented on FLINK-36912: --- This was an infrastructure issue that was

[jira] [Resolved] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-12-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-36451. --- Resolution: Fixed > Kubernetes Application JobManager Potential Deadlock and TaskManager Pod

[jira] [Comment Edited] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-12-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904388#comment-17904388 ] Matthias Pohl edited comment on FLINK-36451 at 12/11/24 3:41 PM: -

[jira] [Commented] (FLINK-36888) Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out

2024-12-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904830#comment-17904830 ] Matthias Pohl commented on FLINK-36888: --- The issue appeared when creating the 1.19

[jira] [Updated] (FLINK-36888) Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out

2024-12-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36888: -- Attachment: build-64250.log > Building flink-shaded-netty-tcnative-static for the OpenSSL e2e

[jira] [Updated] (FLINK-36888) Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out

2024-12-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36888: -- Description: The following build timed out in the e2e #2 stage: https://dev.azure.com/apache-

[jira] [Created] (FLINK-36888) Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out

2024-12-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-36888: - Summary: Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out Key: FLINK-36888 URL: https://issues.apache.org/jira/browse/FLINK-36888 Pro

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

2024-12-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-34672. - Resolution: Duplicate I forgot that I already worked on this issue. -.- Anyway, there a duplicat

[jira] [Commented] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-12-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904388#comment-17904388 ] Matthias Pohl commented on FLINK-36451: --- * master: ** [b32181bb95d8865b8d3eac3c6a

[jira] [Commented] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-12-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904215#comment-17904215 ] Matthias Pohl commented on FLINK-36451: --- Fix is merged to {{master}}. I'm preparin

[jira] [Updated] (FLINK-36073) ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins

2024-12-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36073: -- Affects Version/s: 1.20.0 (was: 1.20.1) > ApplicationMode with the

[jira] [Updated] (FLINK-36594) HiveCatalog should set HiveConf.hiveSiteLocation back

2024-12-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36594: -- Affects Version/s: 1.20.0 (was: 1.20.1) > HiveCatalog should set Hi

[jira] [Updated] (FLINK-36161) Integration Test Example uses deprecated SinkFunction

2024-12-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36161: -- Affects Version/s: (was: 1.20.1) > Integration Test Example uses deprecated SinkFunction >

[jira] [Updated] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok

2024-12-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36612: -- Affects Version/s: 1.20.0 (was: 1.20.1) > Flink TypeSerializer does

[jira] [Updated] (FLINK-36591) WikipediaEditsSourceTest fails in all cases

2024-12-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36591: -- Affects Version/s: 1.20.0 (was: 1.20.1) > WikipediaEditsSourceTest

[jira] [Updated] (FLINK-36021) Delegating the responsibility for compression to every tier

2024-12-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36021: -- Affects Version/s: 1.20.0 (was: 1.20.1) > Delegating the responsibi

[jira] [Updated] (FLINK-36059) SqlClientITCase failed due to could not create/start container

2024-12-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36059: -- Affects Version/s: 1.20.0 (was: 1.20.1) > SqlClientITCase failed du

[jira] [Resolved] (FLINK-36194) Shutdown hook for ExecutionGraphInfo store runs concurrently to cluster shutdown hook causing race conditions

2024-12-01 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-36194. --- Fix Version/s: 2.0.0 Resolution: Fixed master: [82ca1042870a5e9b44da8b3a76ea6c9e20f3

[jira] [Comment Edited] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895936#comment-17895936 ] Matthias Pohl edited comment on FLINK-36451 at 11/27/24 2:34 PM: -

[jira] [Comment Edited] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895936#comment-17895936 ] Matthias Pohl edited comment on FLINK-36451 at 11/27/24 2:33 PM: -

[jira] [Updated] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes

2024-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35315: -- Priority: Critical (was: Major) > MemoryManagerConcurrentModReleaseTest executes more than 15

[jira] [Updated] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes

2024-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35315: -- Affects Version/s: 2.0-preview > MemoryManagerConcurrentModReleaseTest executes more than 15 m

[jira] [Updated] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes

2024-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35315: -- Labels: test-stability (was: ) > MemoryManagerConcurrentModReleaseTest executes more than 15

[jira] [Commented] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes

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

[jira] [Assigned] (FLINK-36512) Make rescale trigger based on failed checkpoints depend on the cause

2024-11-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-36512: - Assignee: Prashant Bhardwaj > Make rescale trigger based on failed checkpoints depend o

[jira] [Commented] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-11-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895936#comment-17895936 ] Matthias Pohl commented on FLINK-36451: --- The problem is that we have two code path

[jira] [Resolved] (FLINK-36623) Improve logging in DefaultStateTransitionManager

2024-11-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-36623. --- Fix Version/s: 2.0.0 Resolution: Fixed master: [21eea0d2ddeea14a791c13c9595d8cb54e9f

[jira] [Commented] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-11-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895568#comment-17895568 ] Matthias Pohl commented on FLINK-36451: --- Thanks for sharing, [~xiechenling]. I wil

[jira] [Assigned] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-11-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-36451: - Assignee: Matthias Pohl > Kubernetes Application JobManager Potential Deadlock and Task

[jira] [Updated] (FLINK-36623) Improve logging in DefaultStateTransitionManager

2024-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36623: -- Fix Version/s: (was: 1.20.1) > Improve logging in DefaultStateTransitionManager >

[jira] [Updated] (FLINK-36623) Improve logging in DefaultStateTransitionManager

2024-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36623: -- Component/s: Runtime / Coordination > Improve logging in DefaultStateTransitionManager > -

[jira] [Updated] (FLINK-36623) Improve logging in DefaultStateTransitionManager

2024-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36623: -- Affects Version/s: 2.0-preview 2.0.0 > Improve logging in DefaultStateT

[jira] [Updated] (FLINK-36451) Kubernetes Application JobManager Potential Deadlock and TaskManager Pod Residuals

2024-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36451: -- Component/s: Runtime / Coordination > Kubernetes Application JobManager Potential Deadlock and

[jira] [Commented] (FLINK-36512) Make rescale trigger based on failed checkpoints depend on the cause

2024-11-03 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895205#comment-17895205 ] Matthias Pohl commented on FLINK-36512: --- Sorry for the late response, [~prbhardwaj

[jira] [Assigned] (FLINK-36317) Populate the ArchivedExecutionGraph with CheckpointStatsSnapshot data if in WaitingForResources state with a previousExecutionGraph being set

2024-10-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-36317: - Assignee: Eaugene Thomas > Populate the ArchivedExecutionGraph with CheckpointStatsSnap

[jira] [Commented] (FLINK-36570) Fatal error occurred in the cluster entrypoint

2024-10-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891392#comment-17891392 ] Matthias Pohl commented on FLINK-36570: --- Hi [~zyhh], one way to elect a new leader

[jira] [Commented] (FLINK-36570) Fatal error occurred in the cluster entrypoint

2024-10-18 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890918#comment-17890918 ] Matthias Pohl commented on FLINK-36570: --- Hi [~zyhh]. Can you share the JobManager

[jira] [Updated] (FLINK-36570) Fatal error occurred in the cluster entrypoint

2024-10-18 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36570: -- Description: I commit batch jobs to my session cluster with rest api. The jobmanager pod woul

[jira] [Comment Edited] (FLINK-36570) Fatal error occurred in the cluster entrypoint

2024-10-18 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890918#comment-17890918 ] Matthias Pohl edited comment on FLINK-36570 at 10/18/24 11:50 AM:

[jira] [Updated] (FLINK-36570) Fatal error occurred in the cluster entrypoint

2024-10-18 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36570: -- Description: I commit batch jobs to my session cluster with rest api. The jobmanager pod woul

[jira] [Updated] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

2024-10-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34063: -- Fix Version/s: 1.19.0 > When snapshot compression is enabled, rescaling of a source operator l

[jira] [Commented] (FLINK-36370) Flink 1.18 fails with Empty server certificate chain when High Availability and mTLS both enabled

2024-10-12 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1759#comment-1759 ] Matthias Pohl commented on FLINK-36370: --- Hi [~aniruddhj], that sounds like it's a

[jira] [Updated] (FLINK-36370) Flink 1.18 fails with Empty server certificate chain when High Availability and mTLS both enabled

2024-10-12 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36370: -- Component/s: Kubernetes Operator Runtime / Coordination > Flink 1.18 fails wi

[jira] [Updated] (FLINK-36370) Flink 1.18 fails with Empty server certificate chain when High Availability and mTLS both enabled

2024-10-12 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36370: -- Affects Version/s: 1.18.1 kubernetes-operator-1.7.0 > Flink 1.18 fails

[jira] [Created] (FLINK-36512) Make rescale trigger based on failed checkpoints depend on the cause

2024-10-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-36512: - Summary: Make rescale trigger based on failed checkpoints depend on the cause Key: FLINK-36512 URL: https://issues.apache.org/jira/browse/FLINK-36512 Project: Flink

[jira] [Comment Edited] (FLINK-14068) Use Java's Duration instead of Flink's Time

2024-09-29 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882175#comment-17882175 ] Matthias Pohl edited comment on FLINK-14068 at 9/29/24 2:32 PM: --

[jira] [Comment Edited] (FLINK-14068) Use Java's Duration instead of Flink's Time

2024-09-29 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17882175#comment-17882175 ] Matthias Pohl edited comment on FLINK-14068 at 9/29/24 2:30 PM: --

[jira] [Commented] (FLINK-36356) HadoopRecoverableWriterTest.testRecoverWithState due to IOException

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

[jira] [Commented] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager

2024-09-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884537#comment-17884537 ] Matthias Pohl commented on FLINK-36011: --- master: [c869326d089705475481c2c2ea42a6e

[jira] [Resolved] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode

2024-09-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-35035. --- Resolution: Fixed Closing this parent issue. All subtasks are addressed and the no new test

[jira] [Updated] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode

2024-09-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35035: -- Fix Version/s: 2.0-preview > Reduce job pause time when cluster resources are expanded in adap

[jira] [Commented] (FLINK-36290) OutOfMemoryError in connect test run

2024-09-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884181#comment-17884181 ] Matthias Pohl commented on FLINK-36290: --- We also see constant e2e test failures (t

[jira] [Commented] (FLINK-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side

2024-09-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884180#comment-17884180 ] Matthias Pohl commented on FLINK-36291: --- This one is a bit unclear. The core test

[jira] [Comment Edited] (FLINK-36290) OutOfMemoryError in connect test run

2024-09-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884172#comment-17884172 ] Matthias Pohl edited comment on FLINK-36290 at 9/24/24 8:21 AM: --

  1   2   3   4   5   6   7   8   9   10   >