[jira] [Commented] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-07-03 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862917#comment-17862917 ] Yuxin Tan commented on FLINK-35690: --- Thanks [~yyhx] for helping the test. > Release T

[jira] [Commented] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-07-01 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861325#comment-17861325 ] Yuxin Tan commented on FLINK-35690: --- [~fanrui] Thanks for the reminding. We have assig

[jira] [Updated] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-24 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35690: -- Description: Follow up the test for https://issues.apache.org/jira/browse/FLINK-35533 In Flink 1.20,

[jira] [Updated] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-24 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35690: -- Description: Follow up the test for https://issues.apache.org/jira/browse/FLINK-35533 In Flink 1.20,

[jira] [Updated] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-24 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35690: -- Component/s: Runtime / Network > Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integr

[jira] [Closed] (FLINK-35603) Release Testing Instructions: Verify FLINK-35533(FLIP-459): Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-24 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan closed FLINK-35603. - Resolution: Fixed Closed due to FLINK-35690. > Release Testing Instructions: Verify FLINK-35533(FLIP-45

[jira] [Updated] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-24 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35690: -- Labels: release-testing (was: ) > Release Testing: Verify FLIP-459: Support Flink hybrid shuffle inte

[jira] [Created] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-24 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-35690: - Summary: Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn Key: FLINK-35690 URL: https://issues.apache.org/jira/browse/FLINK-35690

[jira] [Updated] (FLINK-35603) Release Testing Instructions: Verify FLINK-35533(FLIP-459): Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-24 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35603: -- Description: Follow up the test for https://issues.apache.org/jira/browse/FLINK-35533 In Flink 1.20,

[jira] [Updated] (FLINK-35603) Release Testing Instructions: Verify FLINK-35533(FLIP-459): Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-24 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35603: -- Description: Follow up the test for https://issues.apache.org/jira/browse/FLINK-35533 In Flink 1.20,

[jira] [Updated] (FLINK-35603) Release Testing Instructions: Verify FLINK-35533(FLIP-459): Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-24 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35603: -- Description: Follow up the test for https://issues.apache.org/jira/browse/FLINK-35533 In Flink 1.20,

[jira] [Updated] (FLINK-35603) Release Testing Instructions: Verify FLINK-35533(FLIP-459): Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-24 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35603: -- Description: Follow up the test for https://issues.apache.org/jira/browse/FLINK-35533 In Flink 1.20,

[jira] [Commented] (FLINK-35587) Job fails with "The read buffer is null in credit-based input channel" on TPC-DS 10TB benchmark

2024-06-21 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856695#comment-17856695 ] Yuxin Tan commented on FLINK-35587: --- After some discussions with [~Weijie Guo] and [~J

[jira] [Updated] (FLINK-35658) Hybrid shuffle external tier can not work with UnknownInputChannel

2024-06-20 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35658: -- Labels: pull-request-available (was: ) > Hybrid shuffle external tier can not work with UnknownInputC

[jira] [Created] (FLINK-35658) Hybrid shuffle external tier can not work with UnknownInputChannel

2024-06-20 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-35658: - Summary: Hybrid shuffle external tier can not work with UnknownInputChannel Key: FLINK-35658 URL: https://issues.apache.org/jira/browse/FLINK-35658 Project: Flink

[jira] [Updated] (FLINK-35533) FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-05 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35533: -- Description: This is the jira for [FLIP-459|https://cwiki.apache.org/confluence/display/FLINK/FLIP-459

[jira] [Updated] (FLINK-35533) FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-05 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35533: -- Labels: (was: Umbrella) > FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn >

[jira] [Created] (FLINK-35533) FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-05 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-35533: - Summary: FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn Key: FLINK-35533 URL: https://issues.apache.org/jira/browse/FLINK-35533 Project: Flink

[jira] [Updated] (FLINK-35533) FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

2024-06-05 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35533: -- Labels: Umbrella (was: ) > FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn >

[jira] [Closed] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

2024-05-21 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan closed FLINK-35130. - Fix Version/s: 1.20.0 Resolution: Fixed > Simplify AvailabilityNotifierImpl to support speculativ

[jira] [Commented] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

2024-05-21 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848153#comment-17848153 ] Yuxin Tan commented on FLINK-35130: --- master(1.20.0): 46aaea8083047fc86c35491336d795ddc

[jira] [Updated] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated

2024-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35214: -- Fix Version/s: 1.20.0 > Update result partition id for remote input channel when unknown input > chan

[jira] [Assigned] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated

2024-04-22 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-35214: - Assignee: Yuxin Tan > Update result partition id for remote input channel when unknown input >

[jira] [Created] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated

2024-04-22 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-35214: - Summary: Update result partition id for remote input channel when unknown input channel is updated Key: FLINK-35214 URL: https://issues.apache.org/jira/browse/FLINK-35214 P

[jira] [Assigned] (FLINK-35166) Improve the performance of Hybrid Shuffle when enable memory decoupling

2024-04-21 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-35166: - Assignee: Jiang Xin > Improve the performance of Hybrid Shuffle when enable memory decoupling >

[jira] [Created] (FLINK-35169) Recycle buffers to freeSegments before releasing data buffer for sort accumulator

2024-04-18 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-35169: - Summary: Recycle buffers to freeSegments before releasing data buffer for sort accumulator Key: FLINK-35169 URL: https://issues.apache.org/jira/browse/FLINK-35169 Project:

[jira] [Assigned] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

2024-04-17 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-35130: - Assignee: Yuxin Tan > Simplify AvailabilityNotifierImpl to support speculative scheduler and >

[jira] [Created] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

2024-04-17 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-35130: - Summary: Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance Key: FLINK-35130 URL: https://issues.apache.org/jira/browse/FLINK-35130

[jira] [Updated] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

2024-04-17 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35130: -- Description: The AvailabilityNotifierImpl in SingleInputGate has maps storing the channel ids. But th

[jira] [Updated] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

2024-04-17 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35130: -- Description: The AvailabilityNotifierImpl in SingleInputGate has maps storing the channel ids. But the

[jira] [Closed] (FLINK-34544) Fix tiered result partition check state issue when finishing partition

2024-03-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan closed FLINK-34544. - Resolution: Won't Fix > Fix tiered result partition check state issue when finishing partition > ---

[jira] [Reopened] (FLINK-34544) Fix tiered result partition check state issue when finishing partition

2024-03-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reopened FLINK-34544: --- > Fix tiered result partition check state issue when finishing partition > -

[jira] (FLINK-34544) Fix tiered result partition check state issue when finishing partition

2024-03-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544 ] Yuxin Tan deleted comment on FLINK-34544: --- was (Author: tanyuxin): It is already fixed in https://issues.apache.org/jira/browse/FLINK-33743. > Fix tiered result partition check state issue whe

[jira] [Closed] (FLINK-34544) Fix tiered result partition check state issue when finishing partition

2024-03-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan closed FLINK-34544. - Resolution: Fixed It is already fixed in https://issues.apache.org/jira/browse/FLINK-33743. > Fix tiere

[jira] [Commented] (FLINK-34544) Fix tiered result partition check state issue when finishing partition

2024-03-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822842#comment-17822842 ] Yuxin Tan commented on FLINK-34544: --- I noticed that the issue has been fixed by changi

[jira] [Updated] (FLINK-34544) Fix tiered result partition check state issue when finishing partition

2024-03-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-34544: -- Description: When finishing the tiered result partition, it may throw a check state issue because the

[jira] [Updated] (FLINK-34544) Fix tiered result partition check state issue when finishing partition

2024-03-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-34544: -- Description: When finishing (was: When releasing `TieredResultPartition`, it is not protected by a l

[jira] [Updated] (FLINK-34544) Fix tiered result partition check state issue when finishing partition

2024-03-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-34544: -- Summary: Fix tiered result partition check state issue when finishing partition (was: Tiered result p

[jira] [Updated] (FLINK-34544) Tiered result partition should be released with lock

2024-02-29 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-34544: -- Description: When releasing `TieredResultPartition`, it is not protected by a lock(just like SortMerge

[jira] [Updated] (FLINK-34544) Tiered result partition should be released with lock

2024-02-29 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-34544: -- Description: When releasing `TieredResultPartition`, it is not protected by a lock(just like SortMerge

[jira] [Updated] (FLINK-34544) Tiered result partition should be released with lock

2024-02-28 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-34544: -- Description: When releasing `TieredResultPartition`, it is not protected by a lock, then it may throw

[jira] [Updated] (FLINK-34544) Tiered result partition should be released with lock

2024-02-28 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-34544: -- Description: When releasing `TieredResultPartition`, it is not protected by a lock, then it may thrown

[jira] [Updated] (FLINK-34544) Tiered result partition should be released with lock

2024-02-28 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-34544: -- Summary: Tiered result partition should be released with lock (was: The release check bug in tiered m

[jira] [Updated] (FLINK-34544) The release check bug in tiered memory manager of hybrid shuffle

2024-02-28 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-34544: -- Affects Version/s: 1.20.0 (was: 1.19.0) > The release check bug in tiered m

[jira] [Created] (FLINK-34544) The release check bug in tiered memory manager of hybrid shuffle

2024-02-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-34544: - Summary: The release check bug in tiered memory manager of hybrid shuffle Key: FLINK-34544 URL: https://issues.apache.org/jira/browse/FLINK-34544 Project: Flink I

[jira] [Commented] (FLINK-34424) BoundedBlockingSubpartitionWriteReadTest#testRead10ConsumersConcurrent times out

2024-02-19 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818615#comment-17818615 ] Yuxin Tan commented on FLINK-34424: --- [~mapohl] [~pnowojski] Sorry for the late reply.

[jira] [Assigned] (FLINK-33743) Support consuming multiple subpartitions on a single channel

2023-12-04 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-33743: - Assignee: (was: Yuxin Tan) > Support consuming multiple subpartitions on a single channel >

[jira] [Assigned] (FLINK-33743) Support consuming multiple subpartitions on a single channel

2023-12-04 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-33743: - Assignee: Yunfeng Zhou > Support consuming multiple subpartitions on a single channel > ---

[jira] [Assigned] (FLINK-33743) Support consuming multiple subpartitions on a single channel

2023-12-04 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-33743: - Assignee: Yuxin Tan > Support consuming multiple subpartitions on a single channel > --

[jira] [Updated] (FLINK-33743) Support consuming multiple subpartitions on a single channel

2023-12-04 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33743: -- Description: In Flink jobs that use the AdaptiveBatchScheduler and enable adaptive parallelism, a down

[jira] [Created] (FLINK-33746) More precise dynamic selection of Hybrid Shuffle or AQE

2023-12-04 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33746: - Summary: More precise dynamic selection of Hybrid Shuffle or AQE Key: FLINK-33746 URL: https://issues.apache.org/jira/browse/FLINK-33746 Project: Flink Issue Type:

[jira] [Created] (FLINK-33745) Dynamically choose hybrid shuffle or AQE in a job level

2023-12-04 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33745: - Summary: Dynamically choose hybrid shuffle or AQE in a job level Key: FLINK-33745 URL: https://issues.apache.org/jira/browse/FLINK-33745 Project: Flink Issue Type:

[jira] [Created] (FLINK-33744) Hybrid shuffle avoids restarting the whole job when failover

2023-12-04 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33744: - Summary: Hybrid shuffle avoids restarting the whole job when failover Key: FLINK-33744 URL: https://issues.apache.org/jira/browse/FLINK-33744 Project: Flink Issue

[jira] [Updated] (FLINK-33742) Hybrid Shuffle should work well with Adaptive Query Execution

2023-12-04 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33742: -- Description: At present, Hybrid Shuffle and Adaptive Query Execution (AQE), which includes features s

[jira] [Created] (FLINK-33743) Support consuming multiple subpartitions on a single channel

2023-12-04 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33743: - Summary: Support consuming multiple subpartitions on a single channel Key: FLINK-33743 URL: https://issues.apache.org/jira/browse/FLINK-33743 Project: Flink Issue

[jira] [Created] (FLINK-33742) Hybrid Shuffle should work well with Adaptive Query Execution

2023-12-04 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33742: - Summary: Hybrid Shuffle should work well with Adaptive Query Execution Key: FLINK-33742 URL: https://issues.apache.org/jira/browse/FLINK-33742 Project: Flink Issu

[jira] [Commented] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

2023-11-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789300#comment-17789300 ] Yuxin Tan commented on FLINK-33635: --- The failed reason is that the APIs are changed by

[jira] [Assigned] (FLINK-33612) The table plan of hybrid shuffle may introduce additional blocking edges occasionally

2023-11-21 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-33612: - Assignee: Yuxin Tan > The table plan of hybrid shuffle may introduce additional blocking edges

[jira] [Created] (FLINK-33612) The table plan of hybrid shuffle may introduce additional blocking edges occasionally

2023-11-21 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33612: - Summary: The table plan of hybrid shuffle may introduce additional blocking edges occasionally Key: FLINK-33612 URL: https://issues.apache.org/jira/browse/FLINK-33612 Proje

[jira] [Updated] (FLINK-33582) Update flink-shaded version

2023-11-20 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33582: -- Affects Version/s: 1.17.3 (was: 1.17.2) > Update flink-shaded version > ---

[jira] [Commented] (FLINK-33593) Left title bar of the official documentation for the master branch is misaligned

2023-11-20 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787936#comment-17787936 ] Yuxin Tan commented on FLINK-33593: --- [~lsy] Hi, Dalong, the issue has been resolved at

[jira] [Assigned] (FLINK-33582) Update flink-shaded version

2023-11-17 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-33582: - Assignee: Yuxin Tan > Update flink-shaded version > --- > >

[jira] [Updated] (FLINK-33582) Update flink-shaded version

2023-11-17 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33582: -- Description: This is a follow-up task for https://issues.apache.org/jira/browse/FLINK-33417. After f

[jira] [Created] (FLINK-33582) Update flink-shaded version

2023-11-17 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33582: - Summary: Update flink-shaded version Key: FLINK-33582 URL: https://issues.apache.org/jira/browse/FLINK-33582 Project: Flink Issue Type: Bug Components: B

[jira] [Updated] (FLINK-33537) Docs version nav is missing 1.18 as an option

2023-11-14 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33537: -- Affects Version/s: 1.19.0 > Docs version nav is missing 1.18 as an option > --

[jira] [Commented] (FLINK-33537) Docs version nav is missing 1.18 as an option

2023-11-14 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786187#comment-17786187 ] Yuxin Tan commented on FLINK-33537: --- [~rmoff] Thanks for reporting this issue. I will

[jira] [Commented] (FLINK-33512) Update download link in doc of Kafka connector

2023-11-14 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786144#comment-17786144 ] Yuxin Tan commented on FLINK-33512: --- Fixed in https://issues.apache.org/jira/browse/FL

[jira] [Comment Edited] (FLINK-33401) Kafka connector has broken version

2023-11-10 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784724#comment-17784724 ] Yuxin Tan edited comment on FLINK-33401 at 11/10/23 8:47 AM: -

[jira] [Comment Edited] (FLINK-33401) Kafka connector has broken version

2023-11-10 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784724#comment-17784724 ] Yuxin Tan edited comment on FLINK-33401 at 11/10/23 8:47 AM: -

[jira] [Commented] (FLINK-33401) Kafka connector has broken version

2023-11-10 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784724#comment-17784724 ] Yuxin Tan commented on FLINK-33401: --- After merging the Flink 1.19 hotfix (fa1036c73e3b

[jira] [Updated] (FLINK-33401) Kafka connector has broken version

2023-11-10 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33401: -- Attachment: screenshot-1.png > Kafka connector has broken version > --

[jira] [Commented] (FLINK-33493) Elasticsearch connector ElasticsearchWriterITCase test failed

2023-11-09 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784674#comment-17784674 ] Yuxin Tan commented on FLINK-33493: --- [~martijnvisser] Yeah. I will take a look at this

[jira] [Commented] (FLINK-33493) Elasticsearch connector ElasticsearchWriterITCase test failed

2023-11-09 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784361#comment-17784361 ] Yuxin Tan commented on FLINK-33493: --- In addition, the affected version can not add 4.0

[jira] [Updated] (FLINK-33493) Elasticsearch connector ElasticsearchWriterITCase test failed

2023-11-09 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33493: -- Description: When I ran tests, the test failed. The failed reason is {code:java} Error: /home/runne

[jira] [Updated] (FLINK-33493) Elasticsearch connector ElasticsearchWriterITCase test failed

2023-11-09 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33493: -- Description: When I ran tests, the test failed. The failed reason is {code:java} Error: /home/runne

[jira] [Created] (FLINK-33493) Elasticsearch connector ElasticsearchWriterITCase test failed

2023-11-09 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33493: - Summary: Elasticsearch connector ElasticsearchWriterITCase test failed Key: FLINK-33493 URL: https://issues.apache.org/jira/browse/FLINK-33493 Project: Flink Issu

[jira] [Commented] (FLINK-33401) Kafka connector has broken version

2023-11-06 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783166#comment-17783166 ] Yuxin Tan commented on FLINK-33401: --- [~pavelhp] I noticed that it has been released. Y

[jira] [Commented] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-03 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782463#comment-17782463 ] Yuxin Tan commented on FLINK-33417: --- [~mapohl] ok. Thanks for the tracking. The error

[jira] [Updated] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-03 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33417: -- Attachment: run.log > Update netty version to 4.1.83 for flink-shaded > --

[jira] (FLINK-33445) Translate DataSet migration guideline to Chinese

2023-11-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33445 ] Yuxin Tan deleted comment on FLINK-33445: --- was (Author: tanyuxin): [~liyubin117] Thanks for helping, assigned to you. > Translate DataSet migration guideline to Chinese > -

[jira] [Commented] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782399#comment-17782399 ] Yuxin Tan commented on FLINK-33417: --- [~mapohl] Actually, as I don't possess an in-dept

[jira] [Commented] (FLINK-33445) Translate DataSet migration guideline to Chinese

2023-11-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782385#comment-17782385 ] Yuxin Tan commented on FLINK-33445: --- [~liyubin117] Thanks for helping, assigned to you

[jira] [Assigned] (FLINK-33445) Translate DataSet migration guideline to Chinese

2023-11-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-33445: - Assignee: Yubin Li > Translate DataSet migration guideline to Chinese > ---

[jira] [Updated] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33417: -- Description: In our ARM environment, we encounter a compile error when using Flink 1.17. (The BE20xxx

[jira] [Updated] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33417: -- Attachment: 09DD8FAA-7701-4AA0-85F9-4ABA6C5117DF.png > Update netty version to 4.1.83 for flink-shaded

[jira] [Updated] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-02 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33417: -- Attachment: BE207321-9677-4721-9415-BD3312C29824.png > Update netty version to 4.1.83 for flink-shaded

[jira] [Updated] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-01 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33417: -- Affects Version/s: shaded-16.1 > Update netty version to 4.1.83 for flink-shaded > ---

[jira] [Assigned] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-01 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-33417: - Assignee: Yuxin Tan > Update netty version to 4.1.83 for flink-shaded > ---

[jira] [Comment Edited] (FLINK-33401) Kafka connector has broken version

2023-10-31 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781563#comment-17781563 ] Yuxin Tan edited comment on FLINK-33401 at 11/1/23 12:24 AM: -

[jira] [Commented] (FLINK-33401) Kafka connector has broken version

2023-10-31 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781563#comment-17781563 ] Yuxin Tan commented on FLINK-33401: --- [~pavelhp] If you wish to try it in Flink 1.18, y

[jira] [Updated] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-10-31 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33417: -- Description: In our ARM environment, we encounter a compile error when using Flink 1.17. Flink 1.17 d

[jira] [Created] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-10-31 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33417: - Summary: Update netty version to 4.1.83 for flink-shaded Key: FLINK-33417 URL: https://issues.apache.org/jira/browse/FLINK-33417 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-33401) Kafka connector has broken version

2023-10-30 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781203#comment-17781203 ] Yuxin Tan commented on FLINK-33401: --- [~pavelhp] Thanks for reporting this issue. I wil

[jira] [Created] (FLINK-33370) Simplify validateAndParseHostsString in Elasticsearch connecter's configuration

2023-10-26 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33370: - Summary: Simplify validateAndParseHostsString in Elasticsearch connecter's configuration Key: FLINK-33370 URL: https://issues.apache.org/jira/browse/FLINK-33370 Project: Fl

[jira] [Commented] (FLINK-33323) HybridShuffleITCase fails with produced an uncaught exception in FatalExitExceptionHandler

2023-10-26 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779779#comment-17779779 ] Yuxin Tan commented on FLINK-33323: --- [~Wencong Liu] Could you please take a look at th

[jira] [Updated] (FLINK-33280) tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart due to timeout

2023-10-18 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33280: -- Component/s: Runtime / Network > tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart

[jira] [Updated] (FLINK-33280) tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart due to timeout

2023-10-18 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33280: -- Fix Version/s: 1.19.0 > tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart due to >

[jira] [Updated] (FLINK-33280) tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart due to timeout

2023-10-18 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33280: -- Affects Version/s: 1.19.0 > tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart due t

[jira] [Closed] (FLINK-33280) tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart due to timeout

2023-10-18 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan closed FLINK-33280. - Resolution: Fixed > tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart due to > timeo

[jira] [Commented] (FLINK-33280) tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart due to timeout

2023-10-18 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776628#comment-17776628 ] Yuxin Tan commented on FLINK-33280: --- The reason is the same as https://issues.apache.o

  1   2   3   4   >