Skip to content

Commit

Permalink
Update MasterService.java
Browse files Browse the repository at this point in the history
  • Loading branch information
imbajin committed Dec 8, 2023
1 parent ce2849d commit 7541287
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -409,7 +410,7 @@ void registerAggregator(String name, Class<C> aggregatorClass) {
"The aggregator class can't be null");
Aggregator<V> 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());
Expand Down

0 comments on commit 7541287

Please sign in to comment.