https://5dok.net/document/yj7m474m-safe-data-parallelism-for-general-streaming.html