[jira] [Created] (FLINK-35928) ForSt supports compiling with RocksDB

Hangxiang Yu created FLINK-35928: Summary: ForSt supports compiling with RocksDB Key: FLINK-35928 URL: https://issues.apache.org/jira/browse/FLINK-35928 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35927) Support closing ForSt meta file when using object storage

Hangxiang Yu created FLINK-35927: Summary: Support closing ForSt meta file when using object storage Key: FLINK-35927 URL: https://issues.apache.org/jira/browse/FLINK-35927 Project: Flink Iss

[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] [Resolved] (FLINK-35460) Check file size when position read for ForSt

[ https://issues.apache.org/jira/browse/FLINK-35460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-35460. -- Fix Version/s: 1.20.0 Resolution: Fixed Merged 9fbe9f30 into master. > Check file size

[jira] [Resolved] (FLINK-35434) Support pass exception in StateExecutor to runtime

[ https://issues.apache.org/jira/browse/FLINK-35434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-35434. -- Fix Version/s: 1.20.0 Resolution: Fixed Merged f926d2a5 and 2f7099e7 into master. > Su

[jira] [Created] (FLINK-35460) Check file size when position read for ForSt

Hangxiang Yu created FLINK-35460: Summary: Check file size when position read for ForSt Key: FLINK-35460 URL: https://issues.apache.org/jira/browse/FLINK-35460 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-35434) Support pass exception in StateExecutor to runtime

[ https://issues.apache.org/jira/browse/FLINK-35434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-35434: Assignee: Feifan Wang > Support pass exception in StateExecutor to runtime >

[jira] [Created] (FLINK-35389) Implement List Async State API for ForStStateBackend

Hangxiang Yu created FLINK-35389: Summary: Implement List Async State API for ForStStateBackend Key: FLINK-35389 URL: https://issues.apache.org/jira/browse/FLINK-35389 Project: Flink Issue Ty

[jira] [Updated] (FLINK-35049) Implement Map Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-35049: - Summary: Implement Map Async State API for ForStStateBackend (was: Implement List/Map Async Sta

[jira] [Resolved] (FLINK-35048) Implement all methods of AsyncKeyedStateBakend

[ https://issues.apache.org/jira/browse/FLINK-35048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-35048. -- Fix Version/s: 1.20.0 Resolution: Fixed merged 17d89054 into master. > Implement all m

[jira] [Resolved] (FLINK-35262) Bridge between AsyncKeyedStateBackend and AsyncExecutionController

[ https://issues.apache.org/jira/browse/FLINK-35262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-35262. -- Fix Version/s: 1.20.0 Resolution: Fixed merged 81fd465a into master. > Bridge between

[jira] [Created] (FLINK-35268) Support TTL for Async State API

Hangxiang Yu created FLINK-35268: Summary: Support TTL for Async State API Key: FLINK-35268 URL: https://issues.apache.org/jira/browse/FLINK-35268 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-35161) Implement StateExecutor for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-35161: Assignee: Jinzhong Li > Implement StateExecutor for ForStStateBackend > -

[jira] [Assigned] (FLINK-35048) Implement all methods of AsyncKeyedStateBakend

[ https://issues.apache.org/jira/browse/FLINK-35048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-35048: Assignee: Hangxiang Yu > Implement all methods of AsyncKeyedStateBakend > --

[jira] [Created] (FLINK-35262) Bridge between AsyncKeyedStateBackend and AsyncExecutionController

Hangxiang Yu created FLINK-35262: Summary: Bridge between AsyncKeyedStateBackend and AsyncExecutionController Key: FLINK-35262 URL: https://issues.apache.org/jira/browse/FLINK-35262 Project: Flink

[jira] [Updated] (FLINK-35049) Implement List/Map Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-35049: - Summary: Implement List/Map Async State API for ForStStateBackend (was: Implement Async State A

[jira] [Resolved] (FLINK-35162) Support grouping state get and put access

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

[jira] [Resolved] (FLINK-35125) Implement ValueState for ForStStateBackend

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

[jira] [Resolved] (FLINK-35047) Introduce ForStStateBackend to manage ForSt

[ https://issues.apache.org/jira/browse/FLINK-35047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-35047. -- Fix Version/s: 1.20.0 Resolution: Fixed merged 629c3571...19577b0d into master. > Intr

[jira] [Resolved] (FLINK-35175) HadoopDataInputStream can't compile with Hadoop 3.2.3

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

[jira] [Commented] (FLINK-35175) HadoopDataInputStream can't compile with Hadoop 3.2.3

[ https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839068#comment-17839068 ] Hangxiang Yu commented on FLINK-35175: -- [~rskraba] Thanks for reporting this! I th

[jira] [Resolved] (FLINK-35045) Introduce ForStFileSystem to support reading and writing with ByteBuffer

[ https://issues.apache.org/jira/browse/FLINK-35045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-35045. -- Fix Version/s: 1.20.0 Resolution: Fixed merged 369bbb8f...a312a3bd into master > Intro

[jira] [Assigned] (FLINK-35125) Implement ValueState for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-35125: Assignee: Jinzhong Li > Implement ValueState for ForStStateBackend >

[jira] [Resolved] (FLINK-34987) Introduce Internal State Interface for Async State API

[ https://issues.apache.org/jira/browse/FLINK-34987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34987. -- Fix Version/s: 1.20.0 Resolution: Fixed merged 7699a0d2...2c5078bc into master > Intro

[jira] [Resolved] (FLINK-35046) Introduce New KeyedStateBackend related Async interfaces

[ https://issues.apache.org/jira/browse/FLINK-35046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-35046. -- Fix Version/s: 1.20.0 Resolution: Fixed merged 691cc671 into master. > Introduce New K

[jira] [Assigned] (FLINK-35046) Introduce New KeyedStateBackend related Async interfaces

[ https://issues.apache.org/jira/browse/FLINK-35046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-35046: Assignee: Hangxiang Yu > Introduce New KeyedStateBackend related Async interfaces > -

[jira] [Resolved] (FLINK-35044) Introduce statebackend-forst module

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

[jira] [Resolved] (FLINK-35043) Release beta version of ForSt

[ https://issues.apache.org/jira/browse/FLINK-35043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-35043. -- Resolution: Fixed The beta version could be found in: https://mvnrepository.com/artifact/com.

[jira] [Updated] (FLINK-35044) Introduce statebackend-forst module

[ https://issues.apache.org/jira/browse/FLINK-35044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-35044: - Description: A simple work to introduce a new module for ForStStateBackend, then several subseq

[jira] [Updated] (FLINK-35047) Introduce ForStStateBackend to manage ForSt

[ https://issues.apache.org/jira/browse/FLINK-35047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-35047: - Description: A ForStStateBackend is introduced to leverage ForSt as state store for Flink. This

[jira] [Updated] (FLINK-35045) Introduce ForStFileSystem to support reading and writing with ByteBuffer

[ https://issues.apache.org/jira/browse/FLINK-35045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-35045: - Description: As described in FLIP-427, ForStFileSystem is introduced to support reading and writ

[jira] [Updated] (FLINK-35045) Introduce ForStFileSystem to support reading and writing with ByteBuffer

[ https://issues.apache.org/jira/browse/FLINK-35045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-35045: - Description: As described in FLIP-427, ForStFileSystem is introduced to  > Introduce ForStFileSy

[jira] [Updated] (FLINK-35044) Introduce statebackend-forst module

[ https://issues.apache.org/jira/browse/FLINK-35044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-35044: - Description: A simple work to introduce a new module for ForStStateBackend, then several subsequ

[jira] [Updated] (FLINK-35044) Introduce statebackend-forst module

[ https://issues.apache.org/jira/browse/FLINK-35044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-35044: - Description: A simple work to introduce a new module, then  > Introduce statebackend-forst modul

[jira] [Created] (FLINK-35049) Implement Async State API for ForStStateBackend

Hangxiang Yu created FLINK-35049: Summary: Implement Async State API for ForStStateBackend Key: FLINK-35049 URL: https://issues.apache.org/jira/browse/FLINK-35049 Project: Flink Issue Type: S

[jira] [Created] (FLINK-35048) Implement all methods of AsyncKeyedStateBakend

Hangxiang Yu created FLINK-35048: Summary: Implement all methods of AsyncKeyedStateBakend Key: FLINK-35048 URL: https://issues.apache.org/jira/browse/FLINK-35048 Project: Flink Issue Type: S

[jira] [Updated] (FLINK-35047) Introduce ForStStateBackend to manage ForSt

[ https://issues.apache.org/jira/browse/FLINK-35047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-35047: - Summary: Introduce ForStStateBackend to manage ForSt (was: Introduce ForStStateBackend) > Intr

[jira] [Created] (FLINK-35047) Introduce ForStStateBackend

Hangxiang Yu created FLINK-35047: Summary: Introduce ForStStateBackend Key: FLINK-35047 URL: https://issues.apache.org/jira/browse/FLINK-35047 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-35046) Introduce New KeyedStateBackend related Async interfaces

Hangxiang Yu created FLINK-35046: Summary: Introduce New KeyedStateBackend related Async interfaces Key: FLINK-35046 URL: https://issues.apache.org/jira/browse/FLINK-35046 Project: Flink Issu

[jira] [Created] (FLINK-35045) Introduce ForStFileSystem to support reading and writing with ByteBuffer

Hangxiang Yu created FLINK-35045: Summary: Introduce ForStFileSystem to support reading and writing with ByteBuffer Key: FLINK-35045 URL: https://issues.apache.org/jira/browse/FLINK-35045 Project: Fli

[jira] [Updated] (FLINK-35044) Introduce statebackend-forst module

[ https://issues.apache.org/jira/browse/FLINK-35044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-35044: - Component/s: Runtime / State Backends > Introduce statebackend-forst module > --

[jira] [Created] (FLINK-35044) Introduce statebackend-forst module

Hangxiang Yu created FLINK-35044: Summary: Introduce statebackend-forst module Key: FLINK-35044 URL: https://issues.apache.org/jira/browse/FLINK-35044 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35043) Release beta version of ForSt

Hangxiang Yu created FLINK-35043: Summary: Release beta version of ForSt Key: FLINK-35043 URL: https://issues.apache.org/jira/browse/FLINK-35043 Project: Flink Issue Type: Sub-task

[jira] [Resolved] (FLINK-32079) Read/write checkpoint metadata of merged files

[ https://issues.apache.org/jira/browse/FLINK-32079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32079. -- Resolution: Fixed merged ea4e4981 and 0b7f0fde into master > Read/write checkpoint metadata o

[jira] [Updated] (FLINK-34979) Implement State Future and related utilities

[ https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34979: - Component/s: Runtime / State Backends > Implement State Future and related utilities > -

[jira] [Resolved] (FLINK-34979) Implement State Future and related utilities

[ https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34979. -- Resolution: Fixed merged 739bd337 into master > Implement State Future and related utilities

[jira] [Updated] (FLINK-34979) Implement State Future and related utilities

[ https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34979: - Fix Version/s: 1.20.0 > Implement State Future and related utilities > -

[jira] [Updated] (FLINK-34987) Introduce Internal State Interface for Async State API

[ https://issues.apache.org/jira/browse/FLINK-34987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34987: - Component/s: Runtime / State Backends > Introduce Internal State Interface for Async State API >

[jira] [Created] (FLINK-34987) Introduce Internal State Interface for Async API

Hangxiang Yu created FLINK-34987: Summary: Introduce Internal State Interface for Async API Key: FLINK-34987 URL: https://issues.apache.org/jira/browse/FLINK-34987 Project: Flink Issue Type:

[jira] [Updated] (FLINK-34987) Introduce Internal State Interface for Async State API

[ https://issues.apache.org/jira/browse/FLINK-34987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34987: - Summary: Introduce Internal State Interface for Async State API (was: Introduce Internal State

[jira] [Resolved] (FLINK-34978) Introduce Asynchronous State APIs

[ https://issues.apache.org/jira/browse/FLINK-34978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34978. -- Resolution: Fixed merged f38d8ca4 into master. > Introduce Asynchronous State APIs >

[jira] [Commented] (FLINK-34975) FLIP-427: ForSt - Disaggregated State Store

[ https://issues.apache.org/jira/browse/FLINK-34975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832991#comment-17832991 ] Hangxiang Yu commented on FLINK-34975: -- Hi, [~kkrugler]. Thanks a lot for sharing

[jira] [Updated] (FLINK-34975) FLIP-427: ForSt - Disaggregated State Store

[ https://issues.apache.org/jira/browse/FLINK-34975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34975: - Summary: FLIP-427: ForSt - Disaggregated State Store (was: FLIP-427: ForSt - Disaggregated stat

[jira] [Updated] (FLINK-34975) FLIP-427: ForSt - Disaggregated state Store

[ https://issues.apache.org/jira/browse/FLINK-34975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34975: - Fix Version/s: 2.0.0 > FLIP-427: ForSt - Disaggregated state Store > ---

[jira] [Created] (FLINK-34975) FLIP-427: ForSt - Disaggregated state Store

Hangxiang Yu created FLINK-34975: Summary: FLIP-427: ForSt - Disaggregated state Store Key: FLINK-34975 URL: https://issues.apache.org/jira/browse/FLINK-34975 Project: Flink Issue Type: New F

[jira] [Updated] (FLINK-34936) Register shared state files to FileMergingSnapshotManager

[ https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34936: - Component/s: Runtime / Checkpointing > Register shared state files to FileMergingSnapshotManager

[jira] [Comment Edited] (FLINK-33707) Verify the snapshot migration on Java17

[ https://issues.apache.org/jira/browse/FLINK-33707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831141#comment-17831141 ] Hangxiang Yu edited comment on FLINK-33707 at 3/27/24 2:46 AM: ---

[jira] [Commented] (FLINK-33707) Verify the snapshot migration on Java17

[ https://issues.apache.org/jira/browse/FLINK-33707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831141#comment-17831141 ] Hangxiang Yu commented on FLINK-33707: -- Hi, Scala API has been marked as deprecated

[jira] [Resolved] (FLINK-34516) Move CheckpointingMode to flink-core

[ https://issues.apache.org/jira/browse/FLINK-34516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34516. -- Fix Version/s: 1.20.0 Resolution: Fixed merged 8fac8046...77945916 into master > Move

[jira] [Resolved] (FLINK-34647) Path normalization is allocation intensive

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

[jira] [Resolved] (FLINK-32074) Support file merging across checkpoints

[ https://issues.apache.org/jira/browse/FLINK-32074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32074. -- Resolution: Fixed Merged 841f23c7 into master > Support file merging across checkpoints > ---

[jira] [Resolved] (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:all-tabpanel ] Hangxiang Yu resolved FLINK-34334. -- Resolution: Fixed Merged  [{{0921968}}|https://github.com/apache/flink/commit/0921968bb7d38bfa

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

  1   2   3   4   5   >