-
Notifications
You must be signed in to change notification settings - Fork 3.3k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
HBASE-23668 Master log start filling with "Flush journal status" messages #1015
Conversation
🎊 +1 overall
This message was automatically generated. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think I can add a UT for this.
You can apply your patch first after changing the minor nits, I will open a new issue to upload the UT.
@@ -382,7 +383,8 @@ public void recoverLease() throws IOException { | |||
if (conf.get(USE_HSYNC_KEY) != null) { | |||
conf.set(HRegion.WAL_HSYNC_CONF_KEY, conf.get(USE_HSYNC_KEY)); | |||
} | |||
conf.setInt(AbstractFSWAL.RING_BUFFER_SLOT_COUNT, IntMath.ceilingPowerOfTwo(16 * numThreads)); | |||
conf.setInt(AbstractFSWAL.RING_BUFFER_SLOT_COUNT, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
emmmm, why this format change? What is the max line width in your formatter config?
changes > flushPerChanges; | ||
if (flush && LOG.isTraceEnabled()) { | ||
LOG.trace("shouldFlush memStoreSize={}, flushSize={}, changes={}, flushPerChanges={}", | ||
region.getMemStoreHeapSize() + region.getMemStoreOffHeapSize(), flushSize, changes, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
These values could change between calls, so I think we'd better store them in a local variable and then log them.
…ages" This reverts commit fb9fa04. i.e. reapplication of patch that was preamaturely applied.
d09b74b
to
aa4c401
Compare
Address @Apache9 nits. |
🎊 +1 overall
This message was automatically generated. |
Manually merged to branch-2 and master. |
…ages"
This reverts commit fb9fa04.
i.e. reapplication of patch that was preamaturely applied.