masteryhx closed pull request #24682: [FLINK-35047][state] Support
ForStStateBackend and ForStKeyedStateBackend
URL: https://github.com/apache/flink/pull/24682
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
masteryhx commented on PR #24682:
URL: https://github.com/apache/flink/pull/24682#issuecomment-2076795175
@flinkbot run azure
--
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
masteryhx commented on PR #24682:
URL: https://github.com/apache/flink/pull/24682#issuecomment-2076794847
@flinkbot run azure
--
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
masteryhx commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1578773304
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackend.java:
##
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the
masteryhx commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1578772481
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStResourceContainer.java:
##
@@ -0,0 +1,547 @@
+/*
+ * Licensed to the
masteryhx commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1578770992
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/restore/ForStRestoreOperation.java:
##
@@ -0,0 +1,29 @@
+/*
+ * Licensed
fredia commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1577715584
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStResourceContainer.java:
##
@@ -0,0 +1,547 @@
+/*
+ * Licensed to the
fredia commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1577638164
##
flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStMultiClassLoaderTest.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the
masteryhx commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1574482995
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOperationUtils.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the
masteryhx commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1574455229
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStResourceContainer.java:
##
@@ -0,0 +1,544 @@
+/*
+ * Licensed to the
Zakelly commented on code in PR #24682:
URL: https://github.com/apache/flink/pull/24682#discussion_r1574434930
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOperationUtils.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the
flinkbot commented on PR #24682:
URL: https://github.com/apache/flink/pull/24682#issuecomment-2065635116
## CI report:
* a5be0a188101bcaf6fb76c8d5144ad002a79a192 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
masteryhx opened a new pull request, #24682:
URL: https://github.com/apache/flink/pull/24682
## What is the purpose of the change
A ForStStateBackend is introduced to leverage ForSt as state store for Flink.
This ticket includes:
- Life cycle of ForSt, including
13 matches
Mail list logo
