fix: Fix typos (#4476)

<!--
Thanks for your contribution! please review
https://github.com/alibaba/GraphScope/blob/main/CONTRIBUTING.md before
opening an issue.
-->

## What do these changes do?
Fix typos
<!-- Please give a short brief about these changes. -->

## Related issue number

<!-- Are there any issues opened that will be resolved by merging this
change? -->

Fixes

analytical_engine/apps/flash/core/degeneracy-ordering.h

@@ -89,9 +89,9 @@ class DegeneracyFlash : public FlashAppBase<FRAG_T, DEGENERACY_TYPE> {
     A = All;
     for (int len = VSize(A), i = 0; len > 0; len = VSize(A), ++i) {
       LOG(INFO) << "Ranking Round " << i << ": size=" << len << std::endl;
-      DefineFV(filterd) { return v.d <= dg; };
+      DefineFV(filtered) { return v.d <= dg; };
       DefineMapV(localr) { v.rank = i; };
-      A = VertexMap(A, filterd, localr);
+      A = VertexMap(A, filtered, localr);
 
       DefineFV(cond) { return v.rank == -1; };
       DefineMapE(update) { d.tmp++; };

analytical_engine/core/fragment/arrow_flattened_fragment.h

@@ -242,7 +242,7 @@ struct NbrDefault {
 };
 
 /**
- * @brief Union of all iteratable adjacent lists of a vertex. The union
+ * @brief Union of all iterable adjacent lists of a vertex. The union
  * list contains all neighbors in format of NbrDefault, which contains the other
  * Node and the data on the Edge. The lists must be non-empty to construct the
  * UnionAdjList.

analytical_engine/java/grape-demo/src/main/java/com/alibaba/graphscope/example/stringApp/StringApp.java

@@ -25,7 +25,7 @@ public class StringApp
      * @param graph          fragment. The graph fragment providing accesses to graph data.
      * @param context        context. User defined context which manages data during the whole
      *                       computations.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @see IFragment
      * @see ParallelContextBase
      * @see ParallelMessageManager
@@ -62,7 +62,7 @@ public void PEval(
      * @param graph          fragment. The graph fragment providing accesses to graph data.
      * @param context        context. User defined context which manages data during the whole
      *                       computations.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @see IFragment
      * @see ParallelContextBase
      * @see ParallelMessageManager

analytical_engine/java/grape-demo/src/main/java/com/alibaba/graphscope/example/stringApp/StringAppContext.java

@@ -27,7 +27,7 @@ public class StringAppContext
      * super steps here.
      *
      * @param frag           The graph fragment providing accesses to graph data.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @param jsonObject     String args from cmdline.
      * @see IFragment
      * @see ParallelMessageManager

analytical_engine/java/grape-giraph/src/main/java/com/alibaba/graphscope/app/GiraphComputationAdaptor.java

@@ -64,7 +64,7 @@ public class GiraphComputationAdaptor<OID_T, VID_T, VDATA_T, EDATA_T> extends Co
      * @param graph fragment. The graph fragment providing accesses to graph data.
      * @param context context. User defined context which manages data during the whole
      *     computations.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @see IFragment
      * @see DefaultContextBase
      * @see DefaultMessageManager
@@ -188,7 +188,7 @@ public void PEval(
      * @param graph fragment. The graph fragment providing accesses to graph data.
      * @param context context. User defined context which manages data during the whole
      *     computations.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @see IFragment
      * @see DefaultContextBase
      * @see DefaultMessageManager

analytical_engine/java/grape-giraph/src/main/java/com/alibaba/graphscope/factory/GiraphComputationFactory.java

@@ -199,7 +199,7 @@ GiraphEdgeManager<OID_T, EDATA_T> createImmutableEdgeManagerImpl(
                     GiraphVertexIdManager<GRAPE_VID_T, OID_T> idManager,
                     ImmutableClassesGiraphConfiguration<OID_T, ?, EDATA_T> conf) {
         if (conf.getEdgeManager().equals("default")) {
-            logger.info("Using [Default] edge manger");
+            logger.info("Using [Default] edge manager");
             return new DefaultImmutableEdgeManager<
                     GRAPE_OID_T, GRAPE_VID_T, GRAPE_VDATA_T, GRAPE_EDATA_T, OID_T, EDATA_T>(
                     fragment, idManager, conf);

analytical_engine/java/grape-graphx/src/main/java/com/alibaba/graphscope/context/GraphXParallelAdaptorContext.java

@@ -149,7 +149,7 @@ public GraphXParallelAdaptorContext(
      * super steps here.
      *
      * @param frag           The graph fragment providing accesses to graph data.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @param jsonObject     String args from cmdline.
      * @see IFragment
      * @see ParallelMessageManager

analytical_engine/java/grape-jdk/src/main/java/com/alibaba/graphscope/app/DefaultAppBase.java

@@ -82,7 +82,7 @@ public interface DefaultAppBase<
      * @param graph fragment. The graph fragment providing accesses to graph data.
      * @param context context. User defined context which manages data during the whole
      *     computations.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @see IFragment
      * @see DefaultContextBase
      * @see DefaultMessageManager
@@ -98,7 +98,7 @@ void PEval(
      * @param graph fragment. The graph fragment providing accesses to graph data.
      * @param context context. User defined context which manages data during the whole
      *     computations.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @see IFragment
      * @see DefaultContextBase
      * @see DefaultMessageManager

analytical_engine/java/grape-jdk/src/main/java/com/alibaba/graphscope/app/ParallelAppBase.java

@@ -82,7 +82,7 @@ public interface ParallelAppBase<
      * @param graph fragment. The graph fragment providing accesses to graph data.
      * @param context context. User defined context which manages data during the whole
      *     computations.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @see IFragment
      * @see ParallelContextBase
      * @see ParallelMessageManager
@@ -97,7 +97,7 @@ void PEval(
      * @param graph fragment. The graph fragment providing accesses to graph data.
      * @param context context. User defined context which manages data during the whole
      *     computations.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @see IFragment
      * @see ParallelContextBase
      * @see ParallelMessageManager

analytical_engine/java/grape-jdk/src/main/java/com/alibaba/graphscope/context/ContextDataType.java

@@ -55,7 +55,7 @@ public static ContextDataType get(int value) {
             case 8:
                 return kUndefined;
             default:
-                throw new IllegalStateException("Unknow value for Context data type: " + value);
+                throw new IllegalStateException("Unknown value for Context data type: " + value);
         }
     }
 

analytical_engine/java/grape-jdk/src/main/java/com/alibaba/graphscope/context/DefaultContextBase.java

@@ -40,7 +40,7 @@ public interface DefaultContextBase<OID_T, VID_T, VDATA_T, EDATA_T> extends Cont
      * super steps here.
      *
      * @param frag The graph fragment providing accesses to graph data.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @param jsonObject String args from cmdline.
      * @see IFragment
      * @see DefaultMessageManager

analytical_engine/java/grape-jdk/src/main/java/com/alibaba/graphscope/context/ParallelContextBase.java

@@ -39,7 +39,7 @@ public interface ParallelContextBase<OID_T, VID_T, VDATA_T, EDATA_T> extends Con
      * super steps here.
      *
      * @param frag The graph fragment providing accesses to graph data.
-     * @param messageManager The message manger which manages messages between fragments.
+     * @param messageManager The message manager which manages messages between fragments.
      * @param jsonObject String args from cmdline.
      * @see IFragment
      * @see ParallelMessageManager

analytical_engine/java/grape-jdk/src/main/java/com/alibaba/graphscope/utils/AppContextGetter.java

@@ -192,7 +192,7 @@ public static String getVertexDataContextDataType(VertexDataContext ctxObj) {
         try {
             ret = getBaseClassTemplateType(ctxClass, 1);
         } catch (Exception exception) {
-            logger.info("Exception ocurred: ");
+            logger.info("Exception occurred: ");
             exception.printStackTrace();
             ret = ctxObj.getDataClass();
             logger.info("vertex data context class: " + ret.getName());

analytical_engine/java/grape-runtime/src/test/java/com/alibaba/graphscope/utils/ContextUtilsTest.java

@@ -60,7 +60,7 @@ public static class SampleContext2
          * during super steps here.
          *
          * @param frag           The graph fragment providing accesses to graph data.
-         * @param messageManager The message manger which manages messages between fragments.
+         * @param messageManager The message manager which manages messages between fragments.
          * @param jsonObject     String args from cmdline.
          * @see IFragment
          * @see DefaultMessageManager

analytical_engine/java/run_graphx.sh

@@ -170,7 +170,7 @@ while test $# -ne 0; do
         shift
         if [[ "${TASK}" == *"load_fragment"* || "${TASK}" == *"run_pregel"* ]];
         then
-            log "Runing task:            "${TASK}
+            log "Running task:            "${TASK}
         else
             err "Received unrecognized task ${TASK}"
             exit 1
@@ -250,5 +250,5 @@ elif  [[ "${TASK}" == *"run_pregel"* ]];
 then
   run_pregel
 else
-  err "Not possible taks "${TASK}
+  err "Not possible task "${TASK}
 fi

analytical_engine/test/giraph_runner.h

@@ -267,7 +267,7 @@ void CreateAndQuery(std::string params) {
              << ", vif: " << vertex_input_format_class
              << ", eif: " << edge_input_format_class;
     if (efile.empty() || vfile.empty()) {
-      LOG(FATAL) << "Make sure efile and vfile are avalibale";
+      LOG(FATAL) << "Make sure efile and vfile are available";
     }
     fragment_id =
         LoadGiraphFragment(comm_spec, vfile, efile, vertex_input_format_class,

coordinator/gscoordinator/flex/core/insight/groot.py

@@ -86,7 +86,7 @@ def _try_to_recover_from_disk(self):
     def _pickle_job_status_impl(self):
         try:
             status = {}
-            # we can't pickle class objct with thread, so we pickle the status
+            # we can't pickle class object with thread, so we pickle the status
             for jobid, fetching in self._job_status.items():
                 status[jobid] = fetching.status
             with open(self._job_status_pickle_path, "wb") as f:

coordinator/gscoordinator/flex/core/insight/job.py

@@ -84,7 +84,7 @@ def _fetch_impl(self):
                     s["log"] = rlt["message"]
             except Exception as e:
                 s["status"] = "FAILED"
-                s["log"] = "Internel error: {0}".format(str(e))
+                s["log"] = "Internal error: {0}".format(str(e))
             finally:
                 self._status = JobStatus.from_dict(s)
                 time.sleep(5)
@@ -329,7 +329,7 @@ def run(self):
                         log=rlt["message"],
                     )
         except Exception as e:
-            logger.error("Exception occured: ", str(e))
+            logger.error("Exception occurred: ", str(e))
             status = self.generate_job_status(
                 status="FAILED", end_time=datetime.datetime.now(), log=str(e)
             )