Skip to content

Commit

Permalink
Fix config name
Browse files Browse the repository at this point in the history
  • Loading branch information
maobaolong committed Dec 31, 2024
1 parent 6e90095 commit bd7e057
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -765,11 +765,7 @@ public class ShuffleServerConf extends RssBaseConf {
.stringType()
.defaultValue(LocalStorageManager.class.getName())
.withDescription("The class of local storage manager implementation");
public static final ConfigOption<Boolean> SERVER_TRIGGER_REPORT_WHILE_UNREGISTER_ENABLED =
ConfigOptions.key("rss.server.heartbeatReportOnUnregisterEnabled")
.booleanType()
.defaultValue(false)
.withDescription("Whether to trigger report while unregister");

public static final ConfigOption<Boolean> SERVER_HEARTBEAT_REPORT_ON_UNREGISTER_ENABLED =
ConfigOptions.key("rss.server.heartbeatReportOnUnregisterEnabled")
.booleanType()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -170,7 +170,7 @@ public void unregisterShuffleByAppId(
try {
if (shuffleServer
.getShuffleServerConf()
.getBoolean(ShuffleServerConf.SERVER_TRIGGER_REPORT_WHILE_UNREGISTER_ENABLED)) {
.getBoolean(ShuffleServerConf.SERVER_HEARTBEAT_REPORT_ON_UNREGISTER_ENABLED)) {
shuffleServer.sendHeartbeat();
}
shuffleServer.getShuffleTaskManager().removeShuffleDataAsync(appId);
Expand Down Expand Up @@ -217,7 +217,7 @@ public void unregisterShuffle(
try {
if (shuffleServer
.getShuffleServerConf()
.getBoolean(ShuffleServerConf.SERVER_TRIGGER_REPORT_WHILE_UNREGISTER_ENABLED)) {
.getBoolean(ShuffleServerConf.SERVER_HEARTBEAT_REPORT_ON_UNREGISTER_ENABLED)) {
shuffleServer.sendHeartbeat();
}
shuffleServer.getShuffleTaskManager().removeShuffleDataAsync(appId, shuffleId);
Expand Down

0 comments on commit bd7e057

Please sign in to comment.