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

[ https://issues.apache.org/jira/browse/FLINK-36356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886310#comment-17886310 ] Piotr Nowojski commented on FLINK-36356: https://dev.azure.com/apache-flink/apac

[jira] [Closed] (FLINK-36260) numBytesInLocal and numBuffersInLocal being reported as remote

[ https://issues.apache.org/jira/browse/FLINK-36260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36260. -- Fix Version/s: 2.0.0 1.19.2 1.20.1 Resolution: Fix

[jira] [Created] (FLINK-36416) Enable splittable timers for temporal join, temporal sort and windowed aggregation in SQL/Table API

Piotr Nowojski created FLINK-36416: -- Summary: Enable splittable timers for temporal join, temporal sort and windowed aggregation in SQL/Table API Key: FLINK-36416 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Assigned] (FLINK-36416) Enable splittable timers for temporal join, temporal sort and windowed aggregation in SQL/Table API

[ https://issues.apache.org/jira/browse/FLINK-36416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-36416: -- Assignee: Piotr Nowojski > Enable splittable timers for temporal join, temporal sort

[jira] [Closed] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35764. -- Fix Version/s: 2.0.0 1.19.2 1.20.1 Resolution: Fix

[jira] [Assigned] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35764: -- Assignee: Liu Liu > TimerGauge is incorrect when update is called during a measuremen

[jira] [Updated] (FLINK-34064) FLIP-417: Expose JobManagerOperatorMetrics via REST API

[ https://issues.apache.org/jira/browse/FLINK-34064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-34064: --- Summary: FLIP-417: Expose JobManagerOperatorMetrics via REST API (was: FLIP-471: Expose Job

[jira] [Created] (FLINK-36260) numBytesInLocal and numBuffersInLocal being reported as remote

Piotr Nowojski created FLINK-36260: -- Summary: numBytesInLocal and numBuffersInLocal being reported as remote Key: FLINK-36260 URL: https://issues.apache.org/jira/browse/FLINK-36260 Project: Flink

[jira] [Updated] (FLINK-35739) FLIP-444: Native file copy support

[ https://issues.apache.org/jira/browse/FLINK-35739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-35739: --- Release Note: Users can now configure Flink to use s5cmd to speed up downloading files from

[jira] [Closed] (FLINK-35739) FLIP-444: Native file copy support

[ https://issues.apache.org/jira/browse/FLINK-35739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35739. -- Fix Version/s: 2.0.0 Release Note: Users can now configure Flink to use s5cmd to speed up

[jira] [Closed] (FLINK-35773) Document s5cmd

[ https://issues.apache.org/jira/browse/FLINK-35773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35773. -- Resolution: Fixed merged commit 20e6d63 into apache:master > Document s5cmd > --

[jira] [Closed] (FLINK-35772) Deprecate/remove DuplicatingFileSystem

[ https://issues.apache.org/jira/browse/FLINK-35772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35772. -- Fix Version/s: 2.0.0 Resolution: Fixed merged commit 56c8199 into apache:master > Depr

[jira] [Closed] (FLINK-36108) Wait for state download on cancellation to enforce cleanup

[ https://issues.apache.org/jira/browse/FLINK-36108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-36108. -- Fix Version/s: 2.0.0 Resolution: Fixed Merged as 576b30820ff to master > Wait for stat

[jira] [Closed] (FLINK-35771) Limit s5cmd resource usage

[ https://issues.apache.org/jira/browse/FLINK-35771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35771. -- Fix Version/s: 2.0.0 Resolution: Fixed merged as 0daca7b6db8 to master > Limit s5cmd r

[jira] [Comment Edited] (FLINK-35770) Interrupt s5cmd call on cancellation

[ https://issues.apache.org/jira/browse/FLINK-35770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876622#comment-17876622 ] Piotr Nowojski edited comment on FLINK-35770 at 8/26/24 8:16 AM: -

[jira] [Closed] (FLINK-35770) Interrupt s5cmd call on cancellation

[ https://issues.apache.org/jira/browse/FLINK-35770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35770. -- Fix Version/s: 2.0.0 Resolution: Fixed merged as 0daca7b6db8 to master > Interrupt s5c

[jira] [Assigned] (FLINK-35773) Document s5cmd

[ https://issues.apache.org/jira/browse/FLINK-35773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35773: -- Assignee: Piotr Nowojski > Document s5cmd > -- > > Key: F

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

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35886. -- Fix Version/s: 2.0.0 1.19.2 1.20.1 Release Note: Fo

[jira] [Assigned] (FLINK-35772) Deprecate/remove DuplicatingFileSystem

[ https://issues.apache.org/jira/browse/FLINK-35772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35772: -- Assignee: Piotr Nowojski > Deprecate/remove DuplicatingFileSystem > -

[jira] [Created] (FLINK-36108) Wait for state download on cancellation to enforce cleanup

Piotr Nowojski created FLINK-36108: -- Summary: Wait for state download on cancellation to enforce cleanup Key: FLINK-36108 URL: https://issues.apache.org/jira/browse/FLINK-36108 Project: Flink

[jira] [Assigned] (FLINK-35771) Limit s5cmd resource usage

[ https://issues.apache.org/jira/browse/FLINK-35771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35771: -- Assignee: Piotr Nowojski > Limit s5cmd resource usage > -- >

[jira] [Assigned] (FLINK-35770) Interrupt s5cmd call on cancellation

[ https://issues.apache.org/jira/browse/FLINK-35770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35770: -- Assignee: Piotr Nowojski > Interrupt s5cmd call on cancellation > --

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

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874458#comment-17874458 ] Piotr Nowojski commented on FLINK-35886: Merged to master as 308f05a911d..5f6200

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

[ https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869613#comment-17869613 ] Piotr Nowojski commented on FLINK-33696: This got blocked a bit, but I hope we w

[jira] [Commented] (FLINK-35899) Accumulated TumblingProcessingTimeWindows in the state for a few days

[ https://issues.apache.org/jira/browse/FLINK-35899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868956#comment-17868956 ] Piotr Nowojski commented on FLINK-35899: {quote} how flink decides what timers

[jira] [Commented] (FLINK-35899) Accumulated TumblingProcessingTimeWindows in the state for a few days

[ https://issues.apache.org/jira/browse/FLINK-35899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868932#comment-17868932 ] Piotr Nowojski commented on FLINK-35899: Partially. FLIP-443/FLINK-20217 would h

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

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868098#comment-17868098 ] Piotr Nowojski edited comment on FLINK-35886 at 7/23/24 3:45 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868098#comment-17868098 ] Piotr Nowojski commented on FLINK-35886: I think this problem requires a public

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

[ https://issues.apache.org/jira/browse/FLINK-35886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35886: -- Assignee: Piotr Nowojski > Incorrect watermark idleness timeout accounting when subta

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

Piotr Nowojski created FLINK-35886: -- Summary: Incorrect watermark idleness timeout accounting when subtask is backpressured/blocked Key: FLINK-35886 URL: https://issues.apache.org/jira/browse/FLINK-35886

[jira] [Commented] (FLINK-35860) S5CmdOnMinioITCase failed due to IllegalAccessError in JDK17/21

[ https://issues.apache.org/jira/browse/FLINK-35860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867284#comment-17867284 ] Piotr Nowojski commented on FLINK-35860: Thanks for closing the ticket [~Weijie

[jira] [Assigned] (FLINK-35860) S5CmdOnMinioITCase failed due to IllegalAccessError in JDK17/21

[ https://issues.apache.org/jira/browse/FLINK-35860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35860: -- Assignee: Piotr Nowojski > S5CmdOnMinioITCase failed due to IllegalAccessError in JDK

[jira] [Closed] (FLINK-35767) Provide native file copy support for S3 using s5cmd

[ https://issues.apache.org/jira/browse/FLINK-35767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35767. -- Fix Version/s: 2.0.0 1.20.0 Resolution: Fixed Merged to master as 5c

[jira] [Closed] (FLINK-35768) Use native file copy in RocksDBStateDownloader

[ https://issues.apache.org/jira/browse/FLINK-35768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35768. -- Fix Version/s: 2.0.0 1.20.0 Resolution: Fixed Merged to master as 95

[jira] [Closed] (FLINK-35821) ResumeCheckpointManuallyITCase failed with File X does not exist or the user running Flink C has insufficient permissions to access it

[ https://issues.apache.org/jira/browse/FLINK-35821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35821. -- Resolution: Duplicate > ResumeCheckpointManuallyITCase failed with File X does not exist or th

[jira] [Commented] (FLINK-35821) ResumeCheckpointManuallyITCase failed with File X does not exist or the user running Flink C has insufficient permissions to access it

[ https://issues.apache.org/jira/browse/FLINK-35821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865353#comment-17865353 ] Piotr Nowojski commented on FLINK-35821: Thanks for the update. After rebasing a

[jira] [Comment Edited] (FLINK-35754) SqlGatewayE2ECase.testMaterializedTableInFullMode failed due to Internal Server Error

[ https://issues.apache.org/jira/browse/FLINK-35754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865115#comment-17865115 ] Piotr Nowojski edited comment on FLINK-35754 at 7/11/24 3:08 PM: -

[jira] [Commented] (FLINK-35754) SqlGatewayE2ECase.testMaterializedTableInFullMode failed due to Internal Server Error

[ https://issues.apache.org/jira/browse/FLINK-35754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865115#comment-17865115 ] Piotr Nowojski commented on FLINK-35754: [~hackergin], can you elaborate what's

[jira] [Updated] (FLINK-35821) ResumeCheckpointManuallyITCase failed with File X does not exist or the user running Flink C has insufficient permissions to access it

[ https://issues.apache.org/jira/browse/FLINK-35821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-35821: --- Description: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=60857&vi

[jira] [Updated] (FLINK-35821) ResumeCheckpointManuallyITCase failed with File X does not exist or the user running Flink C has insufficient permissions to access it

[ https://issues.apache.org/jira/browse/FLINK-35821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-35821: --- Description: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=60857&vi

[jira] [Created] (FLINK-35821) ResumeCheckpointManuallyITCase failed with File X does not exist or the user running Flink C has insufficient permissions to access it

Piotr Nowojski created FLINK-35821: -- Summary: ResumeCheckpointManuallyITCase failed with File X does not exist or the user running Flink C has insufficient permissions to access it Key: FLINK-35821 URL: https://i

[jira] [Created] (FLINK-35773) Document s5cmd

Piotr Nowojski created FLINK-35773: -- Summary: Document s5cmd Key: FLINK-35773 URL: https://issues.apache.org/jira/browse/FLINK-35773 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Assigned] (FLINK-35768) Use native file copy in RocksDBStateDownloader

[ https://issues.apache.org/jira/browse/FLINK-35768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35768: -- Assignee: Piotr Nowojski > Use native file copy in RocksDBStateDownloader > -

[jira] [Created] (FLINK-35772) Deprecate/remove DuplicatingFileSystem

Piotr Nowojski created FLINK-35772: -- Summary: Deprecate/remove DuplicatingFileSystem Key: FLINK-35772 URL: https://issues.apache.org/jira/browse/FLINK-35772 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-35770) Interrupt s5cmd call on cancellation

Piotr Nowojski created FLINK-35770: -- Summary: Interrupt s5cmd call on cancellation Key: FLINK-35770 URL: https://issues.apache.org/jira/browse/FLINK-35770 Project: Flink Issue Type: Sub-tas

[jira] [Assigned] (FLINK-35767) Provide native file copy support for S3 using s5cmd

[ https://issues.apache.org/jira/browse/FLINK-35767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35767: -- Assignee: Piotr Nowojski > Provide native file copy support for S3 using s5cmd >

[jira] [Assigned] (FLINK-35739) FLIP-444: Native file copy support

[ https://issues.apache.org/jira/browse/FLINK-35739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35739: -- Assignee: Piotr Nowojski > FLIP-444: Native file copy support > -

[jira] [Created] (FLINK-35771) Limit s5cmd resource usage

Piotr Nowojski created FLINK-35771: -- Summary: Limit s5cmd resource usage Key: FLINK-35771 URL: https://issues.apache.org/jira/browse/FLINK-35771 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35767) Provide native file copy support for S3 using s5cmd

Piotr Nowojski created FLINK-35767: -- Summary: Provide native file copy support for S3 using s5cmd Key: FLINK-35767 URL: https://issues.apache.org/jira/browse/FLINK-35767 Project: Flink Issue

[jira] [Created] (FLINK-35768) Use native file copy in RocksDBStateDownloader

Piotr Nowojski created FLINK-35768: -- Summary: Use native file copy in RocksDBStateDownloader Key: FLINK-35768 URL: https://issues.apache.org/jira/browse/FLINK-35768 Project: Flink Issue Type

[jira] [Updated] (FLINK-35739) FLIP-444: Native file copy support

[ https://issues.apache.org/jira/browse/FLINK-35739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-35739: --- Component/s: Runtime / State Backends > FLIP-444: Native file copy support > ---

[jira] [Created] (FLINK-35739) FLIP-444: Native file copy support

Piotr Nowojski created FLINK-35739: -- Summary: FLIP-444: Native file copy support Key: FLINK-35739 URL: https://issues.apache.org/jira/browse/FLINK-35739 Project: Flink Issue Type: New Featur

[jira] [Closed] (FLINK-35614) Release Testing Instructions: Verify FLIP-443: Interruptible timers firing

[ https://issues.apache.org/jira/browse/FLINK-35614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35614. -- Resolution: Won't Fix I think there is no need to test this feature: * it is already covered b

[jira] [Comment Edited] (FLINK-25646) Document buffer debloating issues with high parallelism

[ https://issues.apache.org/jira/browse/FLINK-25646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859595#comment-17859595 ] Piotr Nowojski edited comment on FLINK-25646 at 6/24/24 7:39 AM: -

[jira] [Commented] (FLINK-25646) Document buffer debloating issues with high parallelism

[ https://issues.apache.org/jira/browse/FLINK-25646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859595#comment-17859595 ] Piotr Nowojski commented on FLINK-25646: Yes, that would be the best. Neither me

[jira] [Commented] (FLINK-25646) Document buffer debloating issues with high parallelism

[ https://issues.apache.org/jira/browse/FLINK-25646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856273#comment-17856273 ] Piotr Nowojski commented on FLINK-25646: Hi [~hejufang001]. No, there have been

[jira] [Commented] (FLINK-35629) Performance regression in stringRead and stringWrite

[ https://issues.apache.org/jira/browse/FLINK-35629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856172#comment-17856172 ] Piotr Nowojski commented on FLINK-35629: It's strange, why JMH upgrade is causin

[jira] [Closed] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-34252. -- Fix Version/s: 1.19.2 Resolution: Fixed merged to release-1.18 as b60318ba1a7^ and b603

[jira] [Commented] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855830#comment-17855830 ] Piotr Nowojski commented on FLINK-34252: Merged to master as d93e92c665a and d93

[jira] [Assigned] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-34252: -- Assignee: Piotr Nowojski (was: David Christle) > WatermarkAssignerOperator should no

[jira] [Closed] (FLINK-20217) More fine-grained timer processing

[ https://issues.apache.org/jira/browse/FLINK-20217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-20217. -- Release Note: Firing timers can now be interrupted to speed up checkpointing. Timers that wer

[jira] (FLINK-20217) More fine-grained timer processing

[ https://issues.apache.org/jira/browse/FLINK-20217 ] Piotr Nowojski deleted comment on FLINK-20217: was (Author: pnowojski): Firing timers can now be interrupted to speed up checkpointing. Timers that were interrupted by a checkpoint, will

[jira] [Reopened] (FLINK-20217) More fine-grained timer processing

[ https://issues.apache.org/jira/browse/FLINK-20217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-20217: > More fine-grained timer processing > -- > >

[jira] [Closed] (FLINK-20217) More fine-grained timer processing

[ https://issues.apache.org/jira/browse/FLINK-20217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-20217. -- Fix Version/s: 1.20.0 Resolution: Fixed Firing timers can now be interrupted to speed u

[jira] [Closed] (FLINK-35528) Skip execution of interruptible mails when yielding

[ https://issues.apache.org/jira/browse/FLINK-35528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35528. -- Fix Version/s: 1.20.0 Resolution: Fixed merged commit 77cd1cd into apache:master now >

[jira] [Commented] (FLINK-20217) More fine-grained timer processing

[ https://issues.apache.org/jira/browse/FLINK-20217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854413#comment-17854413 ] Piotr Nowojski commented on FLINK-20217: Merged to master as 503593ab2d4..986d06

[jira] [Created] (FLINK-35528) Skip execution of interruptible mails when yielding

Piotr Nowojski created FLINK-35528: -- Summary: Skip execution of interruptible mails when yielding Key: FLINK-35528 URL: https://issues.apache.org/jira/browse/FLINK-35528 Project: Flink Issue

[jira] [Updated] (FLINK-35518) CI Bot doesn't run on PRs - status UNKNOWN

[ https://issues.apache.org/jira/browse/FLINK-35518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-35518: --- Summary: CI Bot doesn't run on PRs - status UNKNOWN (was: CI Bot doesn't run on PRs) > CI

[jira] [Created] (FLINK-35518) CI Bot doesn't run on PRs

Piotr Nowojski created FLINK-35518: -- Summary: CI Bot doesn't run on PRs Key: FLINK-35518 URL: https://issues.apache.org/jira/browse/FLINK-35518 Project: Flink Issue Type: Bug Compo

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

[ https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850965#comment-17850965 ] Piotr Nowojski edited comment on FLINK-30719 at 5/31/24 8:11 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850965#comment-17850965 ] Piotr Nowojski commented on FLINK-30719: {noformat} 14:47:52.892 [ERROR] Failed

[jira] [Closed] (FLINK-32142) Apple Silicon Support: Unable to Build Flink Project due to "Bad CPU Type" Error

[ https://issues.apache.org/jira/browse/FLINK-32142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-32142. -- Resolution: Fixed merged commit d075c9f into apache:master > Apple Silicon Support: Unable to

[jira] (FLINK-28260) flink-runtime-web fails to execute "npm ci" on Apple Silicon (arm64) without rosetta

[ https://issues.apache.org/jira/browse/FLINK-28260 ] Piotr Nowojski deleted comment on FLINK-28260: was (Author: pnowojski): merged commit d075c9f into apache:master > flink-runtime-web fails to execute "npm ci" on Apple Silicon (arm64) wi

[jira] [Commented] (FLINK-28260) flink-runtime-web fails to execute "npm ci" on Apple Silicon (arm64) without rosetta

[ https://issues.apache.org/jira/browse/FLINK-28260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850963#comment-17850963 ] Piotr Nowojski commented on FLINK-28260: merged commit d075c9f into apache:maste

[jira] [Closed] (FLINK-35351) Restore from unaligned checkpoints with a custom partitioner fails.

[ https://issues.apache.org/jira/browse/FLINK-35351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35351. -- Fix Version/s: 1.18.2 1.20.0 1.19.1 Resolution: Fi

[jira] [Updated] (FLINK-35420) WordCountMapredITCase fails to compile in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-35420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-35420: --- Fix Version/s: 1.20.0 > WordCountMapredITCase fails to compile in IntelliJ > ---

[jira] [Assigned] (FLINK-35420) WordCountMapredITCase fails to compile in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-35420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35420: -- Assignee: Piotr Nowojski > WordCountMapredITCase fails to compile in IntelliJ > -

[jira] [Closed] (FLINK-35420) WordCountMapredITCase fails to compile in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-35420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35420. -- Resolution: Fixed 9ccfb65 into apache:master now > WordCountMapredITCase fails to compile in

[jira] [Created] (FLINK-35420) WordCountMapredITCase fails to compile in IntelliJ

Piotr Nowojski created FLINK-35420: -- Summary: WordCountMapredITCase fails to compile in IntelliJ Key: FLINK-35420 URL: https://issues.apache.org/jira/browse/FLINK-35420 Project: Flink Issue

[jira] [Closed] (FLINK-32828) Partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-32828. -- Fix Version/s: 2.0.0 1.18.2 1.20.0 1.1

[jira] [Commented] (FLINK-35351) Restore from unaligned checkpoints with a custom partitioner fails.

[ https://issues.apache.org/jira/browse/FLINK-35351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846869#comment-17846869 ] Piotr Nowojski commented on FLINK-35351: Thanks, after reading the PR indeed I u

[jira] [Updated] (FLINK-32828) Partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-32828: --- Summary: Partition aware watermark not handled correctly shortly after job start up from che

[jira] [Comment Edited] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846694#comment-17846694 ] Piotr Nowojski edited comment on FLINK-32828 at 5/15/24 4:27 PM: -

[jira] [Commented] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846694#comment-17846694 ] Piotr Nowojski commented on FLINK-32828: We have just stumbled upon the same iss

[jira] [Updated] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-32828: --- Priority: Critical (was: Major) > Kafka partition aware watermark not handled correctly sho

[jira] [Updated] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-32828: --- Affects Version/s: 1.18.1 1.19.0 > Kafka partition aware watermark no

[jira] [Assigned] (FLINK-32828) Kafka partition aware watermark not handled correctly shortly after job start up from checkpoint or savepoint

[ https://issues.apache.org/jira/browse/FLINK-32828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-32828: -- Assignee: Piotr Nowojski > Kafka partition aware watermark not handled correctly shor

[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846597#comment-17846597 ] Piotr Nowojski commented on FLINK-33109: Hi! {quote} I guess this bug has been

[jira] [Comment Edited] (FLINK-35351) Restore from unaligned checkpoints with a custom partitioner fails.

[ https://issues.apache.org/jira/browse/FLINK-35351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846231#comment-17846231 ] Piotr Nowojski edited comment on FLINK-35351 at 5/14/24 9:11 AM: -

[jira] [Commented] (FLINK-35351) Restore from unaligned checkpoints with a custom partitioner fails.

[ https://issues.apache.org/jira/browse/FLINK-35351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846231#comment-17846231 ] Piotr Nowojski commented on FLINK-35351: Hi [~lda-dima], thanks for reporting th

[jira] [Assigned] (FLINK-35351) Restore from unaligned checkpoints with a custom partitioner fails.

[ https://issues.apache.org/jira/browse/FLINK-35351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-35351: -- Assignee: Dmitriy Linevich > Restore from unaligned checkpoints with a custom partiti

[jira] [Commented] (FLINK-33856) Add metrics to monitor the interaction performance between task and external storage system in the process of checkpoint making

[ https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840327#comment-17840327 ] Piotr Nowojski commented on FLINK-33856: Hey [~hejufang001]! Sorry for the usual

[jira] [Updated] (FLINK-33856) Add sub-task spans to TraceReporter for checkpointing

[ https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-33856: --- Summary: Add sub-task spans to TraceReporter for checkpointing (was: Add metrics to monitor

[jira] [Closed] (FLINK-34913) ConcurrentModificationException SubTaskInitializationMetricsBuilder.addDurationMetric

[ https://issues.apache.org/jira/browse/FLINK-34913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-34913. -- Fix Version/s: 1.20.0 (was: 2.0.0) Resolution: Fixed > Concurren

[jira] [Assigned] (FLINK-20217) More fine-grained timer processing

[ https://issues.apache.org/jira/browse/FLINK-20217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-20217: -- Assignee: Piotr Nowojski > More fine-grained timer processing > -

[jira] [Commented] (FLINK-34704) Process checkpoint barrier in AsyncWaitOperator when the element queue is full

[ https://issues.apache.org/jira/browse/FLINK-34704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836113#comment-17836113 ] Piotr Nowojski commented on FLINK-34704: Sounds good to me (y) Indeed we could l

[jira] [Comment Edited] (FLINK-34704) Process checkpoint barrier in AsyncWaitOperator when the element queue is full

[ https://issues.apache.org/jira/browse/FLINK-34704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836083#comment-17836083 ] Piotr Nowojski edited comment on FLINK-34704 at 4/11/24 9:57 AM: -

[jira] [Commented] (FLINK-34704) Process checkpoint barrier in AsyncWaitOperator when the element queue is full

[ https://issues.apache.org/jira/browse/FLINK-34704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836083#comment-17836083 ] Piotr Nowojski commented on FLINK-34704: {quote} the checkpoint still happen whe

[jira] [Commented] (FLINK-34704) Process checkpoint barrier in AsyncWaitOperator when the element queue is full

[ https://issues.apache.org/jira/browse/FLINK-34704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836037#comment-17836037 ] Piotr Nowojski commented on FLINK-34704: {code:java} So it is designed to be saf

[jira] [Comment Edited] (FLINK-34704) Process checkpoint barrier in AsyncWaitOperator when the element queue is full

[ https://issues.apache.org/jira/browse/FLINK-34704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835796#comment-17835796 ] Piotr Nowojski edited comment on FLINK-34704 at 4/10/24 3:46 PM: -

  1   2   3   4   5   6   7   8   9   10   >