This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a commit to branch kyy
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/kyy by this push:
new f1bccea format
f1bccea is described below
commit f1bccea60151fee513fca15dda0ed1215c391f86
Author: Ring-k <[email protected]>
AuthorDate: Mon Jul 20 17:00:08 2020 +0800
format
---
.../org/apache/iotdb/cluster/client/sync/SyncClientAdaptor.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptor.java
b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptor.java
index 7456fc3..f42ace9 100644
---
a/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptor.java
+++
b/cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptor.java
@@ -222,9 +222,9 @@ public class SyncClientAdaptor {
PullSchemaRequest pullSchemaRequest) throws TException,
InterruptedException {
AtomicReference<List<MeasurementSchema>> timeseriesSchemas = new
AtomicReference<>();
synchronized (timeseriesSchemas) {
- client
- .pullTimeSeriesSchema(pullSchemaRequest, new
PullTimeseriesSchemaHandler(client.getNode(),
- pullSchemaRequest.getPrefixPaths(), timeseriesSchemas));
+ client.pullTimeSeriesSchema(pullSchemaRequest,
+ new PullTimeseriesSchemaHandler(client.getNode(),
pullSchemaRequest.getPrefixPaths(),
+ timeseriesSchemas));
timeseriesSchemas.wait(RaftServer.getReadOperationTimeoutMS());
}
return timeseriesSchemas.get();