scheduler: fix the issue that some scheduler persist config without s…

…olving error (#2817) (#2818) Signed-off-by: ti-srebot <[email protected]>
tikv · Sep 1, 2020 · 928c257 · 928c257
1 parent 57f6db1
commit 928c257
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 8 deletions.
diff --git a/plugin/scheduler_example/evict_leader.go b/plugin/scheduler_example/evict_leader.go
@@ -132,8 +132,7 @@ func (conf *evictLeaderSchedulerConfig) Persist() error {
 	if err != nil {
 		return err
 	}
-	conf.storage.SaveScheduleConfig(name, data)
-	return nil
+	return conf.storage.SaveScheduleConfig(name, data)
 }
 
 func (conf *evictLeaderSchedulerConfig) getScheduleName() string {

diff --git a/server/schedulers/evict_leader.go b/server/schedulers/evict_leader.go
@@ -120,8 +120,7 @@ func (conf *evictLeaderSchedulerConfig) Persist() error {
 	if err != nil {
 		return err
 	}
-	conf.storage.SaveScheduleConfig(name, data)
-	return nil
+	return conf.storage.SaveScheduleConfig(name, data)
 }
 
 func (conf *evictLeaderSchedulerConfig) getSchedulerName() string {

diff --git a/server/schedulers/grant_leader.go b/server/schedulers/grant_leader.go
@@ -114,8 +114,7 @@ func (conf *grantLeaderSchedulerConfig) Persist() error {
 	if err != nil {
 		return err
 	}
-	conf.storage.SaveScheduleConfig(name, data)
-	return nil
+	return conf.storage.SaveScheduleConfig(name, data)
 }
 
 func (conf *grantLeaderSchedulerConfig) getSchedulerName() string {

diff --git a/server/schedulers/scatter_range.go b/server/schedulers/scatter_range.go
@@ -110,8 +110,7 @@ func (conf *scatterRangeSchedulerConfig) Persist() error {
 	if err != nil {
 		return err
 	}
-	conf.storage.SaveScheduleConfig(name, data)
-	return nil
+	return conf.storage.SaveScheduleConfig(name, data)
 }
 
 func (conf *scatterRangeSchedulerConfig) GetRangeName() string {