rename

apache · Jan 10, 2025 · 3f9ded6 · 3f9ded6
1 parent ac91209
commit 3f9ded6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...-server/src/main/java/org/apache/bigtop/manager/server/command/helper/JobCacheHelper.java b/...-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/...anager-server/src/main/java/org/apache/bigtop/manager/server/command/job/AbstractJob.java b/...anager-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()) {