Problem Type (问题类型)
exception / error (运行异常)
Before submit
Environment (环境信息)
Your Question (问题描述)
我试着运行 .../computer-test/src/main/java/com/baidu/hugegraph/computer/algorithm/centrality/degree/DegreeCentralityTest.java 中的 testRunAlgorithm() 这个case,得到了如下的错误日志,是我缺少什么配置吗,或者说这个测试用例是可以独立运行的吗?它的成功执行依赖其他进程吗?因为除了这个用例以外我并未运行其他的服务
![image](https://user-images.githubusercontent.com/101246748/174972271-ee93c41e-0558-4c0d-8b55-ce3f865595b9.png)
![image](https://user-images.githubusercontent.com/101246748/174972392-f4b17bd4-5e98-407d-a99c-d87d52d6dbc5.png)
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