Skip to content

Commit

Permalink
Remove ineffective property keys for embedded journal
Browse files Browse the repository at this point in the history
pr-link: #13750
change-id: cid-19ea8a2d1cd5d594a2192f306fc6fdcf8a56fbcf
  • Loading branch information
Göktürk Gezer committed Jul 7, 2021
1 parent 4705d65 commit ebcf0f7
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 57 deletions.
57 changes: 0 additions & 57 deletions core/common/src/main/java/alluxio/conf/PropertyKey.java
Expand Up @@ -1723,20 +1723,6 @@ public String toString() {
.setConsistencyCheckLevel(ConsistencyCheckLevel.WARN)
.setScope(Scope.MASTER)
.build();
/**
* @deprecated appender batch size is used by copycat dependency which is removed
*/
@Deprecated
public static final PropertyKey MASTER_EMBEDDED_JOURNAL_APPENDER_BATCH_SIZE =
new Builder(Name.MASTER_EMBEDDED_JOURNAL_APPENDER_BATCH_SIZE)
.setDescription("Amount of data that is appended from leader to followers "
+ "in a single heartbeat. Setting higher values might require increasing "
+ "election timeout due to increased network delay. Setting lower values "
+ "might stall knowledge propagation between the leader and followers.")
.setDefaultValue("512KB")
.setConsistencyCheckLevel(ConsistencyCheckLevel.WARN)
.setScope(Scope.MASTER)
.build();
public static final PropertyKey MASTER_EMBEDDED_JOURNAL_CATCHUP_RETRY_WAIT =
new Builder(Name.MASTER_EMBEDDED_JOURNAL_CATCHUP_RETRY_WAIT)
.setDefaultValue("1s")
Expand Down Expand Up @@ -1779,30 +1765,6 @@ public String toString() {
.setConsistencyCheckLevel(ConsistencyCheckLevel.WARN)
.setScope(Scope.MASTER)
.build();
/**
* @deprecated storage level is used by copycat dependency which is removed
*/
@Deprecated
public static final PropertyKey MASTER_EMBEDDED_JOURNAL_STORAGE_LEVEL =
new Builder(Name.MASTER_EMBEDDED_JOURNAL_STORAGE_LEVEL)
.setDescription("The storage level for storing embedded journal logs. Use DISK for "
+ "maximum durability. Use MAPPED for better performance, but some risk of "
+ "losing state in case of power loss or host failure. Use MEMORY for "
+ "optimal performance, but no state persistence across cluster restarts.")
.setDefaultValue("DISK")
.setScope(Scope.MASTER)
.build();
/**
* @deprecated journal shutdown timeout is used by copycat dependency which is removed
*/
@Deprecated
public static final PropertyKey MASTER_EMBEDDED_JOURNAL_SHUTDOWN_TIMEOUT =
new Builder(Name.MASTER_EMBEDDED_JOURNAL_SHUTDOWN_TIMEOUT)
.setDefaultValue("10sec")
.setDescription("Maximum time to wait for embedded journal to stop on shutdown.")
.setConsistencyCheckLevel(ConsistencyCheckLevel.WARN)
.setScope(Scope.MASTER)
.build();
public static final PropertyKey MASTER_EMBEDDED_JOURNAL_WRITE_LOCAL_FIRST_ENABLED =
new Builder(Name.MASTER_EMBEDDED_JOURNAL_WRITE_LOCAL_FIRST_ENABLED)
.setDefaultValue(true)
Expand Down Expand Up @@ -1835,17 +1797,6 @@ public String toString() {
.setConsistencyCheckLevel(ConsistencyCheckLevel.WARN)
.setScope(Scope.MASTER)
.build();
/**
* @deprecated snapshot wait timeout is used by copycat dependency which is removed
*/
@Deprecated
public static final PropertyKey MASTER_EMBEDDED_JOURNAL_TRIGGERED_SNAPSHOT_WAIT_TIMEOUT =
new Builder(Name.MASTER_EMBEDDED_JOURNAL_TRIGGERED_SNAPSHOT_WAIT_TIMEOUT)
.setDefaultValue("2hour")
.setDescription("Maximum time to wait for the triggered snapshot to finish.")
.setConsistencyCheckLevel(ConsistencyCheckLevel.WARN)
.setScope(Scope.MASTER)
.build();
public static final PropertyKey MASTER_EMBEDDED_JOURNAL_TRANSPORT_REQUEST_TIMEOUT_MS =
new Builder(Name.MASTER_EMBEDDED_JOURNAL_TRANSPORT_REQUEST_TIMEOUT_MS)
.setDefaultValue("5sec")
Expand Down Expand Up @@ -5672,8 +5623,6 @@ public static final class Name {
"alluxio.master.embedded.journal.addresses";
public static final String MASTER_EMBEDDED_JOURNAL_ELECTION_TIMEOUT =
"alluxio.master.embedded.journal.election.timeout";
public static final String MASTER_EMBEDDED_JOURNAL_APPENDER_BATCH_SIZE =
"alluxio.master.embedded.journal.appender.batch.size";
public static final String MASTER_EMBEDDED_JOURNAL_CATCHUP_RETRY_WAIT =
"alluxio.master.embedded.journal.catchup.retry.wait";
public static final String MASTER_EMBEDDED_JOURNAL_ENTRY_SIZE_MAX =
Expand All @@ -5686,10 +5635,6 @@ public static final class Name {
"alluxio.master.embedded.journal.port";
public static final String MASTER_EMBEDDED_JOURNAL_RETRY_CACHE_EXPIRY_TIME =
"alluxio.master.embedded.journal.retry.cache.expiry.time";
public static final String MASTER_EMBEDDED_JOURNAL_STORAGE_LEVEL =
"alluxio.master.embedded.journal.storage.level";
public static final String MASTER_EMBEDDED_JOURNAL_SHUTDOWN_TIMEOUT =
"alluxio.master.embedded.journal.shutdown.timeout";
public static final String MASTER_EMBEDDED_JOURNAL_WRITE_LOCAL_FIRST_ENABLED =
"alluxio.master.embedded.journal.write.local.first.enabled";
public static final String MASTER_EMBEDDED_JOURNAL_WRITE_REMOTE_ENABLED =
Expand All @@ -5698,8 +5643,6 @@ public static final class Name {
"alluxio.master.embedded.journal.write.timeout";
public static final String MASTER_EMBEDDED_JOURNAL_SNAPSHOT_REPLICATION_CHUNK_SIZE =
"alluxio.master.embedded.journal.snapshot.replication.chunk.size";
public static final String MASTER_EMBEDDED_JOURNAL_TRIGGERED_SNAPSHOT_WAIT_TIMEOUT =
"alluxio.master.embedded.journal.triggered.snapshot.wait.timeout";
public static final String MASTER_EMBEDDED_JOURNAL_TRANSPORT_REQUEST_TIMEOUT_MS =
"alluxio.master.embedded.journal.transport.request.timeout.ms";
public static final String MASTER_EMBEDDED_JOURNAL_TRANSPORT_MAX_INBOUND_MESSAGE_SIZE =
Expand Down
4 changes: 4 additions & 0 deletions core/common/src/main/java/alluxio/conf/RemovedKey.java
Expand Up @@ -81,6 +81,10 @@ private static String replacedSince(String version, String newProperty) {
put("alluxio.master.retry", removedSince(V2_0_0));
put("alluxio.master.worker.threads.max", removedSince(V2_0_0));
put("alluxio.master.worker.threads.min", removedSince(V2_0_0));
put("alluxio.master.embedded.journal.appender.batch.size", removedSince(V2_4_0));
put("alluxio.master.embedded.journal.storage.level", removedSince(V2_4_0));
put("alluxio.master.embedded.journal.shutdown.timeout", removedSince(V2_4_0));
put("alluxio.master.embedded.journal.triggered.snapshot.wait.timeout", removedSince(V2_4_0));
put("alluxio.network.netty.heartbeat.timeout", removedSince(V2_0_0));
put("alluxio.network.thrift.frame.size.bytes.max", removedSince(V2_0_0));
put("alluxio.underfs.object.store.read.retry.base.sleep", removedSince(V2_0_0));
Expand Down

0 comments on commit ebcf0f7

Please sign in to comment.