[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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [Created] (FLINK-34032) Cleanup local=recovery dir when switching local-recovery from enabled to disabled

Hangxiang Yu created FLINK-34032: Summary: Cleanup local=recovery dir when switching local-recovery from enabled to disabled Key: FLINK-34032 URL: https://issues.apache.org/jira/browse/FLINK-34032 Pro

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

Hangxiang Yu created FLINK-34030: Summary: Avoid using negative value for periodic-materialize.interval Key: FLINK-34030 URL: https://issues.apache.org/jira/browse/FLINK-34030 Project: Flink

[jira] [Created] (FLINK-33055) Correct the error value about 'state.backend.type' in the document

Hangxiang Yu created FLINK-33055: Summary: Correct the error value about 'state.backend.type' in the document Key: FLINK-33055 URL: https://issues.apache.org/jira/browse/FLINK-33055 Project: Flink

[jira] [Created] (FLINK-32601) Unstable RemoteChannelThroughputBenchmark_remoteRebalance_jmhTest

Hangxiang Yu created FLINK-32601: Summary: Unstable RemoteChannelThroughputBenchmark_remoteRebalance_jmhTest Key: FLINK-32601 URL: https://issues.apache.org/jira/browse/FLINK-32601 Project: Flink

[jira] [Created] (FLINK-32364) Add Rescaling benchmark for ChangelogStateBackend

Hangxiang Yu created FLINK-32364: Summary: Add Rescaling benchmark for ChangelogStateBackend Key: FLINK-32364 URL: https://issues.apache.org/jira/browse/FLINK-32364 Project: Flink Issue Type:

[jira] [Created] (FLINK-31875) OSS throwns NoClassDefFoundError due to old hadoop-common version

Hangxiang Yu created FLINK-31875: Summary: OSS throwns NoClassDefFoundError due to old hadoop-common version Key: FLINK-31875 URL: https://issues.apache.org/jira/browse/FLINK-31875 Project: Flink

[jira] [Created] (FLINK-31366) Exception is thrown when s3a and s3p are used together

Hangxiang Yu created FLINK-31366: Summary: Exception is thrown when s3a and s3p are used together Key: FLINK-31366 URL: https://issues.apache.org/jira/browse/FLINK-31366 Project: Flink Issue

[jira] [Created] (FLINK-30854) Expose periodic compaction to RocksdbCompactFilterCleanupStrategy

Hangxiang Yu created FLINK-30854: Summary: Expose periodic compaction to RocksdbCompactFilterCleanupStrategy Key: FLINK-30854 URL: https://issues.apache.org/jira/browse/FLINK-30854 Project: Flink

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

Hangxiang Yu created FLINK-30656: Summary: Provide more logs for schema compatibility check Key: FLINK-30656 URL: https://issues.apache.org/jira/browse/FLINK-30656 Project: Flink Issue Type:

[jira] [Created] (FLINK-30614) Improve resolving schema compatibility -- Milestone two

Hangxiang Yu created FLINK-30614: Summary: Improve resolving schema compatibility -- Milestone two Key: FLINK-30614 URL: https://issues.apache.org/jira/browse/FLINK-30614 Project: Flink Issue

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

Hangxiang Yu created FLINK-30613: Summary: Improve resolving schema compatibility -- Milestone one Key: FLINK-30613 URL: https://issues.apache.org/jira/browse/FLINK-30613 Project: Flink Issue

[jira] [Created] (FLINK-30450) FileSystem supports exporting client-side metrics

Hangxiang Yu created FLINK-30450: Summary: FileSystem supports exporting client-side metrics Key: FLINK-30450 URL: https://issues.apache.org/jira/browse/FLINK-30450 Project: Flink Issue Type:

[jira] [Created] (FLINK-30345) Improve the serializer performace of state change of changelog

Hangxiang Yu created FLINK-30345: Summary: Improve the serializer performace of state change of changelog Key: FLINK-30345 URL: https://issues.apache.org/jira/browse/FLINK-30345 Project: Flink

[jira] [Created] (FLINK-29844) FLIP-263: Improve resolving schema compatibility

Hangxiang Yu created FLINK-29844: Summary: FLIP-263: Improve resolving schema compatibility Key: FLINK-29844 URL: https://issues.apache.org/jira/browse/FLINK-29844 Project: Flink Issue Type:

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

Hangxiang Yu created FLINK-29802: Summary: ChangelogStateBackend supports native savepoint Key: FLINK-29802 URL: https://issues.apache.org/jira/browse/FLINK-29802 Project: Flink Issue Type: I

[jira] [Created] (FLINK-29777) [JUnit5 Migration] Module: flink-dstl

Hangxiang Yu created FLINK-29777: Summary: [JUnit5 Migration] Module: flink-dstl Key: FLINK-29777 URL: https://issues.apache.org/jira/browse/FLINK-29777 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29776) [JUnit5 Migration] Module: flink-statebackend-changelog

Hangxiang Yu created FLINK-29776: Summary: [JUnit5 Migration] Module: flink-statebackend-changelog Key: FLINK-29776 URL: https://issues.apache.org/jira/browse/FLINK-29776 Project: Flink Issue

[jira] [Created] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb

Hangxiang Yu created FLINK-29775: Summary: [JUnit5 Migration] Module: flink-statebackend-rocksdb Key: FLINK-29775 URL: https://issues.apache.org/jira/browse/FLINK-29775 Project: Flink Issue T

[jira] [Created] (FLINK-28602) Changelog cannot close stream normally while enabling compression

Hangxiang Yu created FLINK-28602: Summary: Changelog cannot close stream normally while enabling compression Key: FLINK-28602 URL: https://issues.apache.org/jira/browse/FLINK-28602 Project: Flink

[jira] [Created] (FLINK-28581) Test Changelog StateBackend V2 Manually

Hangxiang Yu created FLINK-28581: Summary: Test Changelog StateBackend V2 Manually Key: FLINK-28581 URL: https://issues.apache.org/jira/browse/FLINK-28581 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28553) The serializer in StateMap has not been updated when metaInfo of StateTable updated

Hangxiang Yu created FLINK-28553: Summary: The serializer in StateMap has not been updated when metaInfo of StateTable updated Key: FLINK-28553 URL: https://issues.apache.org/jira/browse/FLINK-28553 P

[jira] [Created] (FLINK-27327) Add description about changing max parallelism explicitly leads to state incompatibility

Hangxiang Yu created FLINK-27327: Summary: Add description about changing max parallelism explicitly leads to state incompatibility Key: FLINK-27327 URL: https://issues.apache.org/jira/browse/FLINK-27327

[jira] [Created] (FLINK-25997) FsStateChangelogWriter cannot work well when there is no change appended

Hangxiang Yu created FLINK-25997: Summary: FsStateChangelogWriter cannot work well when there is no change appended Key: FLINK-25997 URL: https://issues.apache.org/jira/browse/FLINK-25997 Project: Fli

[jira] [Created] (FLINK-25492) Changelog with InMemoryStateChangelogStorage cannot work well

Hangxiang Yu created FLINK-25492: Summary: Changelog with InMemoryStateChangelogStorage cannot work well Key: FLINK-25492 URL: https://issues.apache.org/jira/browse/FLINK-25492 Project: Flink

[jira] [Created] (FLINK-25477) The directory structure of the State Backends document is not standardized

Hangxiang Yu created FLINK-25477: Summary: The directory structure of the State Backends document is not standardized Key: FLINK-25477 URL: https://issues.apache.org/jira/browse/FLINK-25477 Project: F