From 75412879db1eb5f95cf0e1132cd8afce2bdab6a0 Mon Sep 17 00:00:00 2001 From: imbajin Date: Fri, 8 Dec 2023 14:07:28 +0800 Subject: [PATCH] Update MasterService.java --- .../apache/hugegraph/computer/core/master/MasterService.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/computer-core/src/main/java/org/apache/hugegraph/computer/core/master/MasterService.java b/computer-core/src/main/java/org/apache/hugegraph/computer/core/master/MasterService.java index afbf83296..51f58ebfa 100644 --- a/computer-core/src/main/java/org/apache/hugegraph/computer/core/master/MasterService.java +++ b/computer-core/src/main/java/org/apache/hugegraph/computer/core/master/MasterService.java @@ -144,7 +144,8 @@ private void registerShutdownHook() { */ @Override public synchronized void close() { - this.checkInited(); + // TODO: check the logic of close carefully later + //this.checkInited(); if (this.closed) { LOG.info("{} MasterService had closed before", this); return; @@ -409,7 +410,7 @@ void registerAggregator(String name, Class aggregatorClass) { "The aggregator class can't be null"); Aggregator aggr; try { - aggr = aggregatorClass.newInstance(); + aggr = aggregatorClass.getDeclaredConstructor().newInstance(); } catch (Exception e) { throw new ComputerException("Can't new instance from class: %s", e, aggregatorClass.getName());