[jira] [Resolved] (FLINK-37249) Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util

[ https://issues.apache.org/jira/browse/FLINK-37249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37249. Fix Version/s: 2.1 Resolution: Fixed master 5d98b8a277a7231780023d918d6a85ee801bb6b1 > Rem

[jira] [Comment Edited] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline

[ https://issues.apache.org/jira/browse/FLINK-37761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17953409#comment-17953409 ] Junrui Lee edited comment on FLINK-37761 at 5/29/25 9:14 AM: -

[jira] [Resolved] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline

[ https://issues.apache.org/jira/browse/FLINK-37761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37761. Fix Version/s: 2.1 Resolution: Fixed master 78e0d01f0c6d55d3d2f986e5c142079fef7a88f1 > Bat

[jira] [Commented] (FLINK-37825) Standard YAML convert and dump failed

[ https://issues.apache.org/jira/browse/FLINK-37825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17953298#comment-17953298 ] Junrui Lee commented on FLINK-37825: I think the issue is that your dev code does no

[jira] [Commented] (FLINK-33297) FLIP-366: Support standard YAML for FLINK configuration

[ https://issues.apache.org/jira/browse/FLINK-33297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17953078#comment-17953078 ] Junrui Lee commented on FLINK-33297: [~melin] Could you please create a new Jira tic

[jira] [Comment Edited] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline

[ https://issues.apache.org/jira/browse/FLINK-37761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949900#comment-17949900 ] Junrui Lee edited comment on FLINK-37761 at 5/7/25 5:55 AM:

[jira] [Commented] (FLINK-37761) BatchJobRecoveryTest.testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot test failed of test_cron_azure core pipeline

[ https://issues.apache.org/jira/browse/FLINK-37761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17949900#comment-17949900 ] Junrui Lee commented on FLINK-37761: [~lsy] ** I will try to replicate it locally fi

[jira] [Resolved] (FLINK-37680) Add subclass cache for PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-37680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37680. Fix Version/s: 2.1.0 Resolution: Fixed master 794005c5c33669e72706bcb9a51a13bf3fb6c39e > A

[jira] [Assigned] (FLINK-37680) Add subclass cache for PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-37680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37680: -- Assignee: Zhanghao Chen > Add subclass cache for PojoSerializer > ---

[jira] [Closed] (FLINK-27383) Make Application mode wait with cluster shutdown until cleanup is done

[ https://issues.apache.org/jira/browse/FLINK-27383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-27383. -- Resolution: Fixed fixed by FLINK-37697 > Make Application mode wait with cluster shutdown until clean

[jira] [Resolved] (FLINK-37697) ExecutionGraphInfo may not be archived when cluster shutdown in application mode

[ https://issues.apache.org/jira/browse/FLINK-37697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37697. Fix Version/s: 2.1.0 Resolution: Fixed master b0607a15e62b664d15efbda0b0e991f72e45a467 > E

[jira] [Commented] (FLINK-37697) ExecutionGraphInfo may not be archived when cluster shutdown in application mode

[ https://issues.apache.org/jira/browse/FLINK-37697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17945700#comment-17945700 ] Junrui Lee commented on FLINK-37697: Assigned to you, [~yizh]  > ExecutionGraphInfo

[jira] [Assigned] (FLINK-37697) ExecutionGraphInfo may not be archived when cluster shutdown in application mode

[ https://issues.apache.org/jira/browse/FLINK-37697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37697: -- Assignee: Yi Zhang > ExecutionGraphInfo may not be archived when cluster shutdown in applicat

[jira] [Closed] (FLINK-37225) Remove remaining test resources of Gelly

[ https://issues.apache.org/jira/browse/FLINK-37225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37225. -- Resolution: Fixed master 0a1b3ca917949e1f1965e8eec27b0d31889d690b > Remove remaining test resources o

[jira] [Assigned] (FLINK-37225) Remove remaining test resources of Gelly

[ https://issues.apache.org/jira/browse/FLINK-37225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37225: -- Assignee: Zhanghao Chen > Remove remaining test resources of Gelly >

[jira] [Resolved] (FLINK-37576) Batch job failed when submit JobGraph contains broadcast edge

[ https://issues.apache.org/jira/browse/FLINK-37576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37576. Fix Version/s: 2.1.0 2.0.1 Resolution: Fixed master d5e1ff2ecabea0c6babd

[jira] [Assigned] (FLINK-37568) Improve the method flatten of class GlobalConfiguration

[ https://issues.apache.org/jira/browse/FLINK-37568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37568: -- Assignee: Jiaan Geng > Improve the method flatten of class GlobalConfiguration >

[jira] [Resolved] (FLINK-37568) Improve the method flatten of class GlobalConfiguration

[ https://issues.apache.org/jira/browse/FLINK-37568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37568. Fix Version/s: 2.1.0 2.0.1 Resolution: Fixed master d5ecb07dab460f0dfff7

[jira] [Commented] (FLINK-37387) License check behaves differently for different jdk versions

[ https://issues.apache.org/jira/browse/FLINK-37387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932485#comment-17932485 ] Junrui Lee commented on FLINK-37387: release-2.0 315046b171b13b4e02c0ad1a4e4529305fd

[jira] [Resolved] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-36172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-36172. Fix Version/s: 2.0.0 Resolution: Fixed master: 65772142fda02bb000f4adfca3c8589907130402 re

[jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out

[ https://issues.apache.org/jira/browse/FLINK-34224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931618#comment-17931618 ] Junrui Lee commented on FLINK-34224: https://dev.azure.com/apache-flink/apache-flink

[jira] [Closed] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios

[ https://issues.apache.org/jira/browse/FLINK-37384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37384. -- Resolution: Fixed master  741ff29b67535427eedb7b8a757b6acbd12c40e5 d45f0da6d02e5260e015f771c36bea447

[jira] [Updated] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios

[ https://issues.apache.org/jira/browse/FLINK-37384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37384: --- Fix Version/s: (was: 2.0.1) > the execution time of DefaultVertexParallelismAndInputInfosDecider

[jira] [Updated] (FLINK-37333) Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect

[ https://issues.apache.org/jira/browse/FLINK-37333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37333: --- Fix Version/s: 2.0.1 > Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effec

[jira] [Closed] (FLINK-37382) Early optimization for adaptive join when one input is below broadcast threshold

[ https://issues.apache.org/jira/browse/FLINK-37382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37382. -- Fix Version/s: 2.0.0 2.0.1 Resolution: Done master 69559fb5d231d704633fed807

[jira] [Assigned] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios

[ https://issues.apache.org/jira/browse/FLINK-37384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37384: -- Assignee: Lei Yang > the execution time of DefaultVertexParallelismAndInputInfosDecider excee

[jira] [Updated] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios

[ https://issues.apache.org/jira/browse/FLINK-37384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37384: --- Fix Version/s: (was: 2.1.0) > the execution time of DefaultVertexParallelismAndInputInfosDecider

[jira] [Assigned] (FLINK-37382) Early optimization for adaptive join when one input is below broadcast threshold

[ https://issues.apache.org/jira/browse/FLINK-37382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37382: -- Assignee: xingbe > Early optimization for adaptive join when one input is below broadcast >

[jira] [Closed] (FLINK-37350) Memory leak caused by skewed join optimization strategy

[ https://issues.apache.org/jira/browse/FLINK-37350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37350. -- Assignee: Lei Yang Resolution: Fixed master add2cd65873a9a6ea36934b4f295678d9ea5bd74 f02ef226894

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

[ https://issues.apache.org/jira/browse/FLINK-37161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17929667#comment-17929667 ] Junrui Lee commented on FLINK-37161: Thanks [~xiasun] for verification~ > Cross-tea

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

[ https://issues.apache.org/jira/browse/FLINK-37161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37161. -- Resolution: Done > Cross-team verification for "Adaptive skewed join optimization for batch jobs" > --

[jira] [Assigned] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-36172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-36172: -- Assignee: Francesco > Web UI Freezes When There Are Many Finished Tasks in Batch Jobs > -

[jira] [Commented] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-36172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17929549#comment-17929549 ] Junrui Lee commented on FLINK-36172: [~fdc91] Thanks for your work on this issue. I'

[jira] [Closed] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss

[ https://issues.apache.org/jira/browse/FLINK-35724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-35724. -- Fix Version/s: 2.0.0 2.0.1 Resolution: Done master 225ef6a2a060bff13530d699d

[jira] [Assigned] (FLINK-35622) Filter out noisy "Coordinator of operator xxxx does not exist" exceptions in batch mode

[ https://issues.apache.org/jira/browse/FLINK-35622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-35622: -- Assignee: Biao Geng > Filter out noisy "Coordinator of operator does not exist" exceptio

[jira] [Closed] (FLINK-35622) Filter out noisy "Coordinator of operator xxxx does not exist" exceptions in batch mode

[ https://issues.apache.org/jira/browse/FLINK-35622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-35622. -- Fix Version/s: 2.0.1 Resolution: Fixed master c92f208f4a074812b5314f2b4858f244b5ecd9fe > Filte

[jira] [Commented] (FLINK-37333) Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect

[ https://issues.apache.org/jira/browse/FLINK-37333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928971#comment-17928971 ] Junrui Lee commented on FLINK-37333: release-2.0 83dc6f4013854ccc5089daf7d9bc0472504

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

[ https://issues.apache.org/jira/browse/FLINK-37149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37149. -- Resolution: Done master 1c759337fd9eef2bcf482ae173d0d45355213565 release-2.0 63e1bfbbae1ff43b150fbc0ec

[jira] [Commented] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API"

[ https://issues.apache.org/jira/browse/FLINK-37048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928647#comment-17928647 ] Junrui Lee commented on FLINK-37048: I searched the current flink-streaming-java and

[jira] [Closed] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API"

[ https://issues.apache.org/jira/browse/FLINK-37048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37048. -- Resolution: Done > Cross-team verification for "Remove Deprecated methods/fields/classes in > DataStr

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

[ https://issues.apache.org/jira/browse/FLINK-37160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37160. -- Resolution: Done > Cross-team verification for "Adaptive broadcast join for batch jobs" >

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

[ https://issues.apache.org/jira/browse/FLINK-37160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928646#comment-17928646 ] Junrui Lee commented on FLINK-37160: Thanks [~noorall] for verification! > Cross-te

[jira] [Commented] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss

[ https://issues.apache.org/jira/browse/FLINK-35724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928628#comment-17928628 ] Junrui Lee commented on FLINK-35724: I also encountered this bug when using Flink 1.

[jira] [Assigned] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss

[ https://issues.apache.org/jira/browse/FLINK-35724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-35724: -- Assignee: Junrui Lee > javax.xml.bind.JAXBException not found with jdk11 while writing to oss

[jira] [Commented] (FLINK-36172) Web UI Freezes When There Are Many Finished Tasks in Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-36172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928370#comment-17928370 ] Junrui Lee commented on FLINK-36172: Gentle ping [~Zhanghao Chen] on this issue. >

[jira] [Commented] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs"

[ https://issues.apache.org/jira/browse/FLINK-37073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928271#comment-17928271 ] Junrui Lee commented on FLINK-37073: Thanks [~yizh] for verification~ > Cross-team

[jira] [Closed] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs"

[ https://issues.apache.org/jira/browse/FLINK-37073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37073. -- Resolution: Done > Cross-team verification for "Adaptive optimization for batch jobs" > --

[jira] [Comment Edited] (FLINK-37309) Skewed join optimization not working as expected

[ https://issues.apache.org/jira/browse/FLINK-37309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926712#comment-17926712 ] Junrui Lee edited comment on FLINK-37309 at 2/13/25 8:35 AM: -

[jira] [Closed] (FLINK-37309) Skewed join optimization not working as expected

[ https://issues.apache.org/jira/browse/FLINK-37309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37309. -- > Skewed join optimization not working as expected > > >

[jira] [Resolved] (FLINK-37309) Skewed join optimization not working as expected

[ https://issues.apache.org/jira/browse/FLINK-37309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37309. Resolution: Fixed master * 3790af913214f94c658ad36669c6fd185a9be010 * 05a3e9c578e9efe8755058d1f7f

[jira] [Assigned] (FLINK-37309) Skewed join optimization not working as expected

[ https://issues.apache.org/jira/browse/FLINK-37309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37309: -- Assignee: Lei Yang > Skewed join optimization not working as expected > -

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

[ https://issues.apache.org/jira/browse/FLINK-37150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37150. Fix Version/s: 2.0.0 Resolution: Done master: * 9ea618243727d3297ec66f88bbde89e579d4ed3b

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

[ https://issues.apache.org/jira/browse/FLINK-37160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37160: -- Assignee: (was: xingbe) > Cross-team verification for "Adaptive broadcast join for batch

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

[ https://issues.apache.org/jira/browse/FLINK-37284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37284. Fix Version/s: 2.0.0 2.0.1 Resolution: Fixed release-2.0:  * ea28cadfb1

[jira] [Closed] (FLINK-37056) Cross-team verification for FLINK-23620

[ https://issues.apache.org/jira/browse/FLINK-37056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37056. -- Resolution: Won't Do > Cross-team verification for FLINK-23620 > -

[jira] [Closed] (FLINK-37055) Cross-team verification for "Introduce a clean configuration layer"

[ https://issues.apache.org/jira/browse/FLINK-37055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37055. -- Resolution: Won't Do > Cross-team verification for "Introduce a clean configuration layer" > -

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

[ https://issues.apache.org/jira/browse/FLINK-37161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37161: -- Assignee: (was: Lei Yang) > Cross-team verification for "Adaptive skewed join optimizatio

[jira] [Assigned] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs"

[ https://issues.apache.org/jira/browse/FLINK-37073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37073: -- Assignee: (was: Junrui Lee) > Cross-team verification for "Adaptive optimization for batc

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

[ https://issues.apache.org/jira/browse/FLINK-37284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37284: -- Assignee: Junrui Lee (was: Lei Yang) > ForwardForConsecutiveHashPartitioner cannot be chaine

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

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] [Commented] (FLINK-37218) Avoid repeatedly reading the broadcast buffer from the sort-merge shuffle data file while accumulating small buffers from multiple sub-partitions.

[ https://issues.apache.org/jira/browse/FLINK-37218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924356#comment-17924356 ] Junrui Lee commented on FLINK-37218: release-2.0:4e2bc4d05ffc2911c0347cc0c7ec306

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

[ https://issues.apache.org/jira/browse/FLINK-37218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37218. -- Fix Version/s: 2.0.0 2.1.0 Resolution: Fixed master 8b6a608490322d7eb1056120

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

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] [Updated] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs"

[ https://issues.apache.org/jira/browse/FLINK-37161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37161: --- Description: In Flink 2.0, we support the capability of adaptive skewed join optimization for batch

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

[ https://issues.apache.org/jira/browse/FLINK-37161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37161: --- Description: In Flink 2.0, we support the capability of adaptive skewed join optimization for batch

[jira] [Updated] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs"

[ https://issues.apache.org/jira/browse/FLINK-37073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37073: --- Description: In Flink 2.0, we introduced adaptive batch execution. In this mode, the job graph is i

[jira] [Updated] (FLINK-37182) PartitionedFileWriteReadTest should remove partition files after test finishes.

[ https://issues.apache.org/jira/browse/FLINK-37182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37182: --- Fix Version/s: 2.1.0 > PartitionedFileWriteReadTest should remove partition files after test > fini

[jira] [Resolved] (FLINK-37182) PartitionedFileWriteReadTest should remove partition files after test finishes.

[ https://issues.apache.org/jira/browse/FLINK-37182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37182. Resolution: Fixed master： abbfc66c905c9385a255f9a2193221ba97550884 085f37bfe694bc10e2bc216777ef4b5

[jira] [Assigned] (FLINK-37182) PartitionedFileWriteReadTest should remove partition files after test finishes.

[ https://issues.apache.org/jira/browse/FLINK-37182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37182: -- Assignee: Ao Li > PartitionedFileWriteReadTest should remove partition files after test > fi

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

[ https://issues.apache.org/jira/browse/FLINK-37160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37160: --- Description: In Flink 2.0, we support the capability of adaptive broadcast join for batch jobs, whi

[jira] [Updated] (FLINK-36290) OutOfMemoryError in connect test run

[ https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-36290: --- Attachment: (was: image-2025-01-19-19-49-23-335.png) > OutOfMemoryError in connect test run > --

[jira] [Updated] (FLINK-36290) OutOfMemoryError in connect test run

[ https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-36290: --- Attachment: image-2025-01-19-19-49-23-335.png > OutOfMemoryError in connect test run > -

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

[ https://issues.apache.org/jira/browse/FLINK-37160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37160: --- Description: This is for cross-team verification of the release 2.0 work item: "Adaptive broadcast

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

[ https://issues.apache.org/jira/browse/FLINK-37161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37161: --- Description: This is for cross-team verification of the release 2.0 work item: "Adaptive skewed joi

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

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"

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] [Updated] (FLINK-36333) FLIP-475: Support Adaptive Skewed Join Optimization

[ https://issues.apache.org/jira/browse/FLINK-36333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-36333: --- Release Note: In Flink 2.0, we introduce the adaptive execution for batch jobs. And this FLIP suppor

[jira] [Updated] (FLINK-36159) FLIP-470: Support Adaptive Broadcast Join

[ https://issues.apache.org/jira/browse/FLINK-36159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-36159: --- Release Note: In Flink 2.0, we introduce the adaptive execution for batch jobs. And this FLIP suppor

[jira] [Closed] (FLINK-36333) FLIP-475: Support Adaptive Skewed Join Optimization

[ https://issues.apache.org/jira/browse/FLINK-36333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-36333. -- Fix Version/s: 2.0.0 Resolution: Done > FLIP-475: Support Adaptive Skewed Join Optimization > -

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

[ https://issues.apache.org/jira/browse/FLINK-37092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37092. -- Fix Version/s: 2.0.0 Resolution: Done master ed6de5854816654db3487ad1d6ec8b34b451c3cf > Enable

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

[ https://issues.apache.org/jira/browse/FLINK-37149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37149: --- Description: This ticket aims to introduce a new page for adaptive batch execution and includes the

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

[ https://issues.apache.org/jira/browse/FLINK-37150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37150: --- Summary: Adjust the documentation of the configuration file to remove the support for the old config

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

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] [Updated] (FLINK-37149) Add Adaptive Batch Execution Documentation

[ https://issues.apache.org/jira/browse/FLINK-37149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37149: --- Labels: 2.0-related (was: ) > Add Adaptive Batch Execution Documentation >

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

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] [Assigned] (FLINK-37139) Improve AdaptiveSkewedJoinOptimizationStrategy to make it effective in more scenarios

[ https://issues.apache.org/jira/browse/FLINK-37139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37139: -- Assignee: Lei Yang > Improve AdaptiveSkewedJoinOptimizationStrategy to make it effective in m

[jira] [Resolved] (FLINK-37139) Improve AdaptiveSkewedJoinOptimizationStrategy to make it effective in more scenarios

[ https://issues.apache.org/jira/browse/FLINK-37139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37139. Fix Version/s: 2.0.0 Resolution: Fixed master d774cf1bdeac654b35993f43718e4fdc68f129cc > I

[jira] [Closed] (FLINK-36159) FLIP-470: Support Adaptive Broadcast Join

[ https://issues.apache.org/jira/browse/FLINK-36159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-36159. -- Fix Version/s: 2.0.0 Resolution: Done > FLIP-470: Support Adaptive Broadcast Join > ---

[jira] [Closed] (FLINK-37090) Introduce a TPC-DS E2E case for adaptive broadcast join

[ https://issues.apache.org/jira/browse/FLINK-37090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37090. -- Resolution: Done master 65db14d9e3534b26c71a6a430f15c24b07ae286a > Introduce a TPC-DS E2E case for ad

[jira] [Updated] (FLINK-37137) testGenerateStreamGraphJson failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-37137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37137: --- Fix Version/s: 2.0.0 > testGenerateStreamGraphJson failed on AZP > -

[jira] [Resolved] (FLINK-37137) testGenerateStreamGraphJson failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-37137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37137. Resolution: Fixed master 07ea97cd1ae71251abd4b0da57803850fe11bc33 > testGenerateStreamGraphJson f

[jira] [Commented] (FLINK-37137) testGenerateStreamGraphJson failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-37137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913230#comment-17913230 ] Junrui Lee commented on FLINK-37137: [~Yu Chen] Could you help to have a look? thx~

[jira] [Assigned] (FLINK-37137) testGenerateStreamGraphJson failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-37137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37137: -- Assignee: Yu Chen > testGenerateStreamGraphJson failed on AZP > -

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

[ https://issues.apache.org/jira/browse/FLINK-37092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911787#comment-17911787 ] Junrui Lee commented on FLINK-37092: Maybe this ticket can depend on https://issues

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

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] [Updated] (FLINK-37090) Introduce a TPC-DS E2E case for adaptive broadcast join

[ https://issues.apache.org/jira/browse/FLINK-37090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-37090: --- Summary: Introduce a TPC-DS E2E case for adaptive broadcast join (was: Introduce tpc-ds e2e case fo

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

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] [Resolved] (FLINK-37085) AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery

[ https://issues.apache.org/jira/browse/FLINK-37085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee resolved FLINK-37085. Fix Version/s: 2.0.0 Resolution: Fixed master:89c7c2b9c55702f6f54191c98c373ec2ce9f6c41 > A

[jira] [Assigned] (FLINK-37085) AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery

[ https://issues.apache.org/jira/browse/FLINK-37085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee reassigned FLINK-37085: -- Assignee: xingbe > AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery > --

[jira] [Updated] (FLINK-36033) FLIP-469: Supports Adaptive Optimization of StreamGraph

[ https://issues.apache.org/jira/browse/FLINK-36033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee updated FLINK-36033: --- Release Note: In 2.0, we introduced adaptive execution for batch jobs. In this mode, the JobGraph w

  1   2   >