This is an automated email from the ASF dual-hosted git repository. east pushed a commit to branch east_example_akka_cluster in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 588e4115022af2b64b19e225e1a016f17d6edb9f Author: mdf369 <[email protected]> AuthorDate: Mon Mar 4 10:24:45 2019 +0800 update --- iotdb/src/main/java/org/apache/iotdb/db/akka/SimpleIoTDBNode.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/iotdb/src/main/java/org/apache/iotdb/db/akka/SimpleIoTDBNode.java b/iotdb/src/main/java/org/apache/iotdb/db/akka/SimpleIoTDBNode.java index a3c35be..0e1598b 100644 --- a/iotdb/src/main/java/org/apache/iotdb/db/akka/SimpleIoTDBNode.java +++ b/iotdb/src/main/java/org/apache/iotdb/db/akka/SimpleIoTDBNode.java @@ -9,13 +9,15 @@ import akka.cluster.ClusterEvent.MemberUp; import akka.cluster.ClusterEvent.UnreachableMember; import akka.event.Logging; import akka.event.LoggingAdapter; +import org.apache.iotdb.db.conf.IoTDBConfig; import org.apache.iotdb.db.exception.FileNodeManagerException; import org.apache.iotdb.db.service.IoTDB; public class SimpleIoTDBNode extends AbstractActor { LoggingAdapter log = Logging.getLogger(getContext().system(), this); Cluster cluster = Cluster.get(getContext().system()); - IoTDB ioTDB = IoTDB.getInstance(); +// IoTDB ioTDB = IoTDB.getInstance(); + IoTDB ioTDB = new IoTDB(); //subscribe to cluster changes @Override
