[jira] [Resolved] (FLINK-34482) Rename options for checkpointing

[ https://issues.apache.org/jira/browse/FLINK-34482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34482. -- Resolution: Fixed Merged 38070a1b and 26e61931 into master. > Rename options for checkpointin

[jira] [Created] (FLINK-34479) Fix missed changelog configs in the documentation

Hangxiang Yu created FLINK-34479: Summary: Fix missed changelog configs in the documentation Key: FLINK-34479 URL: https://issues.apache.org/jira/browse/FLINK-34479 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-34479) Fix missed changelog configs in the documentation

[ https://issues.apache.org/jira/browse/FLINK-34479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34479. -- Fix Version/s: 1.19.0 1.20.0 Resolution: Fixed Merged  [{{6f7e841}}|

[jira] [Resolved] (FLINK-34457) Rename options for latency tracking

[ https://issues.apache.org/jira/browse/FLINK-34457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34457. -- Resolution: Fixed merged 6be297d1 into master. > Rename options for latency tracking > --

[jira] [Resolved] (FLINK-29802) ChangelogStateBackend supports native savepoint

[ https://issues.apache.org/jira/browse/FLINK-29802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-29802. -- Fix Version/s: 1.20.0 (was: 1.19.0) Resolution: Fixed merged b62

[jira] [Resolved] (FLINK-34458) Rename options for Generalized incremental checkpoints (changelog)

[ https://issues.apache.org/jira/browse/FLINK-34458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34458. -- Resolution: Fixed merged e7e973e2 into master. > Rename options for Generalized incremental c

[jira] [Created] (FLINK-34512) Thrown root cause for  HandlerRequestException

Hangxiang Yu created FLINK-34512: Summary: Thrown root cause for  HandlerRequestException Key: FLINK-34512 URL: https://issues.apache.org/jira/browse/FLINK-34512 Project: Flink Issue Type: Im

[jira] [Updated] (FLINK-30613) Improve resolving schema compatibility -- Milestone one

[ https://issues.apache.org/jira/browse/FLINK-30613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-30613: - Release Note: In Flink 1.19, the old method of resolving schema compatibility has been deprecat

[jira] [Resolved] (FLINK-34454) Introduce StateRecoveryOptions in flink-core

[ https://issues.apache.org/jira/browse/FLINK-34454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34454. -- Resolution: Fixed merged 63dc5598...b9069227 into master > Introduce StateRecoveryOptions in

[jira] [Closed] (FLINK-34512) Thrown root cause for  HandlerRequestException

[ https://issues.apache.org/jira/browse/FLINK-34512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-34512. Resolution: Won't Fix > Thrown root cause for  HandlerRequestException > -

[jira] [Resolved] (FLINK-32075) Delete merged files on checkpoint abort or subsumption

[ https://issues.apache.org/jira/browse/FLINK-32075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32075. -- Fix Version/s: 1.20.0 (was: 1.19.0) Resolution: Fixed merged cd9

[jira] [Resolved] (FLINK-34352) Improve the documentation of allowNonRestoredState

[ https://issues.apache.org/jira/browse/FLINK-34352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34352. -- Fix Version/s: 1.20.0 Resolution: Fixed merged e168cd4d into master. > Improve the doc

[jira] [Commented] (FLINK-34558) Add RocksDB key/value size metrics

[ https://issues.apache.org/jira/browse/FLINK-34558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824593#comment-17824593 ] Hangxiang Yu commented on FLINK-34558: -- I think this mertic maybe useful, but since

[jira] [Commented] (FLINK-34519) Refine checkpoint scheduling and canceling logic

[ https://issues.apache.org/jira/browse/FLINK-34519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824599#comment-17824599 ] Hangxiang Yu commented on FLINK-34519: -- Thanks for reporting this. {quote}stopCheck

[jira] [Commented] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825123#comment-17825123 ] Hangxiang Yu commented on FLINK-29114: -- master: https://dev.azure.com/apache-flink

[jira] [Closed] (FLINK-34632) Log checkpoint Id when logging checkpoint processing delay

[ https://issues.apache.org/jira/browse/FLINK-34632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-34632. Fix Version/s: 1.20.0 Assignee: Mingliang Liu Resolution: Fixed merged 22309fdc in

[jira] [Updated] (FLINK-34652) Use CheckpointStreamFactory for StateChangeFsUploader

[ https://issues.apache.org/jira/browse/FLINK-34652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34652: - Description: As discussed before, we may consider supporting CheckpointStreamFactory for StateC

[jira] [Created] (FLINK-34652) Use CheckpointStreamFactory for StateChangeFsUploader

Hangxiang Yu created FLINK-34652: Summary: Use CheckpointStreamFactory for StateChangeFsUploader Key: FLINK-34652 URL: https://issues.apache.org/jira/browse/FLINK-34652 Project: Flink Issue T

[jira] [Commented] (FLINK-32085) Implement and migrate batch uploading in changelog files into the file merging framework

[ https://issues.apache.org/jira/browse/FLINK-32085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825532#comment-17825532 ] Hangxiang Yu commented on FLINK-32085: -- Maybe we could discuss about FLINK-34652 fi

[jira] [Created] (FLINK-34660) AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError

Hangxiang Yu created FLINK-34660: Summary: AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError Key: FLINK-34660 URL: https://issues.apache.org/jira/browse/FLINK-34660 Project: Flink

[jira] [Resolved] (FLINK-34660) AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError

[ https://issues.apache.org/jira/browse/FLINK-34660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34660. -- Fix Version/s: 1.20.0 Assignee: Hangxiang Yu Resolution: Fixed merged aa71589

[jira] [Resolved] (FLINK-32076) Add file pool for concurrent file reusing

[ https://issues.apache.org/jira/browse/FLINK-32076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32076. -- Assignee: Hangxiang Yu (was: Hangxiang Yu) Resolution: Fixed merged 583722e7 and 3b9623

[jira] [Resolved] (FLINK-18255) Add API annotations to RocksDB user-facing classes

[ https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-18255. -- Resolution: Fixed merged 8fba491c into master. > Add API annotations to RocksDB user-facing c

[jira] [Commented] (FLINK-34660) AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError

[ https://issues.apache.org/jira/browse/FLINK-34660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827439#comment-17827439 ] Hangxiang Yu commented on FLINK-34660: -- I found it's because AutoRescalingITCase#te

[jira] [Updated] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-30863: - Fix Version/s: 1.19.0 > Register local recovery files of changelog before notifyCheckpointComple

[jira] [Commented] (FLINK-33122) [Benchmark] Null checkpoint directory in rescaling benchmarks

[ https://issues.apache.org/jira/browse/FLINK-33122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1663#comment-1663 ] Hangxiang Yu commented on FLINK-33122: -- merged into master via ddaafee5 > [Benchma

[jira] [Updated] (FLINK-33122) [Benchmark] Null checkpoint directory in rescaling benchmarks

[ https://issues.apache.org/jira/browse/FLINK-33122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-33122: - Fix Version/s: 1.19.0 > [Benchmark] Null checkpoint directory in rescaling benchmarks >

[jira] [Resolved] (FLINK-33122) [Benchmark] Null checkpoint directory in rescaling benchmarks

[ https://issues.apache.org/jira/browse/FLINK-33122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-33122. -- Resolution: Fixed > [Benchmark] Null checkpoint directory in rescaling benchmarks > --

[jira] [Assigned] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-27681: Assignee: Yue Ma > Improve the availability of Flink when the RocksDB file is corrupted.

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782014#comment-17782014 ] Hangxiang Yu commented on FLINK-27681: -- [~mayuehappy] Thanks for the reminder. I th

[jira] [Assigned] (FLINK-5865) Throw original exception in states

[ https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-5865: --- Assignee: Zakelly Lan > Throw original exception in states > ---

[jira] [Resolved] (FLINK-5865) Throw original exception in states

[ https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-5865. - Resolution: Fixed merged cee2611e into master. About the [FLIP-368. |https://cwiki.apache.org/c

[jira] [Updated] (FLINK-5865) Throw original exception in states

[ https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-5865: Fix Version/s: 1.19.0 > Throw original exception in states > -- > >

[jira] [Assigned] (FLINK-33437) Flink 1.17 sink commited legacy Committable state, but it was not removed from state backend

[ https://issues.apache.org/jira/browse/FLINK-33437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-33437: Assignee: Yuchi Duan > Flink 1.17 sink commited legacy Committable state, but it was not

[jira] [Commented] (FLINK-33437) Flink 1.17 sink commited legacy Committable state, but it was not removed from state backend

[ https://issues.apache.org/jira/browse/FLINK-33437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783134#comment-17783134 ] Hangxiang Yu commented on FLINK-33437: -- [~dyccode] Thanks for reporting this. Alre

[jira] [Updated] (FLINK-33060) Fix the javadoc of ListState.update/addAll about not allowing null value

[ https://issues.apache.org/jira/browse/FLINK-33060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-33060: - Component/s: Runtime / State Backends > Fix the javadoc of ListState.update/addAll about not all

[jira] [Resolved] (FLINK-33060) Fix the javadoc of ListState.update/addAll about not allowing null value

[ https://issues.apache.org/jira/browse/FLINK-33060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-33060. -- Resolution: Fixed merged e0240c78 into master. > Fix the javadoc of ListState.update/addAll a

[jira] [Updated] (FLINK-33060) Fix the javadoc of ListState.update/addAll about not allowing null value

[ https://issues.apache.org/jira/browse/FLINK-33060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-33060: - Fix Version/s: 1.19.0 > Fix the javadoc of ListState.update/addAll about not allowing null value

[jira] [Resolved] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-26585. -- Fix Version/s: 1.19.0 Resolution: Fixed merged eb4ae5d4 into master > State Processor

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786602#comment-17786602 ] Hangxiang Yu commented on FLINK-18473: -- Thanks [~fanrui] for pinging me here. [~yi

[jira] [Resolved] (FLINK-30235) Comprehensive benchmarks on changelog checkpointing

[ https://issues.apache.org/jira/browse/FLINK-30235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-30235. -- Fix Version/s: 1.17.0 Assignee: Rui Xia Resolution: Fixed Resolved this in 1.1

[jira] [Resolved] (FLINK-34030) Avoid using negative value for periodic-materialize.interval

[ https://issues.apache.org/jira/browse/FLINK-34030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34030. -- Fix Version/s: 1.19.0 Resolution: Fixed merged a6c1f308 and 96d62017 into master > Avo

[jira] [Updated] (FLINK-34030) Avoid using negative value for periodic-materialize.interval

[ https://issues.apache.org/jira/browse/FLINK-34030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34030: - Affects Version/s: 1.19.0 > Avoid using negative value for periodic-materialize.interval > -

[jira] [Commented] (FLINK-33932) Support retry mechanism for rocksdb uploader

[ https://issues.apache.org/jira/browse/FLINK-33932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804951#comment-17804951 ] Hangxiang Yu commented on FLINK-33932: -- Thanks for pinging me here. Retry machanis

[jira] [Commented] (FLINK-33946) RocksDb sets setAvoidFlushDuringShutdown to true to speed up Task Cancel

[ https://issues.apache.org/jira/browse/FLINK-33946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805137#comment-17805137 ] Hangxiang Yu commented on FLINK-33946: -- [~mayuehappy] Thanks for reporting this. It

[jira] [Commented] (FLINK-33819) Support setting CompressType in RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805154#comment-17805154 ] Hangxiang Yu commented on FLINK-33819: -- {quote}It is obvious that closing Compressi

[jira] [Commented] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties

[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805160#comment-17805160 ] Hangxiang Yu commented on FLINK-34015: -- [~zhourenxiang] Thanks for reporting this.

[jira] [Created] (FLINK-34051) Fix equals/hashCode/toString for SavepointRestoreSettings

Hangxiang Yu created FLINK-34051: Summary: Fix equals/hashCode/toString for SavepointRestoreSettings Key: FLINK-34051 URL: https://issues.apache.org/jira/browse/FLINK-34051 Project: Flink Iss

[jira] [Updated] (FLINK-30088) Excessive state updates for TtlMapState and TtlListState

[ https://issues.apache.org/jira/browse/FLINK-30088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-30088: - Component/s: Runtime / State Backends > Excessive state updates for TtlMapState and TtlListState

[jira] [Assigned] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties

[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-34015: Assignee: Renxiang Zhou (was: Hangxiang Yu) > Setting `execution.savepoint.ignore-unclai

[jira] [Assigned] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties

[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-34015: Assignee: Hangxiang Yu > Setting `execution.savepoint.ignore-unclaimed-state` does not ta

[jira] [Commented] (FLINK-34015) Setting `execution.savepoint.ignore-unclaimed-state` does not take effect when passing this parameter by dynamic properties

[ https://issues.apache.org/jira/browse/FLINK-34015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805359#comment-17805359 ] Hangxiang Yu commented on FLINK-34015: -- [~zhourenxiang] Fine, it's vaild. I have a

[jira] [Assigned] (FLINK-33946) RocksDb sets setAvoidFlushDuringShutdown to true to speed up Task Cancel

[ https://issues.apache.org/jira/browse/FLINK-33946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-33946: Assignee: Hangxiang Yu > RocksDb sets setAvoidFlushDuringShutdown to true to speed up Tas

[jira] [Assigned] (FLINK-33946) RocksDb sets setAvoidFlushDuringShutdown to true to speed up Task Cancel

[ https://issues.apache.org/jira/browse/FLINK-33946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-33946: Assignee: Yue Ma (was: Hangxiang Yu) > RocksDb sets setAvoidFlushDuringShutdown to true

[jira] [Assigned] (FLINK-33819) Support setting CompressType in RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-33819: Assignee: Yue Ma > Support setting CompressType in RocksDBStateBackend >

[jira] [Resolved] (FLINK-33881) [TtlListState]Avoid copy and update value in TtlListState#getUnexpiredOrNull

[ https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-33881. -- Resolution: Fixed Thanks [~lijinzhong] for the great work! merged 907d0f32 into master > [Tt

[jira] [Assigned] (FLINK-33932) Support Retry Mechanism in RocksDBStateDataTransfer

[ https://issues.apache.org/jira/browse/FLINK-33932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-33932: Assignee: xiangyu feng > Support Retry Mechanism in RocksDBStateDataTransfer > --

[jira] [Commented] (FLINK-33932) Support Retry Mechanism in RocksDBStateDataTransfer

[ https://issues.apache.org/jira/browse/FLINK-33932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805467#comment-17805467 ] Hangxiang Yu commented on FLINK-33932: -- Sure, already assigned to you. Please take

[jira] [Resolved] (FLINK-34051) Fix equals/hashCode/toString for SavepointRestoreSettings

[ https://issues.apache.org/jira/browse/FLINK-34051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34051. -- Fix Version/s: 1.19.0 Resolution: Fixed merged 7745ef83 and ecb68704 into master > Fix

[jira] [Resolved] (FLINK-33946) RocksDb sets setAvoidFlushDuringShutdown to true to speed up Task Cancel

[ https://issues.apache.org/jira/browse/FLINK-33946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-33946. -- Resolution: Fixed merged aa0c1b5e into master > RocksDb sets setAvoidFlushDuringShutdown to t

[jira] [Commented] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

[ https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805915#comment-17805915 ] Hangxiang Yu commented on FLINK-34050: -- Thanks [~lijinzhong] and [~mayuehappy] prov

[jira] [Commented] (FLINK-34009) Apache flink: Checkpoint restoration issue on Application Mode of deployment

[ https://issues.apache.org/jira/browse/FLINK-34009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805937#comment-17805937 ] Hangxiang Yu commented on FLINK-34009: -- [~vrang...@in.ibm.com] Hi, You could reorg

[jira] [Resolved] (FLINK-30613) Improve resolving schema compatibility -- Milestone one

[ https://issues.apache.org/jira/browse/FLINK-30613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-30613. -- Resolution: Fixed merged 13921a08...0e5de813 into master > Improve resolving schema compatibi

[jira] [Resolved] (FLINK-33057) Add options to disable creating job-id subdirectories under the checkpoint directory

[ https://issues.apache.org/jira/browse/FLINK-33057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-33057. -- Fix Version/s: 1.19.0 Resolution: Fixed merged 73b036c3 into master > Add options to d

[jira] [Commented] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

[ https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806659#comment-17806659 ] Hangxiang Yu commented on FLINK-34050: -- [~lijinzhong] Yeah, I think this benchmark

[jira] [Assigned] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

[ https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-34050: Assignee: Jinzhong Li > Rocksdb state has space amplification after rescaling with Delete

[jira] [Commented] (FLINK-34078) Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

[ https://issues.apache.org/jira/browse/FLINK-34078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806660#comment-17806660 ] Hangxiang Yu commented on FLINK-34078: -- Thanks for reporting this. It makes sense

[jira] [Assigned] (FLINK-34078) Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

[ https://issues.apache.org/jira/browse/FLINK-34078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-34078: Assignee: Jinzhong Li > Move InternalKeyContext classes from o.a.f.runtime.state.heap to

[jira] [Resolved] (FLINK-34078) Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

[ https://issues.apache.org/jira/browse/FLINK-34078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34078. -- Fix Version/s: 1.19.0 Resolution: Fixed merged 6bdb4f75 into master > Move InternalKey

[jira] [Assigned] (FLINK-29802) ChangelogStateBackend supports native savepoint

[ https://issues.apache.org/jira/browse/FLINK-29802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-29802: Assignee: Hangxiang Yu > ChangelogStateBackend supports native savepoint > --

[jira] [Resolved] (FLINK-33679) RestoreMode uses NO_CLAIM as default instead of LEGACY

[ https://issues.apache.org/jira/browse/FLINK-33679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-33679. -- Fix Version/s: 1.19.0 Assignee: Zakelly Lan Resolution: Fixed merged fb7324b0

[jira] [Created] (FLINK-34119) Improve description about changelog in document

Hangxiang Yu created FLINK-34119: Summary: Improve description about changelog in document Key: FLINK-34119 URL: https://issues.apache.org/jira/browse/FLINK-34119 Project: Flink Issue Type: I

[jira] [Updated] (FLINK-34119) Improve description about changelog in document

[ https://issues.apache.org/jira/browse/FLINK-34119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34119: - Description: Since we have resolved some issues and marked as prodution-ready in [release note,

[jira] [Updated] (FLINK-34119) Improve description about changelog in document

[ https://issues.apache.org/jira/browse/FLINK-34119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34119: - Description: Since we have resolved some issues and marked as prodution-ready in [release note|

[jira] [Commented] (FLINK-30656) Provide more logs for schema compatibility check

[ https://issues.apache.org/jira/browse/FLINK-30656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807968#comment-17807968 ] Hangxiang Yu commented on FLINK-30656: -- We should support to remain some messages f

[jira] [Resolved] (FLINK-34119) Improve description about changelog in document

[ https://issues.apache.org/jira/browse/FLINK-34119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34119. -- Fix Version/s: 1.19.0 Resolution: Fixed merged 2ec8f81 into master > Improve descripti

[jira] [Comment Edited] (FLINK-30656) Provide more logs for schema compatibility check

[ https://issues.apache.org/jira/browse/FLINK-30656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807968#comment-17807968 ] Hangxiang Yu edited comment on FLINK-30656 at 1/18/24 3:57 AM: ---

[jira] [Comment Edited] (FLINK-30656) Provide more logs for schema compatibility check

[ https://issues.apache.org/jira/browse/FLINK-30656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807968#comment-17807968 ] Hangxiang Yu edited comment on FLINK-30656 at 1/19/24 1:37 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-34164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34164. -- Resolution: Fixed merged fc87459 into master > [Benchmark] Compilation error since Jan. 16th

[jira] [Resolved] (FLINK-33437) Flink 1.17 sink commited legacy Committable state, but it was not removed from state backend

[ https://issues.apache.org/jira/browse/FLINK-33437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-33437. -- Fix Version/s: 1.19.0 Resolution: Fixed merged efbd8c40 into master > Flink 1.17 sink

[jira] [Assigned] (FLINK-34210) DefaultExecutionGraphBuilder#isCheckpointingEnabled may return Wrong Value when checkpoint disabled

[ https://issues.apache.org/jira/browse/FLINK-34210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-34210: Assignee: Yue Ma > DefaultExecutionGraphBuilder#isCheckpointingEnabled may return Wrong V

[jira] [Resolved] (FLINK-34190) Deprecate RestoreMode#LEGACY

[ https://issues.apache.org/jira/browse/FLINK-34190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34190. -- Resolution: Fixed merged f7a2819f...bed79d33 into master > Deprecate RestoreMode#LEGACY > ---

[jira] [Updated] (FLINK-34190) Deprecate RestoreMode#LEGACY

[ https://issues.apache.org/jira/browse/FLINK-34190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34190: - Component/s: Runtime / Checkpointing > Deprecate RestoreMode#LEGACY > --

[jira] [Commented] (FLINK-33819) Support setting CompressType in RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810682#comment-17810682 ] Hangxiang Yu commented on FLINK-33819: -- merged 4f7725aa into master which is not bl

[jira] [Created] (FLINK-34352) Improve the documentation of allowNonRestoredState

Hangxiang Yu created FLINK-34352: Summary: Improve the documentation of allowNonRestoredState Key: FLINK-34352 URL: https://issues.apache.org/jira/browse/FLINK-34352 Project: Flink Issue Type

[jira] [Closed] (FLINK-34292) Release Testing Instructions: Verify FLINK-30613 Improve resolving schema compatibility

[ https://issues.apache.org/jira/browse/FLINK-34292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-34292. Resolution: Fixed Closed Since it doesn't beak the change of public API. This introduces a new de

[jira] [Commented] (FLINK-34334) Add sub-task level RocksDB file count metric

[ https://issues.apache.org/jira/browse/FLINK-34334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814655#comment-17814655 ] Hangxiang Yu commented on FLINK-34334: -- I think we could add such a metric. But I'

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789903#comment-17789903 ] Hangxiang Yu commented on FLINK-27681: -- [~pnowojski] [~fanrui]  Thanks for joining

[jira] [Comment Edited] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789903#comment-17789903 ] Hangxiang Yu edited comment on FLINK-27681 at 11/27/23 4:33 AM: --

[jira] [Commented] (FLINK-33679) RestoreMode uses NO_CLAIM as default instead of LEGACY

[ https://issues.apache.org/jira/browse/FLINK-33679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791403#comment-17791403 ] Hangxiang Yu commented on FLINK-33679: -- Hi, NO_CLAIM should be more production frie

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791409#comment-17791409 ] Hangxiang Yu commented on FLINK-27681: -- {quote}Fail job directly is fine for me, bu

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17793189#comment-17793189 ] Hangxiang Yu commented on FLINK-27681: -- Sorry for the late reply. {quote}However, 

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794190#comment-17794190 ] Hangxiang Yu commented on FLINK-27681: -- {quote}Yes, I think we don't need any extra

[jira] [Commented] (FLINK-33798) Automatically clean up rocksdb logs when the task failover.

[ https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17795576#comment-17795576 ] Hangxiang Yu commented on FLINK-33798: -- Thanks [~fanrui] pinging me here. I think

[jira] [Assigned] (FLINK-26586) FileSystem uses unbuffered read I/O

[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-26586: Assignee: Matthias Schwalbe > FileSystem uses unbuffered read I/O > -

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17795577#comment-17795577 ] Hangxiang Yu commented on FLINK-26586: -- [~Matthias Schwalbe] Sure. Just feel free t

[jira] [Commented] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17795627#comment-17795627 ] Hangxiang Yu commented on FLINK-26585: -- [~jingge] I saw 1.18.1 is releasing. Could

[jira] [Resolved] (FLINK-33723) Disallow triggering incremental checkpoint explicitly from REST API

[ https://issues.apache.org/jira/browse/FLINK-33723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-33723. -- Resolution: Fixed merged 07d159bf into master > Disallow triggering incremental checkpoint ex

[jira] [Commented] (FLINK-33819) Support setting CompressType in RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796992#comment-17796992 ] Hangxiang Yu commented on FLINK-33819: -- Linked FLINK-20684 as it has been discussed

[jira] [Resolved] (FLINK-20772) RocksDBValueState with TTL occurs NullPointerException when calling update(null) method

[ https://issues.apache.org/jira/browse/FLINK-20772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-20772. -- Fix Version/s: 1.19.0 Resolution: Fixed merged ac1ed6b6 and 9aa7a3cd into master > Roc

  1   2   3   4   5   >