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

2024-06-12 Thread Junrui Li (Jira)
Junrui Li created FLINK-35587: - Summary: Job fails with "The read buffer is null in credit-based input channel" on TPC-DS 10TB benchmark Key: FLINK-35587 URL: https://issues.apache.org/jira/browse/FLINK-35587

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

2024-06-12 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854632#comment-17854632 ] Junrui Li commented on FLINK-35587: --- [~Weijie Guo] [~tanyuxin] Would you mind taking a

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

2024-06-12 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-35587: -- Attachment: image-2024-06-13-13-48-37-162.png > Job fails with "The read buffer is null in credit-base

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

2024-06-12 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-35587: -- Description: While running TPC-DS 10TB benchmark on the latest master branch locally, I've encountere

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

2024-06-12 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-35587: -- Description: While running TPC-DS 10TB benchmark on the latest master branch locally, I've encountere

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

2024-06-16 Thread Junrui Li (Jira)
Junrui Li created FLINK-35622: - Summary: Filter out noisy "Coordinator of operator does not exist" exceptions in batch mode Key: FLINK-35622 URL: https://issues.apache.org/jira/browse/FLINK-35622 Pro

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

2024-06-18 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855933#comment-17855933 ] Junrui Li commented on FLINK-35587: --- [~showuon]  Unfortunately, I didn't save the full

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

2024-06-18 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855933#comment-17855933 ] Junrui Li edited comment on FLINK-35587 at 6/18/24 1:15 PM:

[jira] [Commented] (FLINK-35642) parsing the configuration file in flink, when configuring the s3 key, if there is contain # char, the correct key will be split

2024-06-18 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856140#comment-17856140 ] Junrui Li commented on FLINK-35642: --- [~blackpighe] Could you try to use the new config

[jira] [Created] (FLINK-35669) Release Testing: Verify FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs

2024-06-21 Thread Junrui Li (Jira)
Junrui Li created FLINK-35669: - Summary: Release Testing: Verify FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs Key: FLINK-35669 URL: https://issues.apache.org/jira/browse/FLINK-35669

[jira] [Updated] (FLINK-35669) Release Testing: Verify FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs

2024-06-21 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-35669: -- Description: In 1.20, we introduced a batch job recovery mechanism to enable batch jobs to recover as

[jira] [Commented] (FLINK-35635) Release Testing: Verify FLIP-445: Support dynamic parallelism inference for HiveSource

2024-06-26 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860297#comment-17860297 ] Junrui Li commented on FLINK-35635: --- I'd like to take this ticket. :D > Release Testi

[jira] [Created] (FLINK-35731) Sink V2 operator is mistakenly assumed always to be parallelism configured

2024-06-30 Thread Junrui Li (Jira)
Junrui Li created FLINK-35731: - Summary: Sink V2 operator is mistakenly assumed always to be parallelism configured Key: FLINK-35731 URL: https://issues.apache.org/jira/browse/FLINK-35731 Project: Flink

[jira] [Commented] (FLINK-35635) Release Testing: Verify FLIP-445: Support dynamic parallelism inference for HiveSource

2024-07-04 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863127#comment-17863127 ] Junrui Li commented on FLINK-35635: --- I prepared two Flink jobs to read from Hive. In t

[jira] [Commented] (FLINK-35731) Sink V2 operator is mistakenly assumed always to be parallelism configured

2024-07-05 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863153#comment-17863153 ] Junrui Li commented on FLINK-35731: --- Thanks for reminder, [~zhuzh]  Backport to 1.19:

[jira] [Created] (FLINK-35766) When the job contains many YieldingOperatorFactory instances, compiling the JobGraph hangs

2024-07-05 Thread Junrui Li (Jira)
Junrui Li created FLINK-35766: - Summary: When the job contains many YieldingOperatorFactory instances, compiling the JobGraph hangs Key: FLINK-35766 URL: https://issues.apache.org/jira/browse/FLINK-35766

[jira] [Commented] (FLINK-35766) When the job contains many YieldingOperatorFactory instances, compiling the JobGraph hangs

2024-07-05 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863196#comment-17863196 ] Junrui Li commented on FLINK-35766: --- A simple and intuitive fix would be to cache the

[jira] [Comment Edited] (FLINK-35766) When the job contains many YieldingOperatorFactory instances, compiling the JobGraph hangs

2024-07-05 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863196#comment-17863196 ] Junrui Li edited comment on FLINK-35766 at 7/5/24 10:18 AM:

[jira] [Updated] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2024-02-20 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33581: -- Release Note: The non-ConfigOption objects in the StreamExecutionEnvironment, CheckpointConfig, and E

[jira] [Updated] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2024-02-20 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33581: -- Release Note: The non-ConfigOption objects in the StreamExecutionEnvironment, CheckpointConfig, and E

[jira] [Updated] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2024-02-20 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33581: -- Release Note: The non-ConfigOption objects in the StreamExecutionEnvironment, CheckpointConfig, and E

[jira] [Updated] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2024-02-20 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33581: -- Release Note: The non-ConfigOption objects in the StreamExecutionEnvironment, CheckpointConfig, and E

[jira] [Commented] (FLINK-34356) Release Testing: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-02-21 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819132#comment-17819132 ] Junrui Li commented on FLINK-34356: --- I'd like to take this ticket. [~zhuzh] Could you

[jira] [Commented] (FLINK-34356) Release Testing: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-02-25 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820544#comment-17820544 ] Junrui Li commented on FLINK-34356: --- I have conducted tests for both scenarios as inst

[jira] [Updated] (FLINK-33986) Extend shuffleMaster to support batch snapshot.

2024-02-29 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33986: -- Summary: Extend shuffleMaster to support batch snapshot. (was: Introduce SupportsBatchSnapshot for sh

[jira] [Updated] (FLINK-33986) Extend shuffleMaster to support batch snapshot.

2024-02-29 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33986: -- Description: Extend shuffleMaster to support batch snapshot as follows: # Add method supportsBatchSna

[jira] [Commented] (FLINK-33985) Extend ShuffleMaster to fetch all partition

2024-02-29 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822106#comment-17822106 ] Junrui Li commented on FLINK-33985: --- This ticket can be closed as its contents will be

[jira] [Closed] (FLINK-33985) Extend ShuffleMaster to fetch all partition

2024-02-29 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li closed FLINK-33985. - Resolution: Duplicate > Extend ShuffleMaster to fetch all partition > --

[jira] (FLINK-33985) Support obtain all partitions existing in cluster through ShuffleMaster.

2024-03-13 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33985 ] Junrui Li deleted comment on FLINK-33985: --- was (Author: JIRAUSER293716): This ticket can be closed as its contents will be covered by another ticket. > Support obtain all partitions existing i

[jira] [Updated] (FLINK-33985) Support obtain all partitions existing in cluster through ShuffleMaster.

2024-03-13 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33985: -- Description: Support obtain all partitions existing in cluster through ShuffleMaster. > Support obtai

[jira] [Updated] (FLINK-33985) Support obtain all partitions existing in cluster through ShuffleMaster.

2024-03-13 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33985: -- Summary: Support obtain all partitions existing in cluster through ShuffleMaster. (was: Extend Shuffl

[jira] [Reopened] (FLINK-33985) Support obtain all partitions existing in cluster through ShuffleMaster.

2024-03-13 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li reopened FLINK-33985: --- > Support obtain all partitions existing in cluster through ShuffleMaster. > ---

[jira] [Created] (FLINK-34661) TaskExecutor supports retain partitions after JM crashed.

2024-03-13 Thread Junrui Li (Jira)
Junrui Li created FLINK-34661: - Summary: TaskExecutor supports retain partitions after JM crashed. Key: FLINK-34661 URL: https://issues.apache.org/jira/browse/FLINK-34661 Project: Flink Issue Typ

[jira] [Commented] (FLINK-33299) CLONE - Add checks to guarantee the non-deprecated options not conflicting with standard YAML

2023-10-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776469#comment-17776469 ] Junrui Li commented on FLINK-33299: --- I'm sorry for mistakenly creating an invalid clon

[jira] [Commented] (FLINK-33298) CLONE - Add a suffix to keys that violate YAML spec

2023-10-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776468#comment-17776468 ] Junrui Li commented on FLINK-33298: --- I'm sorry for mistakenly creating an invalid clon

[jira] [Created] (FLINK-33356) The navigation bar on Flink’s official website is messed up.

2023-10-24 Thread Junrui Li (Jira)
Junrui Li created FLINK-33356: - Summary: The navigation bar on Flink’s official website is messed up. Key: FLINK-33356 URL: https://issues.apache.org/jira/browse/FLINK-33356 Project: Flink Issue

[jira] [Commented] (FLINK-33356) The navigation bar on Flink’s official website is messed up.

2023-10-24 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779341#comment-17779341 ] Junrui Li commented on FLINK-33356: --- [~Wencong Liu] Thank you for your volunteering, [

[jira] [Created] (FLINK-33364) Introduce standard YAML for flink configuration

2023-10-25 Thread Junrui Li (Jira)
Junrui Li created FLINK-33364: - Summary: Introduce standard YAML for flink configuration Key: FLINK-33364 URL: https://issues.apache.org/jira/browse/FLINK-33364 Project: Flink Issue Type: Sub-tas

[jira] [Commented] (FLINK-33356) The navigation bar on Flink’s official website is messed up.

2023-11-01 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781621#comment-17781621 ] Junrui Li commented on FLINK-33356: --- [~Wencong Liu] The navigation bar on the official

[jira] [Commented] (FLINK-21126) Reconsider FLINK_PROPERTIES

2023-11-01 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781680#comment-17781680 ] Junrui Li commented on FLINK-21126: --- Hi [~thw], I would like to know if the current o

[jira] [Created] (FLINK-33576) Introduce new Flink conf file config.yaml supporting standard YAML syntax

2023-11-16 Thread Junrui Li (Jira)
Junrui Li created FLINK-33576: - Summary: Introduce new Flink conf file config.yaml supporting standard YAML syntax Key: FLINK-33576 URL: https://issues.apache.org/jira/browse/FLINK-33576 Project: Flink

[jira] [Created] (FLINK-33577) Make "conf.yaml" as the default Flink configuration file

2023-11-16 Thread Junrui Li (Jira)
Junrui Li created FLINK-33577: - Summary: Make "conf.yaml" as the default Flink configuration file Key: FLINK-33577 URL: https://issues.apache.org/jira/browse/FLINK-33577 Project: Flink Issue Type

[jira] [Updated] (FLINK-33576) Introduce new Flink conf file "config.yaml" supporting standard YAML syntax

2023-11-16 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33576: -- Summary: Introduce new Flink conf file "config.yaml" supporting standard YAML syntax (was: Introduce

[jira] [Created] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-16 Thread Junrui Li (Jira)
Junrui Li created FLINK-33581: - Summary: FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects Key: FLINK-33581 URL: https://issues.apache.org/jira/browse/FLINK-33581 Proj

[jira] [Updated] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-16 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33581: -- Description: Deprecate he non-ConfigOption objects in the StreamExecutionEnvironment, CheckpointConfig

[jira] [Commented] (FLINK-33592) The return type of the function is void,not convenient to use

2023-11-19 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787624#comment-17787624 ] Junrui Li commented on FLINK-33592: --- Hi [~zhangtao9876] , The community has already a

[jira] [Created] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

2024-01-10 Thread Junrui Li (Jira)
Junrui Li created FLINK-34052: - Summary: Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository Key: FLINK-34052 URL: https://issues.apache.org/jira/browse/FLINK-34052 Project: Flin

[jira] [Commented] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

2024-01-10 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805173#comment-17805173 ] Junrui Li commented on FLINK-34052: --- Hi [~Zhanghao Chen] , Could you have a look? > M

[jira] [Updated] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

2024-01-10 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-34052: -- Component/s: Examples > Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

[jira] [Commented] (FLINK-32006) AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry times out on Azure

2024-01-11 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805698#comment-17805698 ] Junrui Li commented on FLINK-32006: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2024-01-14 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806608#comment-17806608 ] Junrui Li commented on FLINK-27756: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Resolved] (FLINK-33712) FLIP-391: Deprecate RuntimeContext#getExecutionConfig

2024-01-15 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li resolved FLINK-33712. --- Fix Version/s: 1.19.0 Release Note: RuntimeContext#getExecutionConfig is now be deprecated in F

[jira] [Commented] (FLINK-34116) GlobalConfigurationTest.testInvalidStandardYamlFile fails

2024-01-16 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807337#comment-17807337 ] Junrui Li commented on FLINK-34116: --- [~mapohl] Thank you for the kind reminder, I will

[jira] [Commented] (FLINK-34116) GlobalConfigurationTest.testInvalidStandardYamlFile fails

2024-01-16 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807503#comment-17807503 ] Junrui Li commented on FLINK-34116: --- This bug arose due to discrepancies in {{ClassCas

[jira] [Commented] (FLINK-34114) Parse error while $internal.application.program-args contains '#' in Yarn/K8s Application Mode

2024-01-16 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807513#comment-17807513 ] Junrui Li commented on FLINK-34114: --- [~ChunJi] This issue will be addressed by [FLIP-

[jira] [Created] (FLINK-34126) Correct the description of jobmanager.scheduler

2024-01-16 Thread Junrui Li (Jira)
Junrui Li created FLINK-34126: - Summary: Correct the description of jobmanager.scheduler Key: FLINK-34126 URL: https://issues.apache.org/jira/browse/FLINK-34126 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-34126) Correct the description of jobmanager.scheduler

2024-01-16 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-34126: -- Description: Now the config option jobmanager.scheduler has description:  _Determines which scheduler

[jira] [Commented] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807701#comment-17807701 ] Junrui Li commented on FLINK-34132: --- [~prabhujoseph] The [limitation|https://nightlie

[jira] [Comment Edited] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807701#comment-17807701 ] Junrui Li edited comment on FLINK-34132 at 1/17/24 11:41 AM: -

[jira] [Commented] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807703#comment-17807703 ] Junrui Li commented on FLINK-34132: --- Since DataSet is deprecated, I'm unsure if it's s

[jira] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132 ] Junrui Li deleted comment on FLINK-34132: --- was (Author: JIRAUSER293716): Since DataSet is deprecated, I'm unsure if it's still meaningful to make such updates. > Batch WordCount job fails whe

[jira] [Commented] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

2024-01-17 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807709#comment-17807709 ] Junrui Li commented on FLINK-34132: --- After discuss with [~wanglijie] offline, I will p

[jira] [Commented] (FLINK-34164) [Benchmark] Compilation error since Jan. 16th

2024-01-18 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808486#comment-17808486 ] Junrui Li commented on FLINK-34164: --- Thanks [~Zakelly] for pointing out, I'll prepare

[jira] [Created] (FLINK-34205) Update flink-docker's Dockerfile and docker-entrypoint.sh to use BashJavaUtils for Flink configuration management

2024-01-22 Thread Junrui Li (Jira)
Junrui Li created FLINK-34205: - Summary: Update flink-docker's Dockerfile and docker-entrypoint.sh to use BashJavaUtils for Flink configuration management Key: FLINK-34205 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-34223) Introduce a migration tool to transfer legacy config file to new config file

2024-01-23 Thread Junrui Li (Jira)
Junrui Li created FLINK-34223: - Summary: Introduce a migration tool to transfer legacy config file to new config file Key: FLINK-34223 URL: https://issues.apache.org/jira/browse/FLINK-34223 Project: Flink

[jira] [Created] (FLINK-34232) Config file unexpectedly lacks support for env.java.home

2024-01-25 Thread Junrui Li (Jira)
Junrui Li created FLINK-34232: - Summary: Config file unexpectedly lacks support for env.java.home Key: FLINK-34232 URL: https://issues.apache.org/jira/browse/FLINK-34232 Project: Flink Issue Type

[jira] [Commented] (FLINK-21126) Reconsider FLINK_PROPERTIES

2024-01-25 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810859#comment-17810859 ] Junrui Li commented on FLINK-21126: --- After reviewing the considerations for deprecatin

[jira] [Updated] (FLINK-33577) Make "config.yaml" as the default Flink configuration file

2024-01-25 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33577: -- Summary: Make "config.yaml" as the default Flink configuration file (was: Make "conf.yaml" as the def

[jira] [Updated] (FLINK-33577) Make "config.yaml" as the default Flink configuration file

2024-01-25 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33577: -- Description: This update ensures that the flink-dist package in FLINK will include the new configurati

[jira] [Created] (FLINK-34247) Document FLIP-366: Support standard YAML for FLINK configuration

2024-01-26 Thread Junrui Li (Jira)
Junrui Li created FLINK-34247: - Summary: Document FLIP-366: Support standard YAML for FLINK configuration Key: FLINK-34247 URL: https://issues.apache.org/jira/browse/FLINK-34247 Project: Flink I

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

2024-01-26 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811331#comment-17811331 ] Junrui Li commented on FLINK-33297: --- [~lincoln.86xy] Not yet, sorry for the misleading

[jira] [Commented] (FLINK-34245) CassandraSinkTest.test_cassandra_sink fails under JDK17 and JDK21 due to InaccessibleObjectException

2024-01-27 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811562#comment-17811562 ] Junrui Li commented on FLINK-34245: --- [~Sergey Nuyanzin] Thanks for kindly reminder, it

[jira] [Created] (FLINK-34257) Update Flink YAML Parser to Support YAML 1.2 Specification

2024-01-28 Thread Junrui Li (Jira)
Junrui Li created FLINK-34257: - Summary: Update Flink YAML Parser to Support YAML 1.2 Specification Key: FLINK-34257 URL: https://issues.apache.org/jira/browse/FLINK-34257 Project: Flink Issue

[jira] [Updated] (FLINK-34257) Update Flink YAML Parser to Support YAML 1.2 Specification

2024-01-28 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-34257: -- Description: FLINK-33364 and FLINK-33577 added snakeyaml and pyyaml dependencies to support a standar

[jira] [Updated] (FLINK-34257) Update Flink YAML Parser to Support YAML 1.2 Specification

2024-01-29 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-34257: -- Description: FLINK-33364 and FLINK-33577 added snakeyaml and pyyaml dependencies to support a standar

[jira] [Updated] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2024-01-30 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33581: -- Release Note: The non-ConfigOption objects in the StreamExecutionEnvironment, CheckpointConfig, and E

[jira] [Commented] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2024-01-30 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812525#comment-17812525 ] Junrui Li commented on FLINK-33581: --- Thanks [~martijnvisser] for the kind reminder. I'

[jira] [Updated] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2024-01-30 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33581: -- Release Note: The non-ConfigOption objects in the StreamExecutionEnvironment, CheckpointConfig, and E

[jira] [Updated] (FLINK-34126) Correct the description of jobmanager.scheduler

2024-01-31 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-34126: -- Component/s: Documentation (was: Runtime / Configuration) > Correct the descripti

[jira] [Commented] (FLINK-34296) Release Testing Instructions: Verify FLINK-33581 Deprecate configuration getters/setters that return/set complex Java objects

2024-02-01 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813466#comment-17813466 ] Junrui Li commented on FLINK-34296: --- [~lincoln.86xy] This change doesn't need cross te

[jira] [Commented] (FLINK-34295) Release Testing Instructions: Verify FLINK-33712 Deprecate RuntimeContext#getExecutionConfig

2024-02-01 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813465#comment-17813465 ] Junrui Li commented on FLINK-34295: --- [~lincoln.86xy] This change doesn't need cross te

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

2024-02-04 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33297: -- Release Note: Starting with Flink-1.19, Flink has officially introduced full support for the standard

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

2024-02-04 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li closed FLINK-33297. - Resolution: Fixed > FLIP-366: Support standard YAML for FLINK configuration > --

[jira] [Commented] (FLINK-34294) Release Testing Instructions: Verify FLINK-33297 Support standard YAML for FLINK configuration

2024-02-05 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814569#comment-17814569 ] Junrui Li commented on FLINK-34294: --- [~lincoln.86xy] Yes, this feature does require cr

[jira] [Created] (FLINK-34377) Release Testing : Verify FLINK-33297 Support standard YAML for FLINK configuration

2024-02-05 Thread Junrui Li (Jira)
Junrui Li created FLINK-34377: - Summary: Release Testing : Verify FLINK-33297 Support standard YAML for FLINK configuration Key: FLINK-34377 URL: https://issues.apache.org/jira/browse/FLINK-34377 Project:

[jira] [Updated] (FLINK-34377) Release Testing : Verify FLINK-33297 Support standard YAML for FLINK configuration

2024-02-05 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-34377: -- Description: This issue aims to verify FLIP-366. Starting with version 1.19, Flink has officially int

[jira] [Updated] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-27 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33581: -- Description: Deprecate the non-ConfigOption objects in the StreamExecutionEnvironment, CheckpointConfi

[jira] [Created] (FLINK-33669) Update the documentation for RestartStrategy, Checkpoint Storage, and State Backend.

2023-11-27 Thread Junrui Li (Jira)
Junrui Li created FLINK-33669: - Summary: Update the documentation for RestartStrategy, Checkpoint Storage, and State Backend. Key: FLINK-33669 URL: https://issues.apache.org/jira/browse/FLINK-33669 Projec

[jira] [Created] (FLINK-33678) Remove configuration getters/setters that return/set complex Java objects

2023-11-28 Thread Junrui Li (Jira)
Junrui Li created FLINK-33678: - Summary: Remove configuration getters/setters that return/set complex Java objects Key: FLINK-33678 URL: https://issues.apache.org/jira/browse/FLINK-33678 Project: Flink

[jira] [Commented] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-30 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791609#comment-17791609 ] Junrui Li commented on FLINK-33581: --- Hey [~fanrui] , thank you for the reminder. Indee

[jira] [Created] (FLINK-33712) FLIP-391: Deprecate RuntimeContext#getExecutionConfig

2023-11-30 Thread Junrui Li (Jira)
Junrui Li created FLINK-33712: - Summary: FLIP-391: Deprecate RuntimeContext#getExecutionConfig Key: FLINK-33712 URL: https://issues.apache.org/jira/browse/FLINK-33712 Project: Flink Issue Type: T

[jira] [Created] (FLINK-33713) Deprecate RuntimeContext#getExecutionConfig

2023-11-30 Thread Junrui Li (Jira)
Junrui Li created FLINK-33713: - Summary: Deprecate RuntimeContext#getExecutionConfig Key: FLINK-33713 URL: https://issues.apache.org/jira/browse/FLINK-33713 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33714) Update documentation about the usage of RuntimeContext#getExecutionConfig

2023-11-30 Thread Junrui Li (Jira)
Junrui Li created FLINK-33714: - Summary: Update documentation about the usage of RuntimeContext#getExecutionConfig Key: FLINK-33714 URL: https://issues.apache.org/jira/browse/FLINK-33714 Project: Flink

[jira] [Created] (FLINK-33721) Extend BashJavaUtils to Support Reading and Writing Standard YAML Files

2023-12-01 Thread Junrui Li (Jira)
Junrui Li created FLINK-33721: - Summary: Extend BashJavaUtils to Support Reading and Writing Standard YAML Files Key: FLINK-33721 URL: https://issues.apache.org/jira/browse/FLINK-33721 Project: Flink

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

2023-12-03 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792505#comment-17792505 ] Junrui Li commented on FLINK-33502: --- Hello [~Wencong Liu], I've noticed an issue that

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

2023-12-03 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792679#comment-17792679 ] Junrui Li commented on FLINK-33502: --- [~Wencong Liu] Thank you for the clarification. I

[jira] [Created] (FLINK-33749) Remove deprecated getter method in Configuration.

2023-12-04 Thread Junrui Li (Jira)
Junrui Li created FLINK-33749: - Summary: Remove deprecated getter method in Configuration. Key: FLINK-33749 URL: https://issues.apache.org/jira/browse/FLINK-33749 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-33750) Remove deprecated config options.

2023-12-04 Thread Junrui Li (Jira)
Junrui Li created FLINK-33750: - Summary: Remove deprecated config options. Key: FLINK-33750 URL: https://issues.apache.org/jira/browse/FLINK-33750 Project: Flink Issue Type: Sub-task Co

[jira] [Commented] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2023-12-19 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798795#comment-17798795 ] Junrui Li commented on FLINK-27756: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-33980) Reorganize job configuration

2024-01-03 Thread Junrui Li (Jira)
Junrui Li created FLINK-33980: - Summary: Reorganize job configuration Key: FLINK-33980 URL: https://issues.apache.org/jira/browse/FLINK-33980 Project: Flink Issue Type: Technical Debt C

  1   2   3   >