fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/SnapshotLocation.java [197:212]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        public void flushToFile() throws IOException {
            if (!closed) {
                // initialize stream if this is the first flushToFile (stream flush, not Darjeeling
                // harvest)
                if (outStream == null) {
                    createStream();
                }

                if (pos > 0) {
                    outStream.write(writeBuffer, 0, pos);
                    pos = 0;
                }
            } else {
                throw new IOException("closed");
            }
        }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



fluss-server/src/main/java/com/alibaba/fluss/server/log/remote/FsRemoteLogOutputStream.java [101:116]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private void flushToFile() throws IOException {
        if (!closed) {
            // initialize stream if this is the first flushToFile (stream flush, not Darjeeling
            // harvest)
            if (outStream == null) {
                createStream();
            }

            if (pos > 0) {
                outStream.write(writeBuffer, 0, pos);
                pos = 0;
            }
        } else {
            throw new IOException("closed");
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -