describe2022 opened a new issue, #186: URL: https://github.com/apache/incubator-hugegraph-computer/issues/186
### Problem Type (问题类型) exception / error (运行异常) ### Before submit - [X] 我已经确认现有的 [Server-Issues](https://github.com/hugegraph/hugegraph/issues) 与 [Computer-Issues](https://github.com/hugegraph/hugegraph-computer/issues) 中没有相同 / 重复问题 ### Environment (环境信息) - Computer Version: v0.1.2 ### Your Question (问题描述) 我试着运行 .../computer-test/src/main/java/com/baidu/hugegraph/computer/algorithm/centrality/degree/DegreeCentralityTest.java 中的 testRunAlgorithm() 这个case，得到了如下的错误日志，是我缺少什么配置吗，或者说这个测试用例是可以独立运行的吗？它的成功执行依赖其他进程吗？因为除了这个用例以外我并未运行其他的服务 2022-06-22 15:25:29 696 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.register_timeout' is redundant, please ensure it has been registered 2022-06-22 15:25:29 697 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.register_timeout' is redundant, please ensure it has been registered 2022-06-22 15:25:29 700 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.result_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 700 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.params_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 700 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'rpc.remote_url' is redundant, please ensure it has been registered 2022-06-22 15:25:29 700 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'job.id' is redundant, please ensure it has been registered 2022-06-22 15:25:29 700 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'job.workers_count' is redundant, please ensure it has been registered 2022-06-22 15:25:29 700 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.log_interval' is redundant, please ensure it has been registered 2022-06-22 15:25:29 701 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'master.computation_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 701 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'output.output_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 701 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'worker.combiner_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 701 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.max_super_step' is redundant, please ensure it has been registered 2022-06-22 15:25:29 701 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'worker.computation_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 701 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'transport.server_port' is redundant, please ensure it has been registered 2022-06-22 15:25:29 701 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'degree_centrality.weight_property' is redundant, please ensure it has been registered 2022-06-22 15:25:29 701 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.message_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 700 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.result_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 703 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'rpc.server_host' is redundant, please ensure it has been registered 2022-06-22 15:25:29 704 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.params_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 704 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'job.id' is redundant, please ensure it has been registered 2022-06-22 15:25:29 704 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'job.workers_count' is redundant, please ensure it has been registered 2022-06-22 15:25:29 704 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.log_interval' is redundant, please ensure it has been registered 2022-06-22 15:25:29 704 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'master.computation_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 704 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'output.output_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 704 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'worker.combiner_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 704 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.max_super_step' is redundant, please ensure it has been registered 2022-06-22 15:25:29 704 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'worker.computation_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 704 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'rpc.server_port' is redundant, please ensure it has been registered 2022-06-22 15:25:29 705 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'degree_centrality.weight_property' is redundant, please ensure it has been registered 2022-06-22 15:25:29 705 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.message_class' is redundant, please ensure it has been registered 2022-06-22 15:25:29 714 [pool-2-thread-2] [INFO ] com.baidu.hugegraph.computer.core.master.MasterService [] - [master ?654393868] Start to initialize master 2022-06-22 15:25:29 714 [pool-2-thread-1] [INFO ] com.baidu.hugegraph.computer.core.worker.WorkerService [] - [worker -1] Start to initialize worker 2022-06-22 15:25:30 1119 [pool-2-thread-1] [INFO ] com.baidu.hugegraph.computer.core.bsp.BspBase [] - Init etcd BSP connection to 'http://localhost:2379' for job 'algo_test_job1' 2022-06-22 15:25:30 1120 [pool-2-thread-1] [INFO ] com.baidu.hugegraph.computer.core.bsp.Bsp4Worker [] - Worker(:-1) is waiting for master init-done 2022-06-22 15:25:30 1760 [pool-2-thread-1] [ERROR] com.baidu.hugegraph.computer.algorithm.AlgorithmTestBase [] - Failed to start worker com.baidu.hugegraph.computer.core.common.exception.ComputerException: Error while getting with key='BSP_MASTER_INIT_DONE' at com.baidu.hugegraph.computer.core.bsp.EtcdClient.get(EtcdClient.java:175) ~[classes/:?] at com.baidu.hugegraph.computer.core.bsp.EtcdBspClient.get(EtcdBspClient.java:74) ~[classes/:?] at com.baidu.hugegraph.computer.core.bsp.Bsp4Worker.waitMasterInitDone(Bsp4Worker.java:54) ~[classes/:?] at com.baidu.hugegraph.computer.core.worker.WorkerService.init(WorkerService.java:114) ~[classes/:?] at com.baidu.hugegraph.computer.core.worker.MockWorkerService.init(MockWorkerService.java:31) ~[classes/:?] at com.baidu.hugegraph.computer.algorithm.AlgorithmTestBase.lambda$runAlgorithm$0(AlgorithmTestBase.java:81) ~[classes/:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_322] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_322] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_322] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_322] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] Caused by: java.util.concurrent.ExecutionException: java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_322] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_322] at com.baidu.hugegraph.computer.core.bsp.EtcdClient.get(EtcdClient.java:161) ~[classes/:?] ... 10 more Caused by: java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:526) ~[guava-25.1-jre.jar:?] at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:487) ~[guava-25.1-jre.jar:?] at io.etcd.jetcd.ClientConnectionManager.lambda$execute$3(ClientConnectionManager.java:351) ~[jetcd-core-0.5.4.jar:?] ... 3 more Caused by: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.Status.asRuntimeException(Status.java:533) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[grpc-stub-1.33.0.jar:1.33.0] at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40) ~[grpc-api-1.33.0.jar:1.33.0] at io.etcd.jetcd.ClientConnectionManager$AuthTokenInterceptor$1$1.onClose(ClientConnectionManager.java:394) ~[jetcd-core-0.5.4.jar:?] at io.grpc.internal.DelayedClientCall$DelayedListener$3.run(DelayedClientCall.java:463) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener.delayOrExecute(DelayedClientCall.java:427) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener.onClose(DelayedClientCall.java:460) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[grpc-core-1.33.0.jar:1.33.0] ... 3 more Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: localhost/127.0.0.1:2379 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:660) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:637) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:524) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:473) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:383) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1044) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] ... 1 more 2022-06-22 15:25:30 1787 [main] [WARN ] com.baidu.hugegraph.computer.suite.unit.UnitTestBase [] - There exist error: com.baidu.hugegraph.computer.core.common.exception.ComputerException: Error while getting with key='BSP_MASTER_INIT_DONE' at com.baidu.hugegraph.computer.core.bsp.EtcdClient.get(EtcdClient.java:175) ~[classes/:?] at com.baidu.hugegraph.computer.core.bsp.EtcdBspClient.get(EtcdBspClient.java:74) ~[classes/:?] at com.baidu.hugegraph.computer.core.bsp.Bsp4Worker.waitMasterInitDone(Bsp4Worker.java:54) ~[classes/:?] at com.baidu.hugegraph.computer.core.worker.WorkerService.init(WorkerService.java:114) ~[classes/:?] at com.baidu.hugegraph.computer.core.worker.MockWorkerService.init(MockWorkerService.java:31) ~[classes/:?] at com.baidu.hugegraph.computer.algorithm.AlgorithmTestBase.lambda$runAlgorithm$0(AlgorithmTestBase.java:81) ~[classes/:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_322] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_322] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_322] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_322] at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_322] Caused by: java.util.concurrent.ExecutionException: java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_322] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_322] at com.baidu.hugegraph.computer.core.bsp.EtcdClient.get(EtcdClient.java:161) ~[classes/:?] ... 10 more Caused by: java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:526) ~[guava-25.1-jre.jar:?] at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:487) ~[guava-25.1-jre.jar:?] at io.etcd.jetcd.ClientConnectionManager.lambda$execute$3(ClientConnectionManager.java:351) ~[jetcd-core-0.5.4.jar:?] ... 3 more Caused by: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.Status.asRuntimeException(Status.java:533) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[grpc-stub-1.33.0.jar:1.33.0] at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40) ~[grpc-api-1.33.0.jar:1.33.0] at io.etcd.jetcd.ClientConnectionManager$AuthTokenInterceptor$1$1.onClose(ClientConnectionManager.java:394) ~[jetcd-core-0.5.4.jar:?] at io.grpc.internal.DelayedClientCall$DelayedListener$3.run(DelayedClientCall.java:463) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener.delayOrExecute(DelayedClientCall.java:427) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener.onClose(DelayedClientCall.java:460) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[grpc-core-1.33.0.jar:1.33.0] ... 3 more Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: localhost/127.0.0.1:2379 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:660) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:637) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:524) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:473) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:383) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1044) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] ... 1 more 2022-06-22 15:34:40 844 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.register_timeout' is redundant, please ensure it has been registered 2022-06-22 15:34:40 844 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.register_timeout' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.result_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.result_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.params_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'rpc.server_host' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'rpc.remote_url' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.params_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'job.id' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'job.id' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'job.workers_count' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'job.workers_count' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.log_interval' is redundant, please ensure it has been registered 2022-06-22 15:34:40 848 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.log_interval' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'master.computation_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'master.computation_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'output.output_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'output.output_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'worker.combiner_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'worker.combiner_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.max_super_step' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'bsp.max_super_step' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'worker.computation_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'worker.computation_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'transport.server_port' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'rpc.server_port' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'degree_centrality.weight_property' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'degree_centrality.weight_property' is redundant, please ensure it has been registered 2022-06-22 15:34:40 849 [pool-2-thread-1] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.message_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 850 [pool-2-thread-2] [WARN ] com.baidu.hugegraph.config.HugeConfig [] - The config option 'algorithm.message_class' is redundant, please ensure it has been registered 2022-06-22 15:34:40 870 [pool-2-thread-2] [INFO ] com.baidu.hugegraph.computer.core.master.MasterService [] - [master ?828266361] Start to initialize master 2022-06-22 15:34:40 871 [pool-2-thread-1] [INFO ] com.baidu.hugegraph.computer.core.worker.WorkerService [] - [worker -1] Start to initialize worker 2022-06-22 15:34:40 1139 [pool-2-thread-1] [INFO ] com.baidu.hugegraph.computer.core.bsp.BspBase [] - Init etcd BSP connection to 'http://localhost:2379' for job 'algo_test_job1' 2022-06-22 15:34:40 1139 [pool-2-thread-1] [INFO ] com.baidu.hugegraph.computer.core.bsp.Bsp4Worker [] - Worker(:-1) is waiting for master init-done 2022-06-22 15:34:41 1394 [pool-2-thread-1] [ERROR] com.baidu.hugegraph.computer.algorithm.AlgorithmTestBase [] - Failed to start worker com.baidu.hugegraph.computer.core.common.exception.ComputerException: Error while getting with key='BSP_MASTER_INIT_DONE' at com.baidu.hugegraph.computer.core.bsp.EtcdClient.get(EtcdClient.java:175) ~[classes/:?] at com.baidu.hugegraph.computer.core.bsp.EtcdBspClient.get(EtcdBspClient.java:74) ~[classes/:?] at com.baidu.hugegraph.computer.core.bsp.Bsp4Worker.waitMasterInitDone(Bsp4Worker.java:54) ~[classes/:?] at com.baidu.hugegraph.computer.core.worker.WorkerService.init(WorkerService.java:113) ~[classes/:?] at com.baidu.hugegraph.computer.core.worker.MockWorkerService.init(MockWorkerService.java:31) ~[classes/:?] at com.baidu.hugegraph.computer.algorithm.AlgorithmTestBase.lambda$runAlgorithm$0(AlgorithmTestBase.java:81) ~[classes/:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_322] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_322] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_322] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_322] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] Caused by: java.util.concurrent.ExecutionException: java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_322] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_322] at com.baidu.hugegraph.computer.core.bsp.EtcdClient.get(EtcdClient.java:161) ~[classes/:?] ... 10 more Caused by: java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:526) ~[guava-25.1-jre.jar:?] at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:487) ~[guava-25.1-jre.jar:?] at io.etcd.jetcd.ClientConnectionManager.lambda$execute$3(ClientConnectionManager.java:351) ~[jetcd-core-0.5.4.jar:?] ... 3 more Caused by: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.Status.asRuntimeException(Status.java:533) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[grpc-stub-1.33.0.jar:1.33.0] at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40) ~[grpc-api-1.33.0.jar:1.33.0] at io.etcd.jetcd.ClientConnectionManager$AuthTokenInterceptor$1$1.onClose(ClientConnectionManager.java:394) ~[jetcd-core-0.5.4.jar:?] at io.grpc.internal.DelayedClientCall$DelayedListener$3.run(DelayedClientCall.java:463) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener.delayOrExecute(DelayedClientCall.java:427) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener.onClose(DelayedClientCall.java:460) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[grpc-core-1.33.0.jar:1.33.0] ... 3 more Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: localhost/127.0.0.1:2379 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:660) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:637) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:524) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:473) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:383) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1044) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] ... 1 more 2022-06-22 15:34:41 1403 [main] [WARN ] com.baidu.hugegraph.computer.suite.unit.UnitTestBase [] - There exist error: com.baidu.hugegraph.computer.core.common.exception.ComputerException: Error while getting with key='BSP_MASTER_INIT_DONE' at com.baidu.hugegraph.computer.core.bsp.EtcdClient.get(EtcdClient.java:175) ~[classes/:?] at com.baidu.hugegraph.computer.core.bsp.EtcdBspClient.get(EtcdBspClient.java:74) ~[classes/:?] at com.baidu.hugegraph.computer.core.bsp.Bsp4Worker.waitMasterInitDone(Bsp4Worker.java:54) ~[classes/:?] at com.baidu.hugegraph.computer.core.worker.WorkerService.init(WorkerService.java:113) ~[classes/:?] at com.baidu.hugegraph.computer.core.worker.MockWorkerService.init(MockWorkerService.java:31) ~[classes/:?] at com.baidu.hugegraph.computer.algorithm.AlgorithmTestBase.lambda$runAlgorithm$0(AlgorithmTestBase.java:81) ~[classes/:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_322] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_322] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_322] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_322] at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_322] Caused by: java.util.concurrent.ExecutionException: java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) ~[?:1.8.0_322] at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) ~[?:1.8.0_322] at com.baidu.hugegraph.computer.core.bsp.EtcdClient.get(EtcdClient.java:161) ~[classes/:?] ... 10 more Caused by: java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:526) ~[guava-25.1-jre.jar:?] at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:487) ~[guava-25.1-jre.jar:?] at io.etcd.jetcd.ClientConnectionManager.lambda$execute$3(ClientConnectionManager.java:351) ~[jetcd-core-0.5.4.jar:?] ... 3 more Caused by: io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.Status.asRuntimeException(Status.java:533) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[grpc-stub-1.33.0.jar:1.33.0] at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23) ~[grpc-api-1.33.0.jar:1.33.0] at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40) ~[grpc-api-1.33.0.jar:1.33.0] at io.etcd.jetcd.ClientConnectionManager$AuthTokenInterceptor$1$1.onClose(ClientConnectionManager.java:394) ~[jetcd-core-0.5.4.jar:?] at io.grpc.internal.DelayedClientCall$DelayedListener$3.run(DelayedClientCall.java:463) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener.delayOrExecute(DelayedClientCall.java:427) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener.onClose(DelayedClientCall.java:460) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[grpc-core-1.33.0.jar:1.33.0] ... 3 more Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: Connection refused: localhost/127.0.0.1:2379 Caused by: java.net.ConnectException: finishConnect(..) failed: Connection refused at io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:660) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:637) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:524) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:473) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:383) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1044) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-all-4.1.42.Final.jar:4.1.42.Final] ... 1 more   ### Vertex/Edge example (问题点 / 边数据举例) _No response_ ### Schema [VertexLabel, EdgeLabel, IndexLabel] (元数据结构) _No response_ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
