[jira] [Created] (FLINK-37284) ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch.

2025-02-07 Thread Junrui Lee (Jira)
Junrui Lee created FLINK-37284: -- Summary: ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch. Key: FLINK-37284 URL: https://issues.apache.org/jira/browse/FLINK-37284 Project: Flink

[jira] [Created] (FLINK-37218) Avoid repeatedly reading the broadcast buffer from the sort-merge shuffle data file while accumulating small buffers from multiple sub-partitions.

2025-01-23 Thread Junrui Lee (Jira)
Junrui Lee created FLINK-37218: -- Summary: Avoid repeatedly reading the broadcast buffer from the sort-merge shuffle data file while accumulating small buffers from multiple sub-partitions. Key: FLINK-37218 URL: http

[jira] [Created] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs"

2025-01-16 Thread Junrui Lee (Jira)
Junrui Lee created FLINK-37161: -- Summary: Cross-team verification for "Adaptive skewed join optimization for batch jobs" Key: FLINK-37161 URL: https://issues.apache.org/jira/browse/FLINK-37161 Project: F

[jira] [Created] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs"

2025-01-16 Thread Junrui Lee (Jira)
Junrui Lee created FLINK-37160: -- Summary: Cross-team verification for "Adaptive broadcast join for batch jobs" Key: FLINK-37160 URL: https://issues.apache.org/jira/browse/FLINK-37160 Project: Flink

[jira] [Created] (FLINK-37150) Adjust the documentation of the configuration file to remove the support for the old configuration file."

2025-01-16 Thread Junrui Lee (Jira)
Junrui Lee created FLINK-37150: -- Summary: Adjust the documentation of the configuration file to remove the support for the old configuration file." Key: FLINK-37150 URL: https://issues.apache.org/jira/browse/FLINK-37

[jira] [Created] (FLINK-37149) Add Adaptive Batch Execution Documentation

2025-01-16 Thread Junrui Lee (Jira)
Junrui Lee created FLINK-37149: -- Summary: Add Adaptive Batch Execution Documentation Key: FLINK-37149 URL: https://issues.apache.org/jira/browse/FLINK-37149 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37092) Enable skewed join optimization in the TPC-DS e2e test.

2025-01-09 Thread Junrui Lee (Jira)
Junrui Lee created FLINK-37092: -- Summary: Enable skewed join optimization in the TPC-DS e2e test. Key: FLINK-37092 URL: https://issues.apache.org/jira/browse/FLINK-37092 Project: Flink Issue Typ

[jira] [Created] (FLINK-37090) Introduce tpc-ds e2e case for adaptive broadcast join

2025-01-09 Thread Junrui Lee (Jira)
Junrui Lee created FLINK-37090: -- Summary: Introduce tpc-ds e2e case for adaptive broadcast join Key: FLINK-37090 URL: https://issues.apache.org/jira/browse/FLINK-37090 Project: Flink Issue Type:

[jira] [Created] (FLINK-36959) Computing readable buffer offsets and sizes when including empty buffers fails.

2024-12-24 Thread Junrui Lee (Jira)
Junrui Lee created FLINK-36959: -- Summary: Computing readable buffer offsets and sizes when including empty buffers fails. Key: FLINK-36959 URL: https://issues.apache.org/jira/browse/FLINK-36959 Project:

[jira] [Created] (FLINK-36850) Adapting batch job progress recovery with StreamGraph adaptive optimization

2024-12-04 Thread Junrui Lee (Jira)
Junrui Lee created FLINK-36850: -- Summary: Adapting batch job progress recovery with StreamGraph adaptive optimization Key: FLINK-36850 URL: https://issues.apache.org/jira/browse/FLINK-36850 Project: Flin