[jira] [Commented] (FLINK-32548) Make watermark alignment ready for production use

[ https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750064#comment-17750064 ] Rui Fan commented on FLINK-32548: - Hi [~knaufk], the beta and Experimental of watermark

[jira] [Commented] (FLINK-32658) State should not be silently removed when ignore-unclaimed-state is false

[ https://issues.apache.org/jira/browse/FLINK-32658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750097#comment-17750097 ] Rui Fan commented on FLINK-32658: - Hi [~Zakelly], thanks for your reply. {quote}you mea

[jira] [Comment Edited] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677312#comment-17677312 ] Rui Fan edited comment on FLINK-30623 at 1/16/23 10:37 AM: --- Th

[jira] [Commented] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677312#comment-17677312 ] Rui Fan commented on FLINK-30623: - Thanks [~Yanfei Lei]   reports this issue, and [~mart

[jira] [Comment Edited] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677312#comment-17677312 ] Rui Fan edited comment on FLINK-30623 at 1/16/23 12:35 PM: --- Th

[jira] [Created] (FLINK-30709) NetworkInput#emitNext() should push records to DataOutput in a while loop

Rui Fan created FLINK-30709: --- Summary: NetworkInput#emitNext() should push records to DataOutput in a while loop Key: FLINK-30709 URL: https://issues.apache.org/jira/browse/FLINK-30709 Project: Flink

[jira] [Commented] (FLINK-30533) SourceOperator#emitNext() should push records to DataOutput in a while loop

[ https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677607#comment-17677607 ] Rui Fan commented on FLINK-30533: - Hi [~lindong] [~pnowojski] , thanks for your contribu

[jira] [Comment Edited] (FLINK-30533) SourceOperator#emitNext() should push records to DataOutput in a while loop

[ https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677607#comment-17677607 ] Rui Fan edited comment on FLINK-30533 at 1/17/23 6:07 AM: -- Hi [

[jira] [Commented] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680500#comment-17680500 ] Rui Fan commented on FLINK-26803: - [~pnowojski] Thanks a lot for your review~ > Merge s

[jira] [Commented] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681196#comment-17681196 ] Rui Fan commented on FLINK-30623: - FLINK-26806 was merged at 23.01.2023, I'm not sure wh

[jira] [Comment Edited] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681196#comment-17681196 ] Rui Fan edited comment on FLINK-30623 at 1/27/23 12:25 PM: --- FL

[jira] [Commented] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681313#comment-17681313 ] Rui Fan commented on FLINK-30623: - > It can not take advantage of the optimization we pu

[jira] [Commented] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682466#comment-17682466 ] Rui Fan commented on FLINK-30623: - {quote} What do you think is the actual reason behind

[jira] [Updated] (FLINK-30461) Some rocksdb sst files will remain forever

[ https://issues.apache.org/jira/browse/FLINK-30461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-30461: Attachment: screenshot-1.png > Some rocksdb sst files will remain forever > --

[jira] [Commented] (FLINK-30461) Some rocksdb sst files will remain forever

[ https://issues.apache.org/jira/browse/FLINK-30461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684382#comment-17684382 ] Rui Fan commented on FLINK-30461: - Hi [~ym], thanks for your review and merge. {quote}I

[jira] [Updated] (FLINK-30461) Some rocksdb sst files will remain forever

[ https://issues.apache.org/jira/browse/FLINK-30461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-30461: Fix Version/s: 1.15.4 1.16.2 > Some rocksdb sst files will remain forever > ---

[jira] [Commented] (FLINK-30916) RocksDBStateUploaderTest.testUploadedSstCanBeCleanedUp failed with assertion

[ https://issues.apache.org/jira/browse/FLINK-30916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684516#comment-17684516 ] Rui Fan commented on FLINK-30916: - Hi [~mapohl] , thanks for report this bug. I‘m worki

[jira] [Created] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

Rui Fan created FLINK-30921: --- Summary: Too many CI failed due to "Could not connect to azure.archive.ubuntu.com" Key: FLINK-30921 URL: https://issues.apache.org/jira/browse/FLINK-30921 Project: Flink

[jira] [Commented] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

[ https://issues.apache.org/jira/browse/FLINK-30921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684560#comment-17684560 ] Rui Fan commented on FLINK-30921: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-30461) Some rocksdb sst files will remain forever

[ https://issues.apache.org/jira/browse/FLINK-30461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684567#comment-17684567 ] Rui Fan commented on FLINK-30461: - Offline discussed with [~ym] , I will submit a PR to

[jira] [Commented] (FLINK-30921) Too many CI failed due to "Could not connect to azure.archive.ubuntu.com"

[ https://issues.apache.org/jira/browse/FLINK-30921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685006#comment-17685006 ] Rui Fan commented on FLINK-30921: - I see it's recovered, the new CI is green. > Too man

[jira] [Assigned] (FLINK-32137) Flame graph is hard to use with many task managers

[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32137: --- Assignee: (was: Rui Fan) > Flame graph is hard to use with many task managers > ---

[jira] [Assigned] (FLINK-32137) Flame graph is hard to use with many task managers

[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32137: --- Assignee: Rui Fan > Flame graph is hard to use with many task managers > --

[jira] [Updated] (FLINK-32137) Flame graph is hard to use with many task managers

[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32137: Attachment: image-2023-05-23-10-57-08-737.png > Flame graph is hard to use with many task managers > -

[jira] [Updated] (FLINK-32137) Flame graph is hard to use with many task managers

[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32137: Attachment: (was: image-2023-05-23-10-57-08-737.png) > Flame graph is hard to use with many task manag

[jira] [Updated] (FLINK-32137) Flame graph is hard to use with many task managers

[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32137: Attachment: image-2023-05-23-11-01-30-391.png > Flame graph is hard to use with many task managers > -

[jira] [Commented] (FLINK-32137) Flame graph is hard to use with many task managers

[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725160#comment-17725160 ] Rui Fan commented on FLINK-32137: - Hi [~netvl] , thanks for your report. It is an ease-

[jira] [Commented] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

[ https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727021#comment-17727021 ] Rui Fan commented on FLINK-32023: - 522ff833ad7e3b3c80f4c1ba326cb05fdc4d6a3c > executio

[jira] [Updated] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

[ https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32023: Fix Version/s: 1.18.0 > execution.buffer-timeout cannot be set to -1 ms >

[jira] [Commented] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

[ https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727881#comment-17727881 ] Rui Fan commented on FLINK-32023: - This Jira isn't closed due to waiting for backport it

[jira] [Commented] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729143#comment-17729143 ] Rui Fan commented on FLINK-26803: - {quote}The PR of this JIRA introduced a new public ev

[jira] [Commented] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729170#comment-17729170 ] Rui Fan commented on FLINK-26803: - {quote}It is probably good to always have a FLIP appr

[jira] [Created] (FLINK-32250) Revert the Field name of BUFFER_TIMEOUT to improve compatibility

Rui Fan created FLINK-32250: --- Summary: Revert the Field name of BUFFER_TIMEOUT to improve compatibility Key: FLINK-32250 URL: https://issues.apache.org/jira/browse/FLINK-32250 Project: Flink Issue

[jira] [Updated] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

[ https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32023: Fix Version/s: 1.16.3 1.17.2 > execution.buffer-timeout cannot be set to -1 ms > --

[jira] [Closed] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

[ https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-32023. --- Resolution: Fixed > execution.buffer-timeout cannot be set to -1 ms > --

[jira] [Comment Edited] (FLINK-32023) execution.buffer-timeout cannot be set to -1 ms

[ https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727021#comment-17727021 ] Rui Fan edited comment on FLINK-32023 at 6/6/23 2:20 AM: - 522ff

[jira] [Closed] (FLINK-32250) Revert the Field name of BUFFER_TIMEOUT to improve compatibility

[ https://issues.apache.org/jira/browse/FLINK-32250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-32250. --- Resolution: Fixed > Revert the Field name of BUFFER_TIMEOUT to improve compatibility > -

[jira] [Commented] (FLINK-32250) Revert the Field name of BUFFER_TIMEOUT to improve compatibility

[ https://issues.apache.org/jira/browse/FLINK-32250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729550#comment-17729550 ] Rui Fan commented on FLINK-32250: - 7403e2efea273c307e52475d56c10910ca940430 > Revert t

[jira] [Created] (FLINK-32294) The CI fails due to HiveITCase

Rui Fan created FLINK-32294: --- Summary: The CI fails due to HiveITCase Key: FLINK-32294 URL: https://issues.apache.org/jira/browse/FLINK-32294 Project: Flink Issue Type: Bug Components: Co

[jira] [Commented] (FLINK-32294) The CI fails due to HiveITCase

[ https://issues.apache.org/jira/browse/FLINK-32294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730785#comment-17730785 ] Rui Fan commented on FLINK-32294: - Hi [~yuxia] , I'm working on FLINK-30585[1], it's rel

[jira] [Commented] (FLINK-32294) The CI fails due to HiveITCase

[ https://issues.apache.org/jira/browse/FLINK-32294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730793#comment-17730793 ] Rui Fan commented on FLINK-32294: - Thanks a lot for your quick feedback, let me try it n

[jira] [Assigned] (FLINK-32294) The CI fails due to HiveITCase

[ https://issues.apache.org/jira/browse/FLINK-32294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32294: --- Assignee: Yuxia Luo > The CI fails due to HiveITCase > -- > >

[jira] [Closed] (FLINK-32291) Hive E2E test fails consistently

[ https://issues.apache.org/jira/browse/FLINK-32291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-32291. --- Resolution: Duplicate > Hive E2E test fails consistently > > >

[jira] [Commented] (FLINK-32291) Hive E2E test fails consistently

[ https://issues.apache.org/jira/browse/FLINK-32291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730794#comment-17730794 ] Rui Fan commented on FLINK-32291: - It's duplicated with FLINK-32294, and it has been fix

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730871#comment-17730871 ] Rui Fan commented on FLINK-31757: - Hi [~xtsong] [~zhuzh] [~wanglijie] , you may also be

[jira] [Commented] (FLINK-30585) Improve flame graph performance at subtask level

[ https://issues.apache.org/jira/browse/FLINK-30585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730890#comment-17730890 ] Rui Fan commented on FLINK-30585: - d857cfda152a5073be07890a5d63855e0fa22639 > Improve

[jira] [Resolved] (FLINK-30585) Improve flame graph performance at subtask level

[ https://issues.apache.org/jira/browse/FLINK-30585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-30585. - Fix Version/s: 1.18.0 Resolution: Done > Improve flame graph performance at subtask level > -

[jira] [Created] (FLINK-32298) The outputQueueSize is negative

Rui Fan created FLINK-32298: --- Summary: The outputQueueSize is negative Key: FLINK-32298 URL: https://issues.apache.org/jira/browse/FLINK-32298 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-28076) StreamFaultToleranceTestBase runs into timeout

[ https://issues.apache.org/jira/browse/FLINK-28076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17731828#comment-17731828 ] Rui Fan commented on FLINK-28076: - {quote}[https://dev.azure.com/apache-flink/apache-fli

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17732424#comment-17732424 ] Rui Fan commented on FLINK-31655: - Hi [~tartarus] , some of our flink scenarios also nee

[jira] [Commented] (FLINK-32316) Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover

[ https://issues.apache.org/jira/browse/FLINK-32316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17732993#comment-17732993 ] Rui Fan commented on FLINK-32316: - Hi [~cailiuyang] , thanks for the report. As I under

[jira] [Comment Edited] (FLINK-32316) Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover

[ https://issues.apache.org/jira/browse/FLINK-32316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17732993#comment-17732993 ] Rui Fan edited comment on FLINK-32316 at 6/15/23 11:56 AM: --- Hi

[jira] [Assigned] (FLINK-32362) SourceAlignment announceCombinedWatermark period task maybe lost

[ https://issues.apache.org/jira/browse/FLINK-32362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32362: --- Assignee: Cai Liuyang > SourceAlignment announceCombinedWatermark period task maybe lost >

[jira] [Assigned] (FLINK-32316) Duplicated announceCombinedWatermark task maybe scheduled if jobmanager failover

[ https://issues.apache.org/jira/browse/FLINK-32316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32316: --- Assignee: Cai Liuyang > Duplicated announceCombinedWatermark task maybe scheduled if jobmanager >

[jira] [Commented] (FLINK-32362) SourceAlignment announceCombinedWatermark period task maybe lost

[ https://issues.apache.org/jira/browse/FLINK-32362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733340#comment-17733340 ] Rui Fan commented on FLINK-32362: - Hi [~cailiuyang] , thanks for the report. It's reall

[jira] [Commented] (FLINK-32137) Flame graph is hard to use with many task managers

[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733343#comment-17733343 ] Rui Fan commented on FLINK-32137: - Hi [~netvl] , do you have any progress? If you are bu

[jira] [Commented] (FLINK-32362) SourceAlignment announceCombinedWatermark period task maybe lost

[ https://issues.apache.org/jira/browse/FLINK-32362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733363#comment-17733363 ] Rui Fan commented on FLINK-32362: - Thanks for your quick feedback. I'm not sure what sh

[jira] [Assigned] (FLINK-32137) Flame graph is hard to use with many task managers

[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32137: --- Assignee: Rui Fan (was: Vladimir Matveev) > Flame graph is hard to use with many task managers > -

[jira] [Assigned] (FLINK-32137) Flame graph is hard to use with many task managers

[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32137: --- Assignee: Vladimir Matveev (was: Rui Fan) > Flame graph is hard to use with many task managers > -

[jira] [Commented] (FLINK-32137) Flame graph is hard to use with many task managers

[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17735128#comment-17735128 ] Rui Fan commented on FLINK-32137: - A mistake has just occurred about assignee. Hi [~net

[jira] [Created] (FLINK-32411) SourceCoordinator thread leaks when job recovers from checkpoint

Rui Fan created FLINK-32411: --- Summary: SourceCoordinator thread leaks when job recovers from checkpoint Key: FLINK-32411 URL: https://issues.apache.org/jira/browse/FLINK-32411 Project: Flink Issue

[jira] [Updated] (FLINK-32411) SourceCoordinator thread leaks when job recovers from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32411: Attachment: (was: image-2023-06-22-11-00-25-446.png) > SourceCoordinator thread leaks when job recover

[jira] [Updated] (FLINK-32411) SourceCoordinator thread leaks when job recovers from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32411: Description: SourceCoordinator thread leaks when job recovers from checkpoint, from the following figure,

[jira] [Updated] (FLINK-32411) SourceCoordinator thread leaks when job recovers from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32411: Description: SourceCoordinator thread leaks when job recovers from checkpoint, from the following figure,

[jira] [Created] (FLINK-32414) Watermark alignment will cause flink jobs to hang forever when any source subtask has no SourceSplit

Rui Fan created FLINK-32414: --- Summary: Watermark alignment will cause flink jobs to hang forever when any source subtask has no SourceSplit Key: FLINK-32414 URL: https://issues.apache.org/jira/browse/FLINK-32414

[jira] [Updated] (FLINK-32414) Watermark alignment will cause flink jobs to hang forever when any source subtask has no SourceSplit

[ https://issues.apache.org/jira/browse/FLINK-32414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32414: Description: Watermark alignment will cause flink jobs to hang forever when any source subtask has no Sou

[jira] [Updated] (FLINK-32414) Watermark alignment will cause flink jobs to hang forever when any source subtask has no SourceSplit

[ https://issues.apache.org/jira/browse/FLINK-32414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32414: Component/s: Connectors / Common > Watermark alignment will cause flink jobs to hang forever when any sour

[jira] [Created] (FLINK-32420) Watermark aggregation performance is poor when watermark alignment is enabled and parallelism is high

Rui Fan created FLINK-32420: --- Summary: Watermark aggregation performance is poor when watermark alignment is enabled and parallelism is high Key: FLINK-32420 URL: https://issues.apache.org/jira/browse/FLINK-32420

[jira] [Updated] (FLINK-32420) Watermark aggregation performance is poor when watermark alignment is enabled and parallelism is high

[ https://issues.apache.org/jira/browse/FLINK-32420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32420: Description: The [SourceCoordinator.WatermarkAggregator#aggregate|https://github.com/apache/flink/blob/27

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17736668#comment-17736668 ] Rui Fan commented on FLINK-31655: - Hi [~tartarus] , thanks for the hard testing. >From

[jira] [Created] (FLINK-30461) Some rocksdb sst files will remain forever

Rui Fan created FLINK-30461: --- Summary: Some rocksdb sst files will remain forever Key: FLINK-30461 URL: https://issues.apache.org/jira/browse/FLINK-30461 Project: Flink Issue Type: Bug Co

[jira] [Commented] (FLINK-30461) Some rocksdb sst files will remain forever

[ https://issues.apache.org/jira/browse/FLINK-30461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649696#comment-17649696 ] Rui Fan commented on FLINK-30461: - Hi [~pnowojski] , could you please help take a look i

[jira] [Created] (FLINK-30468) The SortOrder of BusyRatio should be descend by default

Rui Fan created FLINK-30468: --- Summary: The SortOrder of BusyRatio should be descend by default Key: FLINK-30468 URL: https://issues.apache.org/jira/browse/FLINK-30468 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-30461) Some rocksdb sst files will remain forever

[ https://issues.apache.org/jira/browse/FLINK-30461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-30461: Description: In rocksdb incremental checkpoint mode, during file upload, if some files have been uploaded

[jira] [Created] (FLINK-30583) Provide the flame graph to the subtask level

Rui Fan created FLINK-30583: --- Summary: Provide the flame graph to the subtask level Key: FLINK-30583 URL: https://issues.apache.org/jira/browse/FLINK-30583 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-30583: Description: This is a umbrella Jira about providing the flame graph to the subtask level. (was: This is

[jira] [Updated] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-30583: Description: This is a umbrella Jira about  (was: Provide the flame graph to the subtask level) > Provid

[jira] [Updated] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-30583: Issue Type: New Feature (was: Bug) > Provide the flame graph to the subtask level > -

[jira] [Updated] (FLINK-30185) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-30185: Parent: FLINK-30583 Issue Type: Sub-task (was: Improvement) > Provide the flame graph to the subt

[jira] [Created] (FLINK-30584) Update the flame graph doc of subtask level

Rui Fan created FLINK-30584: --- Summary: Update the flame graph doc of subtask level Key: FLINK-30584 URL: https://issues.apache.org/jira/browse/FLINK-30584 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30585) Improve flame graph performance at subtask level

Rui Fan created FLINK-30585: --- Summary: Improve flame graph performance at subtask level Key: FLINK-30585 URL: https://issues.apache.org/jira/browse/FLINK-30585 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655330#comment-17655330 ] Rui Fan commented on FLINK-30583: - Hi [~xtsong] , could you please assign these sub-task

[jira] [Comment Edited] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655330#comment-17655330 ] Rui Fan edited comment on FLINK-30583 at 1/6/23 8:52 AM: - Hi [~x

[jira] [Commented] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655339#comment-17655339 ] Rui Fan commented on FLINK-30583: - Hi [~xtsong] , thanks for your quick feedback.   Th

[jira] [Commented] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655344#comment-17655344 ] Rui Fan commented on FLINK-30583: - Thanks, I will finish the subtask2 asap:) > Provide

[jira] [Updated] (FLINK-30583) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-30583: Release Note: Starting with Flink 1.17, Flame Graph provides "drill down" visualizations to the task level

[jira] [Commented] (FLINK-31610) Refactoring of LocalBufferPool

[ https://issues.apache.org/jira/browse/FLINK-31610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709173#comment-17709173 ] Rui Fan commented on FLINK-31610: - Thanks [~akalash]  driving this JIRA, and thanks [~We

[jira] [Commented] (FLINK-31588) The unaligned checkpoint type is wrong at subtask level

[ https://issues.apache.org/jira/browse/FLINK-31588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709823#comment-17709823 ] Rui Fan commented on FLINK-31588: - Thanks for your feedback. {quote} If checkpoint was u

[jira] [Assigned] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-31757: --- Assignee: RocMarshal > Optimize Flink un-balanced tasks scheduling > --

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711886#comment-17711886 ] Rui Fan commented on FLINK-31757: - Thanks [~RocMarshal] 's reporting and [~huwh] 's feed

[jira] [Closed] (FLINK-31761) Fix Some Typo And Improve lambda expressions.

[ https://issues.apache.org/jira/browse/FLINK-31761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-31761. --- Fix Version/s: 1.18.0 Resolution: Fixed > Fix Some Typo And Improve lambda expressions. > ---

[jira] [Commented] (FLINK-31761) Fix Some Typo And Improve lambda expressions.

[ https://issues.apache.org/jira/browse/FLINK-31761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711907#comment-17711907 ] Rui Fan commented on FLINK-31761: - Hi [~martijnvisser] , sorry for the late update. Mer

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711932#comment-17711932 ] Rui Fan commented on FLINK-31757: - Hi [~chesnay] , thanks for your reply. {quote}The obv

[jira] [Comment Edited] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711932#comment-17711932 ] Rui Fan edited comment on FLINK-31757 at 4/13/23 3:08 PM: -- Hi [

[jira] [Commented] (FLINK-31131) The INITIALIZING of ExecutionState is missed in the state_machine doc

[ https://issues.apache.org/jira/browse/FLINK-31131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714515#comment-17714515 ] Rui Fan commented on FLINK-31131: - Hi [~Wencong Liu] , thanks for your reply. I see the

[jira] [Created] (FLINK-31864) Generate unaligned checkpoint type based on persisted data

Rui Fan created FLINK-31864: --- Summary: Generate unaligned checkpoint type based on persisted data Key: FLINK-31864 URL: https://issues.apache.org/jira/browse/FLINK-31864 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-31131) The INITIALIZING of ExecutionState is missed in the state_machine doc

[ https://issues.apache.org/jira/browse/FLINK-31131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-31131: --- Assignee: Wencong Liu (was: Rui Fan) > The INITIALIZING of ExecutionState is missed in the state_m

[jira] [Commented] (FLINK-31588) The unaligned checkpoint type is wrong at subtask level

[ https://issues.apache.org/jira/browse/FLINK-31588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715340#comment-17715340 ] Rui Fan commented on FLINK-31588: - Thanks [~pnowojski] for the review and discussion. M

[jira] [Closed] (FLINK-31588) The unaligned checkpoint type is wrong at subtask level

[ https://issues.apache.org/jira/browse/FLINK-31588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-31588. --- Fix Version/s: 1.18.0 Resolution: Fixed > The unaligned checkpoint type is wrong at subtask level > -

[jira] [Reopened] (FLINK-31588) The unaligned checkpoint type is wrong at subtask level

[ https://issues.apache.org/jira/browse/FLINK-31588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reopened FLINK-31588: - > The unaligned checkpoint type is wrong at subtask level >

<    7   8   9   10   11   12   13   14   15   16   >