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

2024-05-23 Thread Hangxiang Yu (Jira)
[ 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

2024-05-17 Thread Hangxiang Yu (Jira)
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

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

2024-05-17 Thread Hangxiang Yu (Jira)
[ 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

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

2024-05-08 Thread Hangxiang Yu (Jira)
[ 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

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

2024-05-08 Thread Hangxiang Yu (Jira)
[ 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

2024-04-29 Thread Hangxiang Yu (Jira)
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

2024-04-29 Thread Hangxiang Yu (Jira)
[ 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

2024-04-29 Thread Hangxiang Yu (Jira)
[ 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

2024-04-29 Thread Hangxiang Yu (Jira)
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

2024-04-25 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-25 Thread Hangxiang Yu (Jira)
[ 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

2024-04-25 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-25 Thread Hangxiang Yu (Jira)
[ 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. >

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

2024-04-21 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-19 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839068#comment-17839068 ] Hangxiang Yu commented on FLINK-35175: -- [~rskraba] Thanks for reporting this! I think it's better

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

2024-04-18 Thread Hangxiang Yu (Jira)
[ 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 >

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

2024-04-17 Thread Hangxiang Yu (Jira)
[ 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

2024-04-17 Thread Hangxiang Yu (Jira)
[ 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 >

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

2024-04-16 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-14 Thread Hangxiang Yu (Jira)
[ 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

2024-04-09 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-09 Thread Hangxiang Yu (Jira)
[ 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:

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

2024-04-08 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-08 Thread Hangxiang Yu (Jira)
[ 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.

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

2024-04-08 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-08 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-08 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-08 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-08 Thread Hangxiang Yu (Jira)
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:

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

2024-04-08 Thread Hangxiang Yu (Jira)
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:

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

2024-04-08 Thread Hangxiang Yu (Jira)
[ 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) >

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

2024-04-08 Thread Hangxiang Yu (Jira)
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

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

2024-04-08 Thread Hangxiang Yu (Jira)
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

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

2024-04-08 Thread Hangxiang Yu (Jira)
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:

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

2024-04-08 Thread Hangxiang Yu (Jira)
[ 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

2024-04-08 Thread Hangxiang Yu (Jira)
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

2024-04-08 Thread Hangxiang Yu (Jira)
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

2024-04-06 Thread Hangxiang Yu (Jira)
[ 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

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

2024-04-06 Thread Hangxiang Yu (Jira)
[ 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

2024-04-06 Thread Hangxiang Yu (Jira)
[ 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

2024-04-06 Thread Hangxiang Yu (Jira)
[ 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

2024-04-02 Thread Hangxiang Yu (Jira)
[ 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

2024-04-02 Thread Hangxiang Yu (Jira)
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

2024-04-02 Thread Hangxiang Yu (Jira)
[ 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

2024-04-01 Thread Hangxiang Yu (Jira)
[ 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

2024-04-01 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17832991#comment-17832991 ] Hangxiang Yu commented on FLINK-34975: -- Hi, [~kkrugler]. Thanks a lot for sharing the interesting

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

2024-04-01 Thread Hangxiang Yu (Jira)
[ 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

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

2024-03-31 Thread Hangxiang Yu (Jira)
[ 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

2024-03-31 Thread Hangxiang Yu (Jira)
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

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

2024-03-26 Thread Hangxiang Yu (Jira)
[ 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

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

2024-03-26 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831141#comment-17831141 ] Hangxiang Yu edited comment on FLINK-33707 at 3/27/24 2:46 AM: --- Hi, Scala

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

2024-03-26 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831141#comment-17831141 ] Hangxiang Yu commented on FLINK-33707: -- Hi, Scala API has been marked as deprecated. Do we still

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

2024-03-21 Thread Hangxiang Yu (Jira)
[ 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

2024-03-20 Thread Hangxiang Yu (Jira)
[ 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

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

2024-03-17 Thread Hangxiang Yu (Jira)
[ 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

2024-03-17 Thread Hangxiang Yu (Jira)
[ 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 

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

2024-03-15 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827439#comment-17827439 ] Hangxiang Yu commented on FLINK-34660: -- I found it's because

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

2024-03-14 Thread Hangxiang Yu (Jira)
[ 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

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

2024-03-13 Thread Hangxiang Yu (Jira)
[ 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

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

2024-03-13 Thread Hangxiang Yu (Jira)
[ 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

2024-03-13 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-34660: Summary: AutoRescalingITCase#testCheckpointRescalingInKeyedState AssertionError Key: FLINK-34660 URL: https://issues.apache.org/jira/browse/FLINK-34660 Project:

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

2024-03-12 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825532#comment-17825532 ] Hangxiang Yu commented on FLINK-32085: -- Maybe we could discuss about FLINK-34652 firstly which has

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

2024-03-12 Thread Hangxiang Yu (Jira)
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

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

2024-03-12 Thread Hangxiang Yu (Jira)
[ 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

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

2024-03-11 Thread Hangxiang Yu (Jira)
[ 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

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

2024-03-10 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825123#comment-17825123 ] Hangxiang Yu commented on FLINK-29114: -- master:

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

2024-03-07 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17824599#comment-17824599 ] Hangxiang Yu commented on FLINK-34519: -- Thanks for reporting this. {quote}stopCheckpointScheduler()

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

2024-03-07 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17824593#comment-17824593 ] Hangxiang Yu commented on FLINK-34558: -- I think this mertic maybe useful, but since it's under the

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

2024-03-04 Thread Hangxiang Yu (Jira)
[ 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

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

2024-03-04 Thread Hangxiang Yu (Jira)
[ 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

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

2024-02-27 Thread Hangxiang Yu (Jira)
[ 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

2024-02-27 Thread Hangxiang Yu (Jira)
[ 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

2024-02-27 Thread Hangxiang Yu (Jira)
[ 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

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

2024-02-25 Thread Hangxiang Yu (Jira)
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:

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

2024-02-21 Thread Hangxiang Yu (Jira)
[ 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

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

2024-02-21 Thread Hangxiang Yu (Jira)
[ 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

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

2024-02-21 Thread Hangxiang Yu (Jira)
[ 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

2024-02-21 Thread Hangxiang Yu (Jira)
[ 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 

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

2024-02-20 Thread Hangxiang Yu (Jira)
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

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

2024-02-05 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814655#comment-17814655 ] Hangxiang Yu commented on FLINK-34334: -- I think we could add such a metric. But I'd suggest to

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

2024-02-04 Thread Hangxiang Yu (Jira)
[ 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

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

2024-02-04 Thread Hangxiang Yu (Jira)
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

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

2024-01-24 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810682#comment-17810682 ] Hangxiang Yu commented on FLINK-33819: -- merged 4f7725aa into master which is not blocked by the

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

2024-01-24 Thread Hangxiang Yu (Jira)
[ 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

2024-01-24 Thread Hangxiang Yu (Jira)
[ 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

2024-01-23 Thread Hangxiang Yu (Jira)
[ 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

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

2024-01-23 Thread Hangxiang Yu (Jira)
[ 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

2024-01-19 Thread Hangxiang Yu (Jira)
[ 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

2024-01-18 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807968#comment-17807968 ] Hangxiang Yu edited comment on FLINK-30656 at 1/19/24 1:37 AM: --- We should

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

2024-01-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807968#comment-17807968 ] Hangxiang Yu edited comment on FLINK-30656 at 1/18/24 3:57 AM: --- We should

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

2024-01-17 Thread Hangxiang Yu (Jira)
[ 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

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

2024-01-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17807968#comment-17807968 ] Hangxiang Yu commented on FLINK-30656: -- We should support to remain some messages for

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

2024-01-16 Thread Hangxiang Yu (Jira)
[ 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

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

2024-01-16 Thread Hangxiang Yu (Jira)
[ 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

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

2024-01-16 Thread Hangxiang Yu (Jira)
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:

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

2024-01-16 Thread Hangxiang Yu (Jira)
[ 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] [Assigned] (FLINK-29802) ChangelogStateBackend supports native savepoint

2024-01-15 Thread Hangxiang Yu (Jira)
[ 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-34078) Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

2024-01-15 Thread Hangxiang Yu (Jira)
[ 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

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

2024-01-14 Thread Hangxiang Yu (Jira)
[ 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] [Commented] (FLINK-34078) Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

2024-01-14 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806660#comment-17806660 ] Hangxiang Yu commented on FLINK-34078: -- Thanks for reporting this. It makes sense to move it to

  1   2   3   4   5   >