-
Notifications
You must be signed in to change notification settings - Fork 13.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-37620][state/forst] ForSt Sync mode support remote storage #26412
Conversation
<td><h5>state.backend.forst.sync.enforce-local</h5></td> | ||
<td style="word-wrap: break-word;">false</td> | ||
<td>Boolean</td> | ||
<td>Whether to enforce local state for operators in synchronous mode when enabling disaggregated state. This is useful in cases where both synchronous operators and asynchronous operators are used in the same job.</td> |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nit: is this true?
same job. -> same local job.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Overall LGTM. One suggestion: how about add descriptions explaining the state.backend.forst.sync.enforce-local
under https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/ops/state/disaggregated_state/#forst-primary-storage-location
Thanks for the PR. |
IIUC, the remote storage accessing in |
…ache#26412) (cherry picked from commit 3bc9600)
What is the purpose of the change
This PR makes ForSt Sync mode support remote storage and provide
state.backend.forst.sync.enforce-local
.Brief change log
state.backend.forst.sync.enforce-local
toForStOptions
.ForStSyncKeyedStateBackend
when configured.ForStSyncKeyedStateBackend.java
Verifying this change
This change added tests and can be verified as follows:
Does this pull request potentially affect one of the following parts:
@Public(Evolving)
: (no)Documentation