-
Notifications
You must be signed in to change notification settings - Fork 2.9k
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
[ALLUXIO-3392] embedded journal #8219
Conversation
Merged build finished. Test FAILed. |
Test FAILed. |
@@ -87,6 +87,9 @@ public static MasterInquireClient create(AlluxioConfiguration conf) { | |||
return ZkMasterInquireClient.getClient(conf.get(PropertyKey.ZOOKEEPER_ADDRESS), | |||
conf.get(PropertyKey.ZOOKEEPER_ELECTION_PATH), | |||
conf.get(PropertyKey.ZOOKEEPER_LEADER_PATH)); | |||
} else if (alluxio.util.ConfigurationUtils.getMasterRpcAddresses(conf).size() > 1) { | |||
return new PollingMasterInquireClient( | |||
alluxio.util.ConfigurationUtils.getMasterRpcAddresses(conf)); |
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.
We can use just ConfigurationUtils
instead of the fully-qualified path alluxio.util.ConfigurationUtils
. Same for the rest of the PR - unless there is a conflict with another class in the file, we don't use fully-qualified paths
@@ -35,10 +36,14 @@ message JournalEntry { | |||
optional DeleteLineageEntry delete_lineage = 7; | |||
optional DeleteMountPointEntry delete_mount_point = 8; | |||
optional DeleteStoreEntry delete_store = 25; | |||
optional FinishJobEntry finish_job = 39; |
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.
what is this for?
@@ -53,6 +58,7 @@ message JournalEntry { | |||
optional RenameStoreEntry rename_store = 28; | |||
optional SetAclEntry set_acl = 31; | |||
optional SetAttributeEntry set_attribute = 27; | |||
optional StartJobEntry start_job = 41; |
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.
what is this for?
* will run at 4am, noon, and 8pm every day. The anchor time avoids issues with clock drift and | ||
* rounding errors. | ||
*/ | ||
public class AnchoredFixedRateRunnable implements Runnable { |
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 this file used anywhere?
Merged build finished. Test FAILed. |
Test FAILed. |
jenkins, test this please |
Merged build finished. Test FAILed. |
Test FAILed. |
Merged build finished. Test FAILed. |
Test FAILed. |
Merged build finished. Test FAILed. |
Test FAILed. |
Merged build finished. Test PASSed. |
Test PASSed. |
@@ -507,6 +512,22 @@ | |||
<artifactId>httpcore</artifactId> | |||
<version>4.4.6</version> | |||
</dependency> | |||
<dependency> | |||
<groupId>io.atomix.copycat.alluxio</groupId> |
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.
Why not use the latest version of atomix ?
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.
Agree that we should upgrade to the latest version at some point, but the Atomix 3 API is very different from the Copycat API, so it will take some serious effort. I think it's worth merging with the Copycat API for now, then upgrading later. Copycat was stable for a long time before the Atomix refactor.
Merged build finished. Test PASSed. |
Test PASSed. |
Merged build finished. Test PASSed. |
Test PASSed. |
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.
LGTM
### What changes are proposed in this pull request? Correct docs about Ratis. ### Why are the changes needed? Embedded journal is introduced in #8219, then Copycat is replaced by Ratis in #12181. Some docs are not updated. ### Does this PR introduce any user facing changes? No. pr-link: #16985 change-id: cid-592a5c06991c5b067690031ef7fffed9d2e6fac6
### What changes are proposed in this pull request? Correct docs about Ratis. ### Why are the changes needed? Embedded journal is introduced in Alluxio#8219, then Copycat is replaced by Ratis in Alluxio#12181. Some docs are not updated. ### Does this PR introduce any user facing changes? No. pr-link: Alluxio#16985 change-id: cid-592a5c06991c5b067690031ef7fffed9d2e6fac6
### What changes are proposed in this pull request? Correct docs about Ratis. ### Why are the changes needed? Embedded journal is introduced in Alluxio#8219, then Copycat is replaced by Ratis in Alluxio#12181. Some docs are not updated. ### Does this PR introduce any user facing changes? No. pr-link: Alluxio#16985 change-id: cid-592a5c06991c5b067690031ef7fffed9d2e6fac6
### What changes are proposed in this pull request? Correct docs about Ratis. ### Why are the changes needed? Embedded journal is introduced in Alluxio#8219, then Copycat is replaced by Ratis in Alluxio#12181. Some docs are not updated. ### Does this PR introduce any user facing changes? No. pr-link: Alluxio#16985 change-id: cid-592a5c06991c5b067690031ef7fffed9d2e6fac6
### What changes are proposed in this pull request? Correct docs about Ratis. ### Why are the changes needed? Embedded journal is introduced in Alluxio#8219, then Copycat is replaced by Ratis in Alluxio#12181. Some docs are not updated. ### Does this PR introduce any user facing changes? No. pr-link: Alluxio#16985 change-id: cid-592a5c06991c5b067690031ef7fffed9d2e6fac6
https://alluxio.atlassian.net/browse/ALLUXIO-3392