1996fanrui commented on a change in pull request #13885:
URL: https://github.com/apache/flink/pull/13885#discussion_r517964413
##########
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java
##########
@@ -877,6 +913,20 @@ public long getWriteBatchSize() {
WRITE_BATCH_SIZE.defaultValue().getBytes() :
writeBatchSize;
}
+ /**
+ * Gets the read buffer size for read checkpoint stream.
+ *
+ * <p>If not explicitly configured, this is the default value of
+ * {@link CheckpointingOptions#FS_READ_BUFFER_SIZE}.
+ *
+ * @return The file system read buffer size, in bytes.
+ */
+ public int getFsReadBufferSize() {
Review comment:
Thanks to @Myasuka 's perfect analysis, this is indeed the reason for my
design.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
