[jira] [Updated] (FLINK-38180) Race condition between failing Task and cancelation hiding the real exception

2025-08-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-38180: --- Description: When task fails, during {{Task#restoreAndInvoke}} invocation we will call {{fi

[jira] [Created] (FLINK-38180) Race condition between failing Task and cancelation hiding the real exception

2025-08-01 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-38180: -- Summary: Race condition between failing Task and cancelation hiding the real exception Key: FLINK-38180 URL: https://issues.apache.org/jira/browse/FLINK-38180 Pro

[jira] [Updated] (FLINK-38158) FLIP-484: Add custom metric variables to operators

2025-07-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-38158: --- Fix Version/s: 2.2 (was: 2.1.0) > FLIP-484: Add custom metric variabl

[jira] [Closed] (FLINK-38158) FLIP-484: Add custom metric variables to operators

2025-07-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-38158. -- Release Note: Users can now assign custom metric variables for each operator/transformation us

[jira] [Created] (FLINK-38158) FLIP-484: Add custom metric variables to operators

2025-07-30 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-38158: -- Summary: FLIP-484: Add custom metric variables to operators Key: FLINK-38158 URL: https://issues.apache.org/jira/browse/FLINK-38158 Project: Flink Issue

[jira] [Closed] (FLINK-37426) FLIP-481: Introduce Event Reporting

2025-07-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37426. -- Fix Version/s: 2.2.0 Release Note: Since 2.1.0 users are able to report events using the

[jira] [Updated] (FLINK-37426) FLIP-481: Introduce Event Reporting

2025-07-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37426: --- Release Note: Since 2.1.0 users are able to report custom events using the EventReporters Si

[jira] [Closed] (FLINK-37561) Report system events

2025-07-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37561. -- Fix Version/s: 2.2.0 Resolution: Fixed Merged to master as 26d7e8a76f3..5050dbe7d8c >

[jira] [Assigned] (FLINK-37560) Document events reporting

2025-07-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37560: -- Assignee: Piotr Nowojski > Document events reporting > - > >

[jira] [Closed] (FLINK-37560) Document events reporting

2025-07-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37560. -- Fix Version/s: 2.2.0 Resolution: Fixed merged to master as a54d8c1e706 and 898e15948fd

[jira] [Assigned] (FLINK-37561) Report system events

2025-07-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37561: -- Assignee: Piotr Nowojski > Report system events > > >

[jira] [Closed] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled

2025-07-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-38056. -- Fix Version/s: 2.1 2.2 Resolution: Fixed > Flink doesn't wait for s5

[jira] [Created] (FLINK-38056) Flink doesn't wait for s5cmd to finish when it is being cancelled

2025-07-07 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-38056: -- Summary: Flink doesn't wait for s5cmd to finish when it is being cancelled Key: FLINK-38056 URL: https://issues.apache.org/jira/browse/FLINK-38056 Project: Flink

[jira] [Closed] (FLINK-37807) Report s5cmd cancellation in a nicer way

2025-07-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37807. -- Resolution: Fixed > Report s5cmd cancellation in a nicer way > ---

[jira] [Closed] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci

2025-06-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37822. -- Fix Version/s: 2.1.0 Resolution: Fixed > OpenTelemetryMetricReporterITCase.testReport t

[jira] [Commented] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci

2025-06-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17956845#comment-17956845 ] Piotr Nowojski commented on FLINK-37822: Thanks for fixing the problem [~izeren]

[jira] [Commented] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci

2025-06-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17956844#comment-17956844 ] Piotr Nowojski commented on FLINK-37822: merged 93a34d7 into apache:master > O

[jira] [Assigned] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci

2025-06-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37822: -- Assignee: Aleksandr Iushmanov (was: Piotr Nowojski) > OpenTelemetryMetricReporterITC

[jira] [Updated] (FLINK-37870) Unaligned checkpoint is disabled for all connections unexpectedly

2025-06-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37870: --- Priority: Critical (was: Major) > Unaligned checkpoint is disabled for all connections unex

[jira] [Commented] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci

2025-05-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17954243#comment-17954243 ] Piotr Nowojski commented on FLINK-37822: Hi [~lsy], I will try to take a look la

[jira] [Assigned] (FLINK-37822) OpenTelemetryMetricReporterITCase.testReport test failed of azure ci

2025-05-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37822: -- Assignee: Piotr Nowojski > OpenTelemetryMetricReporterITCase.testReport test failed o

[jira] [Created] (FLINK-37807) Report s5cmd cancellation in a nicer way

2025-05-15 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37807: -- Summary: Report s5cmd cancellation in a nicer way Key: FLINK-37807 URL: https://issues.apache.org/jira/browse/FLINK-37807 Project: Flink Issue Type: Impr

[jira] [Closed] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy

2025-05-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37545. -- Fix Version/s: 1.20.2 2.1.0 2.0.1 Resolution: Fixe

[jira] [Commented] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy

2025-05-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17950328#comment-17950328 ] Piotr Nowojski commented on FLINK-37545: Thanks for reporting the issue [~gliter

[jira] [Assigned] (FLINK-37545) StackOverflowError when using MetricGroup in custom WatermarkStrategy

2025-05-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37545: -- Assignee: Piotr Nowojski > StackOverflowError when using MetricGroup in custom Waterm

[jira] [Commented] (FLINK-37670) Watermark alignment can deadlock job if there are no more splits to be assigned

2025-04-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945039#comment-17945039 ] Piotr Nowojski commented on FLINK-37670: merged commit ad51793 into apache:relea

[jira] [Closed] (FLINK-37670) Watermark alignment can deadlock job if there are no more splits to be assigned

2025-04-16 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37670. -- Fix Version/s: 1.20.2 2.1.0 2.0.1 Resolution: Fixe

[jira] [Commented] (FLINK-37670) Watermark alignment can deadlock job if there are no more splits to be assigned

2025-04-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17944837#comment-17944837 ] Piotr Nowojski commented on FLINK-37670: merged commit 0849018 into apache:maste

[jira] [Created] (FLINK-37670) Watermark alignment can deadlock job if there are no more splits to be assigned

2025-04-14 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37670: -- Summary: Watermark alignment can deadlock job if there are no more splits to be assigned Key: FLINK-37670 URL: https://issues.apache.org/jira/browse/FLINK-37670 P

[jira] [Assigned] (FLINK-37670) Watermark alignment can deadlock job if there are no more splits to be assigned

2025-04-14 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37670: -- Assignee: Piotr Nowojski > Watermark alignment can deadlock job if there are no more

[jira] [Closed] (FLINK-36167) testSinkDisorderChangeLog failed on AZP

2025-04-09 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36167. -- Resolution: Duplicate > testSinkDisorderChangeLog failed on AZP >

[jira] [Closed] (FLINK-37596) Close metric groups for finished splits

2025-04-08 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37596. -- Resolution: Fixed merged commit c57c220 into apache:master > Close metric groups for finishe

[jira] [Assigned] (FLINK-37596) Close metric groups for finished splits

2025-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37596: -- Assignee: Efrat Levitan > Close metric groups for finished splits > -

[jira] [Closed] (FLINK-37570) NullPointerException thrown for split-level watermarks

2025-03-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37570. -- Resolution: Fixed 38262ee into apache:master now > NullPointerException thrown for split-leve

[jira] [Updated] (FLINK-37570) NullPointerException thrown for split-level watermarks

2025-03-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37570: --- Description: {noformat} java.lang.NullPointerException at io.confluent.flink.common.

[jira] [Created] (FLINK-37570) NullPointerException thrown for split-level watermarks

2025-03-27 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37570: -- Summary: NullPointerException thrown for split-level watermarks Key: FLINK-37570 URL: https://issues.apache.org/jira/browse/FLINK-37570 Project: Flink Is

[jira] [Assigned] (FLINK-37426) FLIP-481: Introduce Event Reporting

2025-03-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37426: -- Assignee: Piotr Nowojski > FLIP-481: Introduce Event Reporting >

[jira] [Commented] (FLINK-37426) FLIP-481: Introduce Event Reporting

2025-03-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938604#comment-17938604 ] Piotr Nowojski commented on FLINK-37426: Core code for event reporters merged to

[jira] [Created] (FLINK-37561) Report system events

2025-03-26 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37561: -- Summary: Report system events Key: FLINK-37561 URL: https://issues.apache.org/jira/browse/FLINK-37561 Project: Flink Issue Type: Sub-task Compo

[jira] [Created] (FLINK-37560) Document events reporting

2025-03-26 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37560: -- Summary: Document events reporting Key: FLINK-37560 URL: https://issues.apache.org/jira/browse/FLINK-37560 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-37410) [FLIP-513] Split-level Watermark Metrics

2025-03-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37410: --- Release Note: Users can now access per split metrics: - split's watermark value - split's id

[jira] [Closed] (FLINK-37410) [FLIP-513] Split-level Watermark Metrics

2025-03-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37410. -- Release Note: Users can now access per split metrics: - current watermark value - idle, active

[jira] [Commented] (FLINK-37410) [FLIP-513] Split-level Watermark Metrics

2025-03-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938507#comment-17938507 ] Piotr Nowojski commented on FLINK-37410: merged commit e1c609c into apache:maste

[jira] [Created] (FLINK-37426) FLIP-481: Introduce Event Reporting

2025-03-05 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37426: -- Summary: FLIP-481: Introduce Event Reporting Key: FLINK-37426 URL: https://issues.apache.org/jira/browse/FLINK-37426 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-37410) [FLIP-513] Split-level Watermark Metrics

2025-03-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37410: --- Summary: [FLIP-513] Split-level Watermark Metrics (was: Split-level Watermark Metrics) > [

[jira] [Assigned] (FLINK-37410) Split-level Watermark Metrics

2025-03-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37410: -- Assignee: Efrat Levitan > Split-level Watermark Metrics > ---

[jira] [Updated] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API

2025-03-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37413: --- Reporter: Piotr Nowojski (was: Xuyang Zhong) > Introduce append-only RowTimeDeduplicateFunc

[jira] [Assigned] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API

2025-03-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-37413: -- Assignee: (was: Xuyang Zhong) > Introduce append-only RowTimeDeduplicateFunction

[jira] [Commented] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API

2025-03-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931962#comment-17931962 ] Piotr Nowojski commented on FLINK-37413: FLINK-37005 introduced the sync only ve

[jira] [Created] (FLINK-37413) Introduce append-only RowTimeDeduplicateFunction with Async State API

2025-03-03 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37413: -- Summary: Introduce append-only RowTimeDeduplicateFunction with Async State API Key: FLINK-37413 URL: https://issues.apache.org/jira/browse/FLINK-37413 Project: Fl

[jira] [Closed] (FLINK-37005) Make StreamExecDeduplicate ouput insert only where possible

2025-03-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37005. -- Fix Version/s: 2.1.0 Release Note: Newly submitted deduplication "keep first row" SQL que

[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37399: --- Description: Imagine the following scenario. Max allowed watermark alignment drift is set to

[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37399: --- Description: Imagine the following scenario. Max allowed watermark alignment drift is set to

[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37399: --- Description: Imagine the following scenario. Max allowed watermark alignment drift is set to

[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37399: --- Description: Imagine the following scenario. Max allowed watermark alignment drift is set to

[jira] [Commented] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931219#comment-17931219 ] Piotr Nowojski commented on FLINK-35076: Hi, selecting {{mean}} instead of {{min

[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37399: --- Description: Imagine the following scenario. Max allowed watermark alignment drift is set to

[jira] [Created] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37399: -- Summary: Watermark alignment can prevent backlogged jobs from using all available resources Key: FLINK-37399 URL: https://issues.apache.org/jira/browse/FLINK-37399

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

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931032#comment-17931032 ] Piotr Nowojski commented on FLINK-36324: and another instance (in an internal bu

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

2025-02-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928877#comment-17928877 ] Piotr Nowojski commented on FLINK-36324: another instance (in an internal built)

[jira] [Comment Edited] (FLINK-37271) Add network channel reconnect capability

2025-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926316#comment-17926316 ] Piotr Nowojski edited comment on FLINK-37271 at 2/12/25 9:30 AM: -

[jira] [Commented] (FLINK-37271) Add network channel reconnect capability

2025-02-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926316#comment-17926316 ] Piotr Nowojski commented on FLINK-37271: I'm not concerned about the network thr

[jira] [Commented] (FLINK-37271) Add network channel reconnect capability

2025-02-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925915#comment-17925915 ] Piotr Nowojski commented on FLINK-37271: If I understand correctly, you would li

[jira] [Created] (FLINK-37280) Inconsistent content of TableConfig in planner when mini batch is enabled

2025-02-07 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37280: -- Summary: Inconsistent content of TableConfig in planner when mini batch is enabled Key: FLINK-37280 URL: https://issues.apache.org/jira/browse/FLINK-37280 Project

[jira] [Commented] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

2025-02-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924901#comment-17924901 ] Piotr Nowojski commented on FLINK-35886: Thanks for fixing it! > Incorrect wate

[jira] [Commented] (FLINK-35886) Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked

2025-02-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924419#comment-17924419 ] Piotr Nowojski commented on FLINK-35886: Hi [~afedulov], sorry I was out of offi

[jira] [Comment Edited] (FLINK-37256) Firing timers can block recovery process

2025-02-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923966#comment-17923966 ] Piotr Nowojski edited comment on FLINK-37256 at 2/5/25 9:02 AM: --

[jira] [Comment Edited] (FLINK-37256) Firing timers can block recovery process

2025-02-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923966#comment-17923966 ] Piotr Nowojski edited comment on FLINK-37256 at 2/5/25 8:56 AM: --

[jira] [Commented] (FLINK-37256) Firing timers can block recovery process

2025-02-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17923966#comment-17923966 ] Piotr Nowojski commented on FLINK-37256: I can see two broad solutions. 1. Use

[jira] [Created] (FLINK-37256) Firing timers can block recovery process

2025-02-05 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37256: -- Summary: Firing timers can block recovery process Key: FLINK-37256 URL: https://issues.apache.org/jira/browse/FLINK-37256 Project: Flink Issue Type: Impr

[jira] [Closed] (FLINK-37213) Improve performance of unbounded OVER aggregations

2025-02-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-37213. -- Fix Version/s: 2.1.0 Release Note: Performance of unbounded OVER aggregations in Table AP

[jira] [Updated] (FLINK-37213) Improve performance of unbounded OVER aggregations

2025-01-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37213: --- Affects Version/s: 1.19.1 > Improve performance of unbounded OVER aggregations > ---

[jira] [Created] (FLINK-37213) Improve performance of unbounded OVER aggregations

2025-01-23 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37213: -- Summary: Improve performance of unbounded OVER aggregations Key: FLINK-37213 URL: https://issues.apache.org/jira/browse/FLINK-37213 Project: Flink Issue

[jira] [Created] (FLINK-37005) Make StreamExecDeduplicate ouput insert only where possible

2025-01-03 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37005: -- Summary: Make StreamExecDeduplicate ouput insert only where possible Key: FLINK-37005 URL: https://issues.apache.org/jira/browse/FLINK-37005 Project: Flink

[jira] [Closed] (FLINK-36764) Add checkpoint type to checkpoint trace

2024-11-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36764. -- Resolution: Fixed merged commit 09ad451 into apache:master > Add checkpoint type to checkpoin

[jira] [Assigned] (FLINK-36764) Add checkpoint type to checkpoint trace

2024-11-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-36764: -- Assignee: Piotr Nowojski > Add checkpoint type to checkpoint trace >

[jira] [Created] (FLINK-36764) Add checkpoint type to checkpoint trace

2024-11-21 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-36764: -- Summary: Add checkpoint type to checkpoint trace Key: FLINK-36764 URL: https://issues.apache.org/jira/browse/FLINK-36764 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-36743) Rescale from unaligend checkpoint failed

2024-11-19 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899386#comment-17899386 ] Piotr Nowojski commented on FLINK-36743: I'm not sure. I would also add that the

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

2024-11-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896359#comment-17896359 ] Piotr Nowojski commented on FLINK-34919: Same issue happened in an internal buil

[jira] [Comment Edited] (FLINK-36099) JobIDLoggingITCase fails due to "Cannot find task to fail for execution [...]" info log message in TM logs

2024-11-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895628#comment-17895628 ] Piotr Nowojski edited comment on FLINK-36099 at 11/5/24 2:19 PM: -

[jira] [Closed] (FLINK-36099) JobIDLoggingITCase fails due to "Cannot find task to fail for execution [...]" info log message in TM logs

2024-11-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36099. -- Fix Version/s: 2.0.0 Resolution: Fixed merged commit 0b64b57 into apache:master > JobI

[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails

2024-11-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895627#comment-17895627 ] Piotr Nowojski commented on FLINK-18476: https://dev.azure.com/apache-flink/apac

[jira] [Assigned] (FLINK-36099) JobIDLoggingITCase fails due to "Cannot find task to fail for execution [...]" info log message in TM logs

2024-11-05 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-36099: -- Assignee: Piotr Nowojski > JobIDLoggingITCase fails due to "Cannot find task to fail

[jira] [Closed] (FLINK-36624) Log JobID in SourceCoordinator

2024-11-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36624. -- Fix Version/s: 2.0.0 Resolution: Fixed Merged to master as 4e2057d7e94, 96bb45d1f7f >

[jira] [Commented] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP

2024-11-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17895359#comment-17895359 ] Piotr Nowojski commented on FLINK-36613: https://dev.azure.com/apache-flink/apac

[jira] [Closed] (FLINK-36571) Flink dashboard does not show Busy / Backpressure

2024-10-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36571. -- Resolution: Fixed merged commit ed50ae2 into apache:master abc070b1ed0 into release-1.20 d7bd4

[jira] [Created] (FLINK-36624) Log JobID in SourceCoordinator

2024-10-29 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-36624: -- Summary: Log JobID in SourceCoordinator Key: FLINK-36624 URL: https://issues.apache.org/jira/browse/FLINK-36624 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-36624) Log JobID in SourceCoordinator

2024-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-36624: -- Assignee: Piotr Nowojski > Log JobID in SourceCoordinator > -

[jira] [Assigned] (FLINK-36621) Build failure: StatefulSink not found

2024-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-36621: -- Assignee: LvYanquan > Build failure: StatefulSink not found > ---

[jira] [Commented] (FLINK-36613) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState fails on AZP

2024-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893856#comment-17893856 ] Piotr Nowojski commented on FLINK-36613: {quote} It is very likely that the reas

[jira] [Comment Edited] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API and deprecated method/interface in Sink V2 in 2.0

2024-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893764#comment-17893764 ] Piotr Nowojski edited comment on FLINK-36245 at 10/29/24 10:39 AM: ---

[jira] [Created] (FLINK-36621) Build failure: StatefulSink not found

2024-10-29 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-36621: -- Summary: Build failure: StatefulSink not found Key: FLINK-36621 URL: https://issues.apache.org/jira/browse/FLINK-36621 Project: Flink Issue Type: Improve

[jira] [Commented] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API and deprecated method/interface in Sink V2 in 2.0

2024-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893764#comment-17893764 ] Piotr Nowojski commented on FLINK-36245: Hi [~kunni], [~renqs] and [~leonard]. I

[jira] [Closed] (FLINK-32483) RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails on AZP

2024-10-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-32483. -- Resolution: Fixed > RescaleCheckpointManuallyITCase.testCheckpointRescalingOutKeyedState fails

[jira] [Closed] (FLINK-36555) Guarantee debloated buffer size grows even with very small alpha

2024-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36555. -- Fix Version/s: 2.0.0 Resolution: Fixed Merged to master as d488b7a989d > Guarantee deb

[jira] [Updated] (FLINK-36556) Allow to configure starting buffer size when using buffer debloating

2024-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-36556: --- Release Note: When using buffer debloating, during job's startup or recovery, when we don't

[jira] [Closed] (FLINK-36556) Allow to configure starting buffer size when using buffer debloating

2024-10-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36556. -- Fix Version/s: 2.0.0 Release Note: When using buffer debloating, during job's startup int

[jira] [Closed] (FLINK-33696) FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter

2024-10-24 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-33696. -- Release Note: Flink now supports reporting metrics and traces to OpenTelemetry using gRPC

[jira] [Commented] (FLINK-22887) Backlog based optimizations for RebalancePartitioner and RescalePartitioner (load rebalance)

2024-10-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892205#comment-17892205 ] Piotr Nowojski commented on FLINK-22887: Hi [~vincentwoo], unfortunately there w

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

2024-10-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892172#comment-17892172 ] Piotr Nowojski commented on FLINK-36591: merged commit 28ae3ae into apache:maste

  1   2   3   4   5   6   7   8   9   10   >