sjwiesman commented on a change in pull request #16849:
URL: https://github.com/apache/flink/pull/16849#discussion_r690508152
##########
File path:
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/BootstrapTransformation.java
##########
@@ -215,12 +217,23 @@ StreamConfig getConfig(
config.setOperatorName(operatorID.toHexString());
config.setOperatorID(operatorID);
config.setStateBackend(stateBackend);
+ config.setCheckpointStorage(getCheckpointStorage());
// This means leaving this stateBackend unwrapped.
config.setChangelogStateBackendEnabled(TernaryBoolean.FALSE);
config.setManagedMemoryFractionOperatorOfUseCase(ManagedMemoryUseCase.STATE_BACKEND,
1.0);
return config;
}
+ /**
+ * @return A checkpoint storage that will write the resulting savepoint to
a DFS. It is
+ * configured with a dummy checkpoint directory to satisfy the API but
should only ever be
+ * used for savepoints. This is required to override the default
checkpoint directory which
+ * is always in memory.
+ */
+ private static CheckpointStorage getCheckpointStorage() {
+ return new FileSystemCheckpointStorage("file:///tmp/unused");
Review comment:
I will avoid that for now. That's a bigger refactor then I want to make
at this time.
--
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 unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
