Skip to content

Commit f8fc58a

Browse files
committed
fix(server): fix some issues of the distributed scheduler
1 parent 5807fb7 commit f8fc58a

3 files changed

Lines changed: 25 additions & 11 deletions

File tree

hugegraph-server/hugegraph-core/src/main/java/org/apache/hugegraph/task/HugeServerInfo.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,12 @@
1717

1818
package org.apache.hugegraph.task;
1919

20+
import java.util.ArrayList;
21+
import java.util.Date;
22+
import java.util.HashMap;
23+
import java.util.List;
24+
import java.util.Map;
25+
2026
import org.apache.hugegraph.HugeGraph;
2127
import org.apache.hugegraph.HugeGraphParams;
2228
import org.apache.hugegraph.backend.id.Id;
@@ -37,8 +43,6 @@
3743
import org.apache.tinkerpop.gremlin.structure.Vertex;
3844
import org.apache.tinkerpop.gremlin.structure.VertexProperty;
3945

40-
import java.util.*;
41-
4246
public class HugeServerInfo {
4347

4448
// Unit millisecond

hugegraph-server/hugegraph-core/src/main/java/org/apache/hugegraph/task/StandardTaskScheduler.java

Lines changed: 11 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,17 @@
1717

1818
package org.apache.hugegraph.task;
1919

20+
import java.util.ArrayList;
21+
import java.util.Iterator;
22+
import java.util.List;
23+
import java.util.Map;
24+
import java.util.concurrent.Callable;
25+
import java.util.concurrent.ConcurrentHashMap;
26+
import java.util.concurrent.ExecutorService;
27+
import java.util.concurrent.Executors;
28+
import java.util.concurrent.Future;
29+
import java.util.concurrent.TimeoutException;
30+
2031
import com.google.common.collect.ImmutableMap;
2132
import org.apache.hugegraph.HugeException;
2233
import org.apache.hugegraph.HugeGraph;
@@ -46,12 +57,6 @@
4657
import org.apache.tinkerpop.gremlin.structure.Vertex;
4758
import org.slf4j.Logger;
4859

49-
import java.util.ArrayList;
50-
import java.util.Iterator;
51-
import java.util.List;
52-
import java.util.Map;
53-
import java.util.concurrent.*;
54-
5560
public class StandardTaskScheduler implements TaskScheduler {
5661

5762
private static final Logger LOG = Log.logger(StandardTaskScheduler.class);

hugegraph-server/hugegraph-core/src/main/java/org/apache/hugegraph/task/TaskManager.java

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,14 @@
1717

1818
package org.apache.hugegraph.task;
1919

20+
import java.util.Map;
21+
import java.util.concurrent.Callable;
22+
import java.util.concurrent.ConcurrentHashMap;
23+
import java.util.concurrent.ExecutorService;
24+
import java.util.concurrent.ThreadPoolExecutor;
25+
import java.util.concurrent.TimeUnit;
26+
import java.util.concurrent.TimeoutException;
27+
2028
import org.apache.hugegraph.HugeException;
2129
import org.apache.hugegraph.HugeGraphParams;
2230
import org.apache.hugegraph.concurrent.PausableScheduledThreadPool;
@@ -27,9 +35,6 @@
2735
import org.apache.hugegraph.util.Log;
2836
import org.slf4j.Logger;
2937

30-
import java.util.Map;
31-
import java.util.concurrent.*;
32-
3338
/**
3439
* Central task management system that coordinates task scheduling and execution.
3540
* Manages task schedulers for different graphs and handles role-based execution.

0 commit comments

Comments
 (0)