-
Notifications
You must be signed in to change notification settings - Fork 3.4k
HBASE-28951 use unique name of temp recovered edits for each worker #7075
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
base: master
Are you sure you want to change the base?
Conversation
This comment has been minimized.
This comment has been minimized.
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'm not sure if this could work. What if 'split to hfile' is enabled?
@@ -55,9 +55,14 @@ public AbstractRecoveredEditsOutputSink(WALSplitter walSplitter, | |||
/** Returns a writer that wraps a {@link WALProvider.Writer} and its Path. Caller should close. */ | |||
protected RecoveredEditsWriter createRecoveredEditsWriter(TableName tableName, byte[] region, | |||
long seqId) throws IOException { | |||
// If multiple worker are splitting a WAL at a same time, both should use unique file name to | |||
// avoid conflict | |||
long workerStartCode = |
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.
Is startCode enough to make unique directory? Different region server could have same start code?
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.
Yeah, I missed this point, this won't work.
To use the whole RS server name, I was worried about reaching the filename lenght limit. Do you also see this concern on it?
This comment has been minimized.
This comment has been minimized.
bff1c53
to
3a658b6
Compare
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
🎊 +1 overall
This message was automatically generated. |
I created this ticket mainly for RecoveredEditsOutputSink. Can we create another ticket for BoundedRecoveredHFilesOutputSink ? |
💔 -1 overall
This message was automatically generated. |
@Apache9 , @NihalJain , @apurtell can you please review this PR ? I looked into failed test and found that those are getting timed out on master branch as well, will take some time to figure out what is the issue |
Solution Document - https://docs.google.com/document/d/1CX9ysa5thq0vajXR2zapcMkfwTwV9VsW6xGXuxdN97M/edit?tab=t.0#heading=h.74kik1edg70t