Zakelly commented on PR #25221:
URL: https://github.com/apache/flink/pull/25221#issuecomment-2306829173
Merged.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscri
Zakelly closed pull request #25221: [FLINK-36096] Add synchronous interfaces
for State V2 API.
URL: https://github.com/apache/flink/pull/25221
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the spe
wqshr12345 commented on code in PR #25221:
URL: https://github.com/apache/flink/pull/25221#discussion_r1726156403
##
flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStDBOperationTestBase.java:
##
@@ -129,6 +137,16 @@ static class TestS
wqshr12345 commented on code in PR #25221:
URL: https://github.com/apache/flink/pull/25221#discussion_r1726156261
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/SyncIteratorWrapper.java:
##
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
wqshr12345 commented on code in PR #25221:
URL: https://github.com/apache/flink/pull/25221#discussion_r1726156110
##
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/AppendingState.java:
##
@@ -54,12 +55,40 @@ public interface AppendingState extends State {
Zakelly commented on code in PR #25221:
URL: https://github.com/apache/flink/pull/25221#discussion_r1724336207
##
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/AppendingState.java:
##
@@ -54,12 +55,40 @@ public interface AppendingState extends State {
flinkbot commented on PR #25221:
URL: https://github.com/apache/flink/pull/25221#issuecomment-2298245957
## CI report:
* 29c3cc40b84d0fcde58a3d5e49389204eabd4348 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
wqshr12345 opened a new pull request, #25221:
URL: https://github.com/apache/flink/pull/25221
## What is the purpose of the change
This pull request implements synchronous interfaces for the State V2 API,
enabling a mix of both synchronous and asynchronous access to the same State
