THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Old | New |
|---|---|
| MemoryStateBackend() | HashMapStateBackend() + JobManagerCheckpointStorage() |
| FsStateBackend() | HashMapStateBackend() + FileSystemCheckpointStorage() |
| RocksDBStateBackend(new MemoryStateBackend()) | EmbeddedRocksDBStateBackend() + JobManagerCheckpointStorage() |
| RocksDBStateBackend(new FsStateBackend()) | EmbeddedRocksDBStateBackend() + FileSystemCheckpointStorage() |
| MemoryStateBackend("file://path") | HashMapStateBackend() + JobManagerCheckpointStorage("file://path") |
All flink-conf configurations will be duplicated for the new state backend or snapshot storage instance, whichever is appropriate. Again, no functionality will be added or dropped in this change. Existing flink-conf keys will also be specified as deprecated keys on the new state backends to ease migration.
...