From 3f9ded615d88c953547c1489506863ecd9ec2e9b Mon Sep 17 00:00:00 2001
From: Zhiguo Wu <zhiguo.wu@linaro.org>
Date: Fri, 10 Jan 2025 23:41:29 +0800
Subject: [PATCH] rename

---
 .../bigtop/manager/server/command/helper/JobCacheHelper.java  | 4 ++--
 .../apache/bigtop/manager/server/command/job/AbstractJob.java | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/command/helper/JobCacheHelper.java b/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/command/helper/JobCacheHelper.java
index cde64e49..9bea2e67 100644
--- a/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/command/helper/JobCacheHelper.java
+++ b/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/command/helper/JobCacheHelper.java
@@ -77,7 +77,7 @@ private static void initialize() {
         INITIALIZED.set(true);
     }
 
-    public static void saveJobCache(Long clusterId, Long jobId, List<String> hostnames) {
+    public static void sendJobCache(Long clusterId, Long jobId, List<String> hostnames) {
         CacheMessagePayload payload = genPayload(clusterId);
         JobCacheRequest request = JobCacheRequest.newBuilder()
                 .setJobId(jobId)
@@ -108,7 +108,7 @@ public static void saveJobCache(Long clusterId, Long jobId, List<String> hostnam
 
         boolean allSuccess = results.stream().allMatch(Boolean::booleanValue);
         if (!allSuccess) {
-            throw new ServerException("Failed to save job cache");
+            throw new ServerException("Failed to send job cache");
         }
     }
 
diff --git a/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/command/job/AbstractJob.java b/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/command/job/AbstractJob.java
index fb096a13..02f07ecf 100644
--- a/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/command/job/AbstractJob.java
+++ b/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/command/job/AbstractJob.java
@@ -105,7 +105,7 @@ public void run() {
                     .flatMap(List::stream)
                     .distinct()
                     .toList();
-            JobCacheHelper.saveJobCache(clusterPO.getId(), jobPO.getId(), hostnames);
+            JobCacheHelper.sendJobCache(clusterPO.getId(), jobPO.getId(), hostnames);
 
             LinkedBlockingQueue<Stage> queue = new LinkedBlockingQueue<>(stages);
             while (!queue.isEmpty()) {