Merge branch 'flink-metadata-sync' of http://code.oppoer.me/idata/com…

…pass into flink-metadata-sync
cubefs · Dec 29, 2023 · 4658feb · 4658feb
2 parents 8d0322c + ede9f85
commit 4658feb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/task-flink/src/main/java/com/oppo/cloud/flink/service/impl/YarnMetaServiceImpl.java b/task-flink/src/main/java/com/oppo/cloud/flink/service/impl/YarnMetaServiceImpl.java
@@ -132,7 +132,7 @@ public void pull(String ip, String clusterName) {
             yarnAppMap.put(id, app.getYarnAppMap());
             log.info("yarnApp-->{},{},{},{}", ip, app.getId(), app.getFinishedTime(), app.getFinalStatus());
         }
-        // todo:保存flink数据
+        // todo:save flink metadata
         log.info("saveYarnAppCount:{},{}", ip, yarnAppMap.size());
     }