sjwiesman commented on a change in pull request #16: [FLINK-15945] Remove
MULTIPLEX_FLINK_STATE config
URL: https://github.com/apache/flink-statefun/pull/16#discussion_r376502933
##########
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/Reductions.java
##########
@@ -145,4 +142,21 @@ void processEnvelopes() {
// TODO: consider preemption if too many local messages.
}
}
+
+ private static boolean useMultiplexedState(KeyedStateBackend<?>
keyedStateBackend) {
+ final String backendClassName = keyedStateBackend.getClass().getName();
+
+ // TODO this is fragile and error-prone to classname changes, but we're
doing this
+ // TODO to avoid additional dependencies on the Flink state backends
+ // TODO ideally, we should revisit how configuration is being passed to the
+ // TODO operators to be available at runtime
+ if
(backendClassName.equals("org.apache.flink.runtime.state.heap.HeapKeyedStateBackend"))
{
+ return false;
+ }
+ if (backendClassName.equals(
+ "org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend")) {
Review comment:
@igalshilman, the statebackend cannot be null. The default is
MemoryStateBackend which is the same implementation as FsStateBackend but
checks are stored in JM memory.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
