fix: superstep not take effect

computer-core/src/main/java/org/apache/hugegraph/computer/core/master/MasterService.java

@@ -335,9 +335,7 @@ private boolean finishedIteration(boolean masterContinue,
         if (context.superstep() >= this.maxSuperStep - 1) {
             return true;
         }
-        long activeVertexCount = context.totalVertexCount() -
-                                 context.finishedVertexCount();
-        return context.messageCount() == 0L && activeVertexCount == 0L;
+        return false;
     }
 
     /**

computer-core/src/main/java/org/apache/hugegraph/computer/core/sender/MessageSendBuffers.java

@@ -23,6 +23,7 @@
 import org.apache.hugegraph.computer.core.common.exception.ComputerException;
 import org.apache.hugegraph.computer.core.config.ComputerOptions;
 import org.apache.hugegraph.computer.core.config.Config;
+import org.apache.hugegraph.computer.core.receiver.MessageStat;
 import org.apache.hugegraph.util.InsertionOrderUtil;
 
 public class MessageSendBuffers {
@@ -67,6 +68,13 @@ public Map<Integer, MessageSendPartition> all() {
         return all;
     }
 
+    public MessageStat messageStat(int partitionId) {
+        if (partitionId < 0 || partitionId >= this.buffers.length)  {
+            throw new ComputerException("Invalid partition id %s", partitionId);
+        }
+        return this.buffers[partitionId].messageWritten();
+    }
+
     public void clear() {
         for (MessageSendPartition partition : this.buffers) {
             partition.clear();

computer-core/src/main/java/org/apache/hugegraph/computer/core/sender/MessageSendManager.java

@@ -171,7 +171,7 @@ public void finishSend(MessageType type) {
     }
 
     public MessageStat messageStat(int partitionId) {
-        return this.buffers.get(partitionId).messageWritten();
+        return this.buffers.messageStat(partitionId);
     }
 
     public void clearBuffer() {

computer-test/src/main/java/org/apache/hugegraph/computer/algorithm/community/lpa/LpaTest.java

@@ -18,12 +18,29 @@
 package org.apache.hugegraph.computer.algorithm.community.lpa;
 
 import org.apache.hugegraph.computer.algorithm.AlgorithmTestBase;
+import org.apache.hugegraph.computer.core.common.ComputerContext;
+import org.apache.hugegraph.computer.core.output.hg.task.TaskManager;
+import org.apache.hugegraph.driver.HugeClient;
+import org.apache.hugegraph.structure.gremlin.ResultSet;
+import org.apache.hugegraph.testutil.Assert;
 import org.junit.Test;
 
+import java.util.LinkedHashMap;
+
 public class LpaTest extends AlgorithmTestBase {
 
     @Test
     public void testRunAlgorithm() throws InterruptedException {
         runAlgorithm(LpaParams.class.getName());
+
+        // check result
+        ComputerContext context  = context();
+        TaskManager taskManager = new TaskManager(context.config());
+        HugeClient client = taskManager.client();
+        ResultSet result  = client.gremlin().gremlin("g.V().group().by('lpa').by(T.id)").execute();
+
+        LinkedHashMap resultRow = (LinkedHashMap)result.data().get(0);
+        Assert.assertEquals(4, resultRow.size());
+
     }
 }