[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

[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

[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=17848153#comment-17848153 ] Yuxin Tan commented on FLINK-35130: --- master(1.20.0): 46aaea8083047fc86c35491336d795ddcd565128 >

[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 >

[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

[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

[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

[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

[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

[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=17822842#comment-17822842 ] Yuxin Tan commented on FLINK-34544: --- I noticed that the issue has been fixed by changing the order of

[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

[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

[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

[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

[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

[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

[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

[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

[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=17818615#comment-17818615 ] Yuxin Tan commented on FLINK-34424: --- [~mapohl] [~pnowojski] Sorry for the late reply. I tried to

[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

[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

[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

[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

[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

[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

[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

[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=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

[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=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

[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:

[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=17786187#comment-17786187 ] Yuxin Tan commented on FLINK-33537: --- [~rmoff] Thanks for reporting this issue. I will take a look. >

[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=17786144#comment-17786144 ] Yuxin Tan commented on FLINK-33512: --- Fixed in https://issues.apache.org/jira/browse/FLINK-33401. >

[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=17784724#comment-17784724 ] Yuxin Tan edited comment on FLINK-33401 at 11/10/23 8:47 AM: - After merging

[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=17784724#comment-17784724 ] Yuxin Tan edited comment on FLINK-33401 at 11/10/23 8:47 AM: - After merging

[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=17784724#comment-17784724 ] Yuxin Tan commented on FLINK-33401: --- After merging the Flink 1.19 hotfix

[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=17784674#comment-17784674 ] Yuxin Tan commented on FLINK-33493: --- [~martijnvisser] Yeah. I will take a look at this issue. >

[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=17784361#comment-17784361 ] Yuxin Tan commented on FLINK-33493: --- In addition, the affected version can not add 4.0.x, because the

[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:

[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:

[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

[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=17783166#comment-17783166 ] Yuxin Tan commented on FLINK-33401: --- [~pavelhp] I noticed that it has been released. You can find the

[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=17782463#comment-17782463 ] Yuxin Tan commented on FLINK-33417: --- [~mapohl] ok. Thanks for the tracking. The error is on our test

[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-03 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=17782399#comment-17782399 ] Yuxin Tan commented on FLINK-33417: --- [~mapohl] Actually, as I don't possess an in-depth understanding

[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=17782385#comment-17782385 ] Yuxin Tan commented on FLINK-33445: --- [~liyubin117] Thanks for helping, assigned to you. > Translate

[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

[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

[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

[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=17781563#comment-17781563 ] Yuxin Tan edited comment on FLINK-33401 at 11/1/23 12:24 AM: - [~pavelhp] If

[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=17781563#comment-17781563 ] Yuxin Tan commented on FLINK-33401: --- [~pavelhp] If you wish to try it in Flink 1.18, you may need to

[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

[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=17781203#comment-17781203 ] Yuxin Tan commented on FLINK-33401: --- [~pavelhp] Thanks for reporting this issue. I will take a look at

[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:

[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=17779779#comment-17779779 ] Yuxin Tan commented on FLINK-33323: --- [~Wencong Liu] Could you please take a look at this issue? >

[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

[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 >

[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=17776628#comment-17776628 ] Yuxin Tan commented on FLINK-33280: --- The reason is the same as

[jira] [Assigned] (FLINK-33185) HybridShuffleITCase fails with TimeoutException: Pending slot request timed out in slot pool on AZP

2023-10-17 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-33185: - Assignee: Yuxin Tan > HybridShuffleITCase fails with TimeoutException: Pending slot request

[jira] [Commented] (FLINK-33185) HybridShuffleITCase fails with TimeoutException: Pending slot request timed out in slot pool on AZP

2023-10-17 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776471#comment-17776471 ] Yuxin Tan commented on FLINK-33185: --- [~Sergey Nuyanzin] Sorry for the late reply. I will take a look.

[jira] [Commented] (FLINK-32193) AWS connector removes the dependency on flink-shaded

2023-10-12 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17774368#comment-17774368 ] Yuxin Tan commented on FLINK-32193: --- Duplicated with https://issues.apache.org/jira/browse/FLINK-33194

[jira] [Closed] (FLINK-32193) AWS connector removes the dependency on flink-shaded

2023-10-12 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan closed FLINK-32193. - Resolution: Duplicate > AWS connector removes the dependency on flink-shaded >

[jira] [Closed] (FLINK-32060) Migrate subclasses of BatchAbstractTestBase in table and other modules to JUnit5

2023-09-18 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan closed FLINK-32060. - > Migrate subclasses of BatchAbstractTestBase in table and other modules to > JUnit5 >

[jira] [Closed] (FLINK-32058) Migrate subclasses of BatchAbstractTestBase in runtime.batch.sql to JUnit5

2023-09-18 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan closed FLINK-32058. - > Migrate subclasses of BatchAbstractTestBase in runtime.batch.sql to JUnit5 >

[jira] [Assigned] (FLINK-32055) Migrate all subclasses of BatchAbstractTestBase to JUnit5

2023-09-18 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-32055: - Assignee: Yuxin Tan > Migrate all subclasses of BatchAbstractTestBase to JUnit5 >

[jira] [Assigned] (FLINK-33103) Hybrid shuffle ITCase supports the new mode

2023-09-18 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-33103: - Assignee: Yuxin Tan > Hybrid shuffle ITCase supports the new mode >

[jira] [Created] (FLINK-33103) Hybrid shuffle ITCase supports the new mode

2023-09-18 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33103: - Summary: Hybrid shuffle ITCase supports the new mode Key: FLINK-33103 URL: https://issues.apache.org/jira/browse/FLINK-33103 Project: Flink Issue Type:

[jira] [Closed] (FLINK-33088) Fix NullPointerException in RemoteTierConsumerAgent of tiered storage

2023-09-15 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan closed FLINK-33088. - Resolution: Fixed > Fix NullPointerException in RemoteTierConsumerAgent of tiered storage >

[jira] [Commented] (FLINK-33088) Fix NullPointerException in RemoteTierConsumerAgent of tiered storage

2023-09-15 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17765530#comment-17765530 ] Yuxin Tan commented on FLINK-33088: --- master(1.19): 1774b84a74f5d348a94bf7dbd5694122150881dd

[jira] [Created] (FLINK-33088) Fix NullPointerException in RemoteTierConsumerAgent of tiered storage

2023-09-14 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33088: - Summary: Fix NullPointerException in RemoteTierConsumerAgent of tiered storage Key: FLINK-33088 URL: https://issues.apache.org/jira/browse/FLINK-33088 Project: Flink

[jira] [Created] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-06 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-33044: - Summary: Reduce the frequency of triggering flush for the disk tier of the tiered storage Key: FLINK-33044 URL: https://issues.apache.org/jira/browse/FLINK-33044 Project:

[jira] [Updated] (FLINK-32779) Release Testing: Verify FLIP-301: Hybrid Shuffle supports Remote Storage

2023-08-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-32779: -- Description: This ticket aims to verify https://issues.apache.org/jira/browse/FLINK-31634. This

[jira] [Assigned] (FLINK-32779) Release Testing: Verify FLIP-301: Hybrid Shuffle supports Remote Storage

2023-08-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-32779: - Assignee: Weijie Guo (was: Weijie Tong) > Release Testing: Verify FLIP-301: Hybrid Shuffle

  1   2   3   4   >