Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r168499407
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
---
@@ -727,19 +729,17 @@ static void resetRocksDBLoadedFlag() throws Exception
{
/**
* This class encapsulates the configuration for local recovery of this
backend.
*/
- public static final class LocalRecoveryConfig implements Serializable {
+ public static final class LocalRecoveryConfig extends
LocalRecoveryConfigBase {
- private static final long serialVersionUID = 1L;
--- End diff --
Changed in later commit.
---
