1032851561 commented on code in PR #8194:
URL: https://github.com/apache/hudi/pull/8194#discussion_r1138123092
##########
hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatWriter.java:
##########
@@ -216,9 +216,10 @@ private int getLogBlockLength(int contentLength, int
headerLength, int footerLen
private void rolloverIfNeeded() throws IOException {
// Roll over if the size is past the threshold
- if (getCurrentSize() > sizeThreshold) {
- LOG.info("CurrentSize " + getCurrentSize() + " has reached threshold " +
sizeThreshold
- + ". Rolling over to the next version");
+ long currentSize = fs.getFileStatus(logFile.getPath()).getLen();
+ if (currentSize > sizeThreshold) {
Review Comment:
Sorry, I found it has been fixed in version 0.12.1 or above by
[HUDI-4780](https://issues.apache.org/jira/browse/HUDI-4780).
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
