// input params are the metad's ip and port
StorageClient client = new StorageClient("10.32.147.37", 9779);
try {
client.connect();
} catch (Exception e) {
LOGGER.error("storage client connect error, ", e);
client.close();
System.exit(1);
}
scanVertex(client);
scanEdge(client);
client.close();
异常如下
ERROR [main] - storage client connect error,
com.facebook.thrift.TApplicationException: Method name verifyClientVersion not found
at com.facebook.thrift.TApplicationException.read(TApplicationException.java:133)
at com.vesoft.nebula.meta.MetaService$Client.recv_verifyClientVersion(MetaService.java:4464)
at com.vesoft.nebula.meta.MetaService$Client.verifyClientVersion(MetaService.java:4439)
at com.vesoft.nebula.client.meta.MetaClient.getClient(MetaClient.java:116)
at com.vesoft.nebula.client.meta.MetaClient.doConnect(MetaClient.java:104)
at com.vesoft.nebula.client.meta.MetaClient.connect(MetaClient.java:93)
at com.vesoft.nebula.client.meta.MetaManager.<init>(MetaManager.java:56)
at com.vesoft.nebula.client.storage.StorageClient.connect(StorageClient.java:82)
at com.vesoft.nebula.examples.StorageClientExample.main(StorageClientExample.java:30)
ERROR [main] - List Spaces Error: java.net.SocketTimeoutException: connect timed out
ERROR [main] - java.net.SocketTimeoutException: connect timed out
ERROR [main] - List Spaces Error: Cannot write to null outputStream
ERROR [main] - Cannot write to null outputStream
Exception in thread "main" java.lang.IllegalArgumentException: Space:test does not exist.
at com.vesoft.nebula.client.meta.MetaManager.getPartsAlloc(MetaManager.java:295)
at com.vesoft.nebula.client.meta.MetaManager.getSpaceParts(MetaManager.java:277)
at com.vesoft.nebula.client.storage.StorageClient.scanVertex(StorageClient.java:358)
at com.vesoft.nebula.client.storage.StorageClient.scanVertex(StorageClient.java:243)
at com.vesoft.nebula.client.storage.StorageClient.scanVertex(StorageClient.java:162)
at com.vesoft.nebula.client.storage.StorageClient.scanVertex(StorageClient.java:100)
at com.vesoft.nebula.examples.StorageClientExample.scanVertex(StorageClientExample.java:56)
at com.vesoft.nebula.examples.StorageClientExample.main(StorageClientExample.java:44)
// check if client version matches server version
VerifyClientVersionResp resp =
client.verifyClientVersion(new VerifyClientVersionReq());
if (resp.error_code != ErrorCode.SUCCEEDED) {
client.getInputProtocol().getTransport().close();
throw new ClientServerIncompatibleException(new String(resp.getError_msg(),
Charsets.UTF_8));
}