[jira] [Closed] (FLINK-28781) Hybrid Shuffle should support compression

[ https://issues.apache.org/jira/browse/FLINK-28781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28781. Resolution: Fixed master (1.16): 2edc43c6e469a3e16ee01a1373cf52523eb96b01 > Hybrid Shuffle

[jira] [Closed] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode

[ https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27862. Release Note: We have introduced a new Hybrid Shuffle Mode for batch executions. It combines the

[jira] [Closed] (FLINK-27909) Add document and tests for hybrid shuffle mode

[ https://issues.apache.org/jira/browse/FLINK-27909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27909. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Closed] (FLINK-27908) Introduce HsResultPartition and HsSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-27908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27908. Resolution: Fixed Fixed in master (1.16) 2dd51f644da14a88914cc7aeeb021f824a28ee48 > Introduce

[jira] [Assigned] (FLINK-28799) Hybrid shuffle can't schedule graph contains blocking edge

[ https://issues.apache.org/jira/browse/FLINK-28799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28799: Assignee: Weijie Guo > Hybrid shuffle can't schedule graph contains blocking edge >

[jira] [Updated] (FLINK-28800) HsFileDataManager should avoid busy-loop when fileReader has not data to read

[ https://issues.apache.org/jira/browse/FLINK-28800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28800: - Fix Version/s: 1.16.0 > HsFileDataManager should avoid busy-loop when fileReader has not data

[jira] [Updated] (FLINK-28785) Hybrid shuffle consumer thread and upstream thread may have dead lock

[ https://issues.apache.org/jira/browse/FLINK-28785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28785: - Affects Version/s: 1.16.0 > Hybrid shuffle consumer thread and upstream thread may have dead

[jira] [Assigned] (FLINK-28800) HsFileDataManager should avoid busy-loop when fileReader has not data to read

[ https://issues.apache.org/jira/browse/FLINK-28800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28800: Assignee: Weijie Guo > HsFileDataManager should avoid busy-loop when fileReader has not

[jira] [Updated] (FLINK-28799) Hybrid shuffle can't schedule graph contains blocking edge

[ https://issues.apache.org/jira/browse/FLINK-28799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28799: - Priority: Critical (was: Major) > Hybrid shuffle can't schedule graph contains blocking edge >

[jira] [Updated] (FLINK-28799) Hybrid shuffle can't schedule graph contains blocking edge

[ https://issues.apache.org/jira/browse/FLINK-28799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28799: - Affects Version/s: 1.16.0 > Hybrid shuffle can't schedule graph contains blocking edge >

[jira] [Updated] (FLINK-28799) Hybrid shuffle can't schedule graph contains blocking edge

[ https://issues.apache.org/jira/browse/FLINK-28799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28799: - Fix Version/s: 1.16.0 > Hybrid shuffle can't schedule graph contains blocking edge >

[jira] [Updated] (FLINK-28800) HsFileDataManager should avoid busy-loop when fileReader has not data to read

[ https://issues.apache.org/jira/browse/FLINK-28800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28800: - Affects Version/s: 1.16.0 > HsFileDataManager should avoid busy-loop when fileReader has not

[jira] [Closed] (FLINK-28161) Introduce the session related API for REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-28161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28161. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Assigned] (FLINK-28785) Hybrid shuffle consumer thread and upstream thread may have dead lock

[ https://issues.apache.org/jira/browse/FLINK-28785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28785: Assignee: Weijie Guo > Hybrid shuffle consumer thread and upstream thread may have dead

[jira] [Assigned] (FLINK-28781) Hybrid Shuffle should support compression

[ https://issues.apache.org/jira/browse/FLINK-28781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28781: Assignee: Weijie Guo > Hybrid Shuffle should support compression >

[jira] [Comment Edited] (FLINK-28777) Add configure session API for sql gateway rest endpoint

[ https://issues.apache.org/jira/browse/FLINK-28777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574184#comment-17574184 ] Xintong Song edited comment on FLINK-28777 at 8/2/22 11:16 AM: ---

[jira] [Commented] (FLINK-28777) Add configure session API for sql gateway rest endpoint

[ https://issues.apache.org/jira/browse/FLINK-28777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574184#comment-17574184 ] Xintong Song commented on FLINK-28777: -- [~martijnvisser], I think this is exactly an outcome of

[jira] [Updated] (FLINK-28777) Add configure session API for sql gateway rest endpoint

[ https://issues.apache.org/jira/browse/FLINK-28777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28777: - Fix Version/s: 1.17.0 > Add configure session API for sql gateway rest endpoint >

[jira] [Updated] (FLINK-28777) Add configure session API for sql gateway rest endpoint

[ https://issues.apache.org/jira/browse/FLINK-28777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28777: - Priority: Major (was: Minor) > Add configure session API for sql gateway rest endpoint >

[jira] [Closed] (FLINK-27769) Introduce the REST endpoint framework

[ https://issues.apache.org/jira/browse/FLINK-27769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27769. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Updated] (FLINK-28701) Minimize the explosion range during failover for hybrid shuffle

[ https://issues.apache.org/jira/browse/FLINK-28701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28701: - Fix Version/s: 1.16.0 > Minimize the explosion range during failover for hybrid shuffle >

[jira] [Updated] (FLINK-28769) Flink History Server show wrong name of batch jobs

[ https://issues.apache.org/jira/browse/FLINK-28769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28769: - Component/s: API / DataSet (was: Runtime / Web Frontend) > Flink History

[jira] [Assigned] (FLINK-28701) Minimize the explosion range during failover for hybrid shuffle

[ https://issues.apache.org/jira/browse/FLINK-28701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28701: Assignee: Weijie Guo > Minimize the explosion range during failover for hybrid shuffle >

[jira] [Closed] (FLINK-27908) Introduce HsResultPartition and HsSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-27908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27908. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Closed] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28698. Fix Version/s: 1.16.0 Resolution: Fixed master (1.16):

[jira] [Assigned] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28698: Assignee: Junhan Yang > The display order of aggregated metrics should follow the order

[jira] [Updated] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28698: - Priority: Minor (was: Major) > The display order of aggregated metrics should follow the order

[jira] [Commented] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571715#comment-17571715 ] Xintong Song commented on FLINK-28698: -- Thanks [~wanglijie95], that makes sense to me. [~junhany],

[jira] [Updated] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28698: - Affects Version/s: 1.16.0 > The display order of aggregated metrics should follow the order of

[jira] [Assigned] (FLINK-27909) Add document and tests for hybrid shuffle mode

[ https://issues.apache.org/jira/browse/FLINK-27909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27909: Assignee: Weijie Guo > Add document and tests for hybrid shuffle mode >

[jira] [Closed] (FLINK-27904) Introduce HsMemoryDataManager

[ https://issues.apache.org/jira/browse/FLINK-27904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27904. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Assigned] (FLINK-27908) Introduce HsResultPartition and HsSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-27908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27908: Assignee: Weijie Guo > Introduce HsResultPartition and HsSubpartitionView >

[jira] [Closed] (FLINK-24713) Postpone resourceManager serving after the recovery phase has finished

[ https://issues.apache.org/jira/browse/FLINK-24713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-24713. Fix Version/s: 1.16.0 Resolution: Fixed master (1.16):

[jira] [Closed] (FLINK-28307) FLIP-241: Completed Jobs Information Enhancement

[ https://issues.apache.org/jira/browse/FLINK-28307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28307. Release Note: We have enhanced the experiences of viewing completed jobs’ information in this

[jira] [Closed] (FLINK-28555) Update history server documentation

[ https://issues.apache.org/jira/browse/FLINK-28555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28555. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Commented] (FLINK-28307) FLIP-241: Completed Jobs Information Enhancement

[ https://issues.apache.org/jira/browse/FLINK-28307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17567954#comment-17567954 ] Xintong Song commented on FLINK-28307: -- I've drafted a release note for this feature. {code} We

[jira] [Closed] (FLINK-27905) Introduce HsSpillingStrategy and Implement SelectiveSpillingStrategy、FullSpillingStrategy

[ https://issues.apache.org/jira/browse/FLINK-27905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27905. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Closed] (FLINK-28558) HistoryServer log retrieval configuration improvement

[ https://issues.apache.org/jira/browse/FLINK-28558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28558. Resolution: Done master (1.16): 6eee0c69b6cd28fb086bf44e1d7fdb6f646a467e > HistoryServer log

[jira] [Commented] (FLINK-27721) Slack: set up archive

[ https://issues.apache.org/jira/browse/FLINK-27721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17567803#comment-17567803 ] Xintong Song commented on FLINK-27721: -- Status updates: Right now, I have something imperfect but

[jira] [Closed] (FLINK-28316) [UI] add external JM and TM log links under history server

[ https://issues.apache.org/jira/browse/FLINK-28316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28316. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Created] (FLINK-28558) HistoryServer log retrieval configuration improvement

Xintong Song created FLINK-28558: Summary: HistoryServer log retrieval configuration improvement Key: FLINK-28558 URL: https://issues.apache.org/jira/browse/FLINK-28558 Project: Flink Issue

[jira] [Created] (FLINK-28555) Update history server documentation

Xintong Song created FLINK-28555: Summary: Update history server documentation Key: FLINK-28555 URL: https://issues.apache.org/jira/browse/FLINK-28555 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-28315) [UI] Introduce aggregate stats in tables of the subtasks and taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-28315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28315. Resolution: Done master (1.16): 35e557afe9e8392b1b1ebb115f0c7134504b584d > [UI] Introduce

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566252#comment-17566252 ] Xintong Song commented on FLINK-27703: --

[jira] [Commented] (FLINK-28531) Shutdown cluster after history server archive finished

[ https://issues.apache.org/jira/browse/FLINK-28531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566214#comment-17566214 ] Xintong Song commented on FLINK-28531: -- I think deregister should only happen when job archiving is

[jira] [Commented] (FLINK-28531) Shutdown cluster after history server archive finished

[ https://issues.apache.org/jira/browse/FLINK-28531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566162#comment-17566162 ] Xintong Song commented on FLINK-28531: -- [~aitozi], Which version of Flink did you use when

[jira] [Closed] (FLINK-28314) [UI] Introduce "Cluster Environment" tab under history server

[ https://issues.apache.org/jira/browse/FLINK-28314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28314. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Assigned] (FLINK-27904) Introduce HsDataBuffer

[ https://issues.apache.org/jira/browse/FLINK-27904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27904: Assignee: Weijie Guo (was: Aitozi) > Introduce HsDataBuffer > -- >

[jira] [Closed] (FLINK-28065) A never reached code in ProcessMemoryUtils Class

[ https://issues.apache.org/jira/browse/FLINK-28065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28065. Resolution: Won't Fix > A never reached code in ProcessMemoryUtils Class >

[jira] [Commented] (FLINK-28477) Support to scan the history server dir with max depth

[ https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564754#comment-17564754 ] Xintong Song commented on FLINK-28477: -- -1 to this change. At the cost of complexity, I don't see

[jira] [Closed] (FLINK-27907) Implement disk read and write logic for hybrid shuffle

[ https://issues.apache.org/jira/browse/FLINK-27907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27907. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Updated] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19358: - Fix Version/s: 1.16.0 > when submit job on application mode with HA,the jobid will be

[jira] [Closed] (FLINK-27906) Introduce HsDataIndex

[ https://issues.apache.org/jira/browse/FLINK-27906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27906. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[jira] [Assigned] (FLINK-28162) Introduce the operation related API for REST endpoint

Title: Message Title Xintong Song

[jira] [Assigned] (FLINK-28164) Introduce utilities API for REST endpint

Title: Message Title Xintong Song

[jira] [Assigned] (FLINK-28163) Introduce the statement related API for REST endpoint

Title: Message Title Xintong Song

[jira] [Assigned] (FLINK-27905) Introduce HsSpillStrategy and Implement SelectiveSpillStrategy

Title: Message Title Xintong Song

[jira] [Assigned] (FLINK-27769) Introduce the REST endpoint framework

[ https://issues.apache.org/jira/browse/FLINK-27769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27769: Assignee: Wencong Liu > Introduce the REST endpoint framework >

[jira] [Assigned] (FLINK-28161) Introduce the session related API for REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-28161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28161: Assignee: Wencong Liu > Introduce the session related API for REST endpoint >

[jira] [Closed] (FLINK-27420) Suspended SlotManager fails to re-register metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27420. Fix Version/s: 1.14.5 Resolution: Fixed Fixed via - master (1.16):

[jira] [Comment Edited] (FLINK-27420) Suspended SlotManager fails to re-register metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529866#comment-17529866 ] Xintong Song edited comment on FLINK-27420 at 6/20/22 9:55 AM: --- Fixed via

[jira] [Assigned] (FLINK-28125) Promote leadership changing logs to INFO level

[ https://issues.apache.org/jira/browse/FLINK-28125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28125: Assignee: Weijie Guo > Promote leadership changing logs to INFO level >

[jira] [Created] (FLINK-28125) Promote leadership changing logs to INFO level

Xintong Song created FLINK-28125: Summary: Promote leadership changing logs to INFO level Key: FLINK-28125 URL: https://issues.apache.org/jira/browse/FLINK-28125 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27420) Suspended SlotManager fail to reregister metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554587#comment-17554587 ] Xintong Song commented on FLINK-27420: -- [~baugarten], Are you still going to work on this? If you

[jira] [Commented] (FLINK-27420) Suspended SlotManager fail to reregister metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554582#comment-17554582 ] Xintong Song commented on FLINK-27420: -- [~danderson], This has already been fixed for: - master

[jira] [Updated] (FLINK-27420) Suspended SlotManager fail to reregister metrics when started again

[ https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27420: - Fix Version/s: (was: 1.14.6) > Suspended SlotManager fail to reregister metrics when

[jira] [Commented] (FLINK-27721) Slack: set up archive

[ https://issues.apache.org/jira/browse/FLINK-27721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554492#comment-17554492 ] Xintong Song commented on FLINK-27721: -- I didn't know there're ASF VMs available. How does that

[jira] [Assigned] (FLINK-27906) Introduce HsDataIndex

[ https://issues.apache.org/jira/browse/FLINK-27906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27906: Assignee: Weijie Guo > Introduce HsDataIndex > - > >

[jira] [Assigned] (FLINK-27907) Abstract and implement disk read and write logic for hybrid shuffle

[ https://issues.apache.org/jira/browse/FLINK-27907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27907: Assignee: Weijie Guo > Abstract and implement disk read and write logic for hybrid

[jira] [Closed] (FLINK-27737) Remove legacy support for unfenced executor in FencedRpcEndpoint

[ https://issues.apache.org/jira/browse/FLINK-27737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27737. Fix Version/s: 1.16.0 Resolution: Fixed master: 41ac1ba13679121f1ddf14b26a36f4f4a3cc73e4

[jira] [Assigned] (FLINK-27904) Introduce HsDataBuffer

[ https://issues.apache.org/jira/browse/FLINK-27904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27904: Assignee: Aitozi > Introduce HsDataBuffer > -- > >

[jira] [Closed] (FLINK-27903) Introduce and support HYBRID resultPartitionType

[ https://issues.apache.org/jira/browse/FLINK-27903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27903. Fix Version/s: 1.16.0 Resolution: Done master: aa693b5076f5461bb193946cd75cbe6d8e101a90 >

[jira] [Assigned] (FLINK-27903) Introduce and support HYBRID resultPartitionType

[ https://issues.apache.org/jira/browse/FLINK-27903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27903: Assignee: Weijie Guo > Introduce and support HYBRID resultPartitionType >

[jira] [Closed] (FLINK-27920) Documented enums constant support ExcludeFromDocumentation annotation

[ https://issues.apache.org/jira/browse/FLINK-27920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27920. Fix Version/s: 1.16.0 Resolution: Done master: 608e40ac42bacda2aacc6be57d2072ece7f0cf31 >

[jira] [Commented] (FLINK-27920) Documented enums constant support ExcludeFromDocumentation annotation

[ https://issues.apache.org/jira/browse/FLINK-27920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551893#comment-17551893 ] Xintong Song commented on FLINK-27920: -- I think prefixing the enum value is really a good idea.

[jira] [Commented] (FLINK-27920) Documented enums constant support ExcludeFromDocumentation annotation

[ https://issues.apache.org/jira/browse/FLINK-27920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551516#comment-17551516 ] Xintong Song commented on FLINK-27920: -- Well, that could happen. Unfortunately, I don't find a good

[jira] [Commented] (FLINK-27710) Improve logs to better display Execution

[ https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551468#comment-17551468 ] Xintong Song commented on FLINK-27710: -- I'm not entirely sure about the format. An execution is

[jira] [Closed] (FLINK-27902) Refactor ResultPartitionType to decouple scheduling and partition release logic

[ https://issues.apache.org/jira/browse/FLINK-27902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27902. Resolution: Fixed master: 98d4cd659bc33313de3888e5e1e29bdf4b182f2e > Refactor

[jira] [Updated] (FLINK-27902) Refactor ResultPartitionType to decouple scheduling and partition release logic

[ https://issues.apache.org/jira/browse/FLINK-27902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27902: - Fix Version/s: 1.16.0 > Refactor ResultPartitionType to decouple scheduling and partition

[jira] [Commented] (FLINK-27920) Documented enums constant support ExcludeFromDocumentation annotation

[ https://issues.apache.org/jira/browse/FLINK-27920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550911#comment-17550911 ] Xintong Song commented on FLINK-27920: -- [~chesnay], This comes from the Hybrid Shuffle effort. We

[jira] [Assigned] (FLINK-27920) Documented enums constant support ExcludeFromDocumentation annotation

[ https://issues.apache.org/jira/browse/FLINK-27920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27920: Assignee: Weijie Guo > Documented enums constant support ExcludeFromDocumentation

[jira] [Commented] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode

[ https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550822#comment-17550822 ] Xintong Song commented on FLINK-27862: -- Hi [~aitozi], Thanks for offering. I see several ways that

[jira] [Assigned] (FLINK-27902) Refactor ResultPartitionType to decouple scheduling and partition release logic

[ https://issues.apache.org/jira/browse/FLINK-27902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27902: Assignee: Weijie Guo (was: reswqa) > Refactor ResultPartitionType to decouple

[jira] [Updated] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode

[ https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27862: - Reporter: Weijie Guo (was: reswqa) > FLIP-235: Hybrid Shuffle Mode >

[jira] [Assigned] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode

[ https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27862: Assignee: Weijie Guo (was: Guo Weijie) > FLIP-235: Hybrid Shuffle Mode >

[jira] [Updated] (FLINK-27902) Refactor ResultPartitionType to decouple scheduling and partition release logic

[ https://issues.apache.org/jira/browse/FLINK-27902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27902: - Affects Version/s: (was: 1.16.0) > Refactor ResultPartitionType to decouple scheduling and

[jira] [Updated] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode

[ https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27862: - Affects Version/s: (was: 1.16.0) > FLIP-235: Hybrid Shuffle Mode >

[jira] [Assigned] (FLINK-27902) Refactor ResultPartitionType to decouple scheduling and partition release logic

[ https://issues.apache.org/jira/browse/FLINK-27902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27902: Assignee: Guo Weijie > Refactor ResultPartitionType to decouple scheduling and partition

[jira] [Closed] (FLINK-27720) Slack: Update the project website regarding communication channels

[ https://issues.apache.org/jira/browse/FLINK-27720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27720. Resolution: Done Subsumed by FLINK-27722 > Slack: Update the project website regarding

[jira] [Assigned] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode

[ https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-27862: Assignee: Guo Weijie > FLIP-235: Hybrid Shuffle Mode > - > >

[jira] [Closed] (FLINK-27848) ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid

[ https://issues.apache.org/jira/browse/FLINK-27848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27848. Resolution: Fixed Fixed in: - release-1.15: 73a33ab5f25dd5ac7e8adb1521c092a8aedcc736 >

[jira] [Updated] (FLINK-27848) ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid

[ https://issues.apache.org/jira/browse/FLINK-27848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27848: - Affects Version/s: (was: 1.14.4) > ZooKeeperLeaderElectionDriver keeps writing leader

[jira] [Updated] (FLINK-27848) ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid

[ https://issues.apache.org/jira/browse/FLINK-27848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27848: - Fix Version/s: (was: 1.14.5) > ZooKeeperLeaderElectionDriver keeps writing leader

[jira] [Updated] (FLINK-27848) ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid

[ https://issues.apache.org/jira/browse/FLINK-27848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27848: - Description: After a leadership change, the new leader may keeps writing its information

[jira] [Commented] (FLINK-27722) Slack: set up auto-updated invitation link

[ https://issues.apache.org/jira/browse/FLINK-27722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544662#comment-17544662 ] Xintong Song commented on FLINK-27722: -- Thanks [~martijnvisser]. +1 to open up the Flink Slack

[jira] [Updated] (FLINK-27848) ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid

[ https://issues.apache.org/jira/browse/FLINK-27848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27848: - Description: After a leadership change, the new leader may keeps writing its information

[jira] [Created] (FLINK-27848) ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid

Xintong Song created FLINK-27848: Summary: ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid Key: FLINK-27848 URL: https://issues.apache.org/jira/browse/FLINK-27848

[jira] [Commented] (FLINK-27722) Slack: set up auto-updated invitation link

[ https://issues.apache.org/jira/browse/FLINK-27722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544094#comment-17544094 ] Xintong Song commented on FLINK-27722: -- I think including the invitation link directly on the

[jira] [Commented] (FLINK-27722) Slack: set up auto-updated invitation link

[ https://issues.apache.org/jira/browse/FLINK-27722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542753#comment-17542753 ] Xintong Song commented on FLINK-27722: -- I've also tried [this

[jira] [Commented] (FLINK-27722) Slack: set up auto-updated invitation link

[ https://issues.apache.org/jira/browse/FLINK-27722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542352#comment-17542352 ] Xintong Song commented on FLINK-27722: -- I tried but couldn't update it. - w/o checking the override

<    5   6   7   8   9   10   11   12   13   14   >