?????????? flink-1.11??????spillable-statebackend????????????????????????????????????????????????????????????????????????OOM???????????????????? //????spillableStateBackend env.setStateBackend(new SpillableStateBackend(path));
-yD jobmanager.memory.process.size=4096m \ -yD taskmanager.memory.process.size=4096m \ -yD taskmanager.memory.managed.size=512m \ -yD state.backend.spillable.chunk-size=128m \ -yD state.backend.spillable.gc-time.threshold=1s \ -yD state.backend.spillable.trigger-interval=1s \ -yD state.backend.spillable.heap-status.check-interval=1s \ ??????????????
