diff --git a/hugegraph-core/src/main/java/org/apache/hugegraph/StandardHugeGraph.java b/hugegraph-core/src/main/java/org/apache/hugegraph/StandardHugeGraph.java index 37f6a39d72..688b5ba8ef 100644 --- a/hugegraph-core/src/main/java/org/apache/hugegraph/StandardHugeGraph.java +++ b/hugegraph-core/src/main/java/org/apache/hugegraph/StandardHugeGraph.java @@ -270,7 +270,7 @@ public void serverStarted(Id serverId, NodeRole serverRole) { serverId, serverRole, this.name); this.serverInfoManager().initServerInfo(serverId, serverRole); - initRoleStateWorker(serverId); + this.initRoleStateWorker(serverId); // TODO: check necessary? LOG.info("Check olap property-key tables for graph '{}'", this.name); diff --git a/hugegraph-core/src/main/java/org/apache/hugegraph/config/CoreOptions.java b/hugegraph-core/src/main/java/org/apache/hugegraph/config/CoreOptions.java index 69da880e52..862cabb454 100644 --- a/hugegraph-core/src/main/java/org/apache/hugegraph/config/CoreOptions.java +++ b/hugegraph-core/src/main/java/org/apache/hugegraph/config/CoreOptions.java @@ -637,7 +637,7 @@ public static synchronized CoreOptions instance() { public static final ConfigOption RANDOM_TIMEOUT_MILLISECOND = new ConfigOption<>( - "server.role.random.timeout", + "server.role.random_timeout", "The role state machine random timeout millisecond time", rangeInt(0, Integer.MAX_VALUE), 400 @@ -645,7 +645,7 @@ public static synchronized CoreOptions instance() { public static final ConfigOption HEARTBEAT_INTERVAL_SECOUND = new ConfigOption<>( - "server.role.heartbeat.interval", + "server.role.heartbeat_interval", "The role state machine heartbeat interval second time", rangeInt(0, Integer.MAX_VALUE), 1 @@ -653,7 +653,7 @@ public static synchronized CoreOptions instance() { public static final ConfigOption EXCEEDS_WORKER_COUNT = new ConfigOption<>( - "server.role.worker.count", + "server.role.worker_count", "Check the number of times that the master node does not initiate " + "the heartbeat threshold", rangeInt(0, Integer.MAX_VALUE), @@ -662,7 +662,7 @@ public static synchronized CoreOptions instance() { public static final ConfigOption BASE_TIMEOUT_MILLISECOND = new ConfigOption<>( - "server.role.base.timeout", + "server.role.base_timeout", "The role state machine candidate state base timeout time", rangeInt(0, Integer.MAX_VALUE), 100 diff --git a/hugegraph-core/src/main/java/org/apache/hugegraph/election/StandardRoleTypeDataAdapter.java b/hugegraph-core/src/main/java/org/apache/hugegraph/election/StandardRoleTypeDataAdapter.java index 65c9640f11..4b917f9f11 100644 --- a/hugegraph-core/src/main/java/org/apache/hugegraph/election/StandardRoleTypeDataAdapter.java +++ b/hugegraph-core/src/main/java/org/apache/hugegraph/election/StandardRoleTypeDataAdapter.java @@ -43,9 +43,9 @@ public class StandardRoleTypeDataAdapter implements RoleTypeDataAdapter { private final HugeGraphParams graphParams; private final Schema schema; - public StandardRoleTypeDataAdapter(HugeGraphParams graphParams) { - this.graphParams = graphParams; - this.schema = new Schema(graphParams); + public StandardRoleTypeDataAdapter(HugeGraphParams graph) { + this.graphParams = graph; + this.schema = new Schema(graph); this.schema.initSchemaIfNeeded(); }