This is an automated email from the ASF dual-hosted git repository.
lta pushed a commit to branch cluster
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/cluster by this push:
new ba0d647 remove system.out
ba0d647 is described below
commit ba0d64721facd1fa40e80074ca6251d6c737ebc2
Author: lta <[email protected]>
AuthorDate: Tue May 21 10:26:20 2019 +0800
remove system.out
---
.../java/org/apache/iotdb/cluster/service/TSServiceClusterImpl.java | 3 ---
.../java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java | 3 ---
.../java/org/apache/iotdb/db/query/control/QueryResourceManager.java | 1 -
.../iotdb/db/query/dataset/EngineDataSetWithoutTimeGenerator.java | 4 ----
iotdb/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java | 5 -----
iotdb/src/main/java/org/apache/iotdb/db/service/Utils.java | 3 ---
6 files changed, 19 deletions(-)
diff --git
a/cluster/src/main/java/org/apache/iotdb/cluster/service/TSServiceClusterImpl.java
b/cluster/src/main/java/org/apache/iotdb/cluster/service/TSServiceClusterImpl.java
index 4306d673..67c90e7 100644
---
a/cluster/src/main/java/org/apache/iotdb/cluster/service/TSServiceClusterImpl.java
+++
b/cluster/src/main/java/org/apache/iotdb/cluster/service/TSServiceClusterImpl.java
@@ -307,14 +307,11 @@ public class TSServiceClusterImpl extends TSServiceImpl {
queryManager.addSingleQuery(jobId, (QueryPlan) physicalPlan);
QueryDataSet queryDataSet =
processor.getExecutor().processQuery((QueryPlan) physicalPlan,
context);
- System.out.println("Create new Data Set");
try {
queryRet.get().put(statement, queryDataSet);
}catch (Exception e){
e.printStackTrace();
}
- System.out.println("Create new Data Set complete");
- System.out.println(queryDataSet == null);
return queryDataSet;
}
diff --git
a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java
b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java
index 1abc553..516abdc 100644
---
a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java
+++
b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java
@@ -551,9 +551,6 @@ public class FileNodeManager implements IStatistic,
IService {
try {
fileNodeProcessor.delete(deviceId, measurementId, timestamp);
} catch (IOException e) {
- System.out.println(deviceId);
- System.out.println(measurementId);
- System.out.println(timestamp);
throw new FileNodeManagerException(e);
}
// change the type of tsfile to overflowed
diff --git
a/iotdb/src/main/java/org/apache/iotdb/db/query/control/QueryResourceManager.java
b/iotdb/src/main/java/org/apache/iotdb/db/query/control/QueryResourceManager.java
index 612f71a..c5f029e 100644
---
a/iotdb/src/main/java/org/apache/iotdb/db/query/control/QueryResourceManager.java
+++
b/iotdb/src/main/java/org/apache/iotdb/db/query/control/QueryResourceManager.java
@@ -164,7 +164,6 @@ public class QueryResourceManager {
throws FileNodeManagerException {
SingleSeriesExpression singleSeriesExpression = new
SingleSeriesExpression(selectedPath, null);
- System.out.println("查询的path为：" + selectedPath);
QueryDataSource queryDataSource = FileNodeManager.getInstance()
.query(singleSeriesExpression, context);
diff --git
a/iotdb/src/main/java/org/apache/iotdb/db/query/dataset/EngineDataSetWithoutTimeGenerator.java
b/iotdb/src/main/java/org/apache/iotdb/db/query/dataset/EngineDataSetWithoutTimeGenerator.java
index fd1d393..bc9bb08 100644
---
a/iotdb/src/main/java/org/apache/iotdb/db/query/dataset/EngineDataSetWithoutTimeGenerator.java
+++
b/iotdb/src/main/java/org/apache/iotdb/db/query/dataset/EngineDataSetWithoutTimeGenerator.java
@@ -60,12 +60,10 @@ public class EngineDataSetWithoutTimeGenerator extends
QueryDataSet {
throws IOException {
super(paths, dataTypes);
this.readers = readers;
- System.out.println("EngineDataSetWithoutTimeGenerator inner set");
initHeap();
}
private void initHeap() throws IOException {
- System.out.println("Start init heap");
timeSet = new HashSet<>();
timeHeap = new PriorityQueue<>();
cacheTimeValueList = new TimeValuePair[readers.size()];
@@ -74,12 +72,10 @@ public class EngineDataSetWithoutTimeGenerator extends
QueryDataSet {
IPointReader reader = readers.get(i);
if (reader.hasNext()) {
TimeValuePair timeValuePair = reader.next();
- System.out.println(timeValuePair);
cacheTimeValueList[i] = timeValuePair;
timeHeapPut(timeValuePair.getTimestamp());
}
}
- System.out.println("Stop init heap");
}
@Override
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
b/iotdb/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
index 0ff4995..b02f1c2 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
@@ -673,17 +673,12 @@ public class TSServiceImpl implements TSIService.Iface,
ServerContext {
int fetchSize = req.getFetch_size();
QueryDataSet queryDataSet;
if (!queryRet.get().containsKey(statement)) {
- System.out.println("Create new data set");
queryDataSet = createNewDataSet(statement, fetchSize, req);
- System.out.println("Create new data set success");
- LOGGER.error("Create new data set success.");
} else {
queryDataSet = queryRet.get().get(statement);
}
- System.out.println("Get next value");
TSQueryDataSet result =
Utils.convertQueryDataSetByFetchSize(queryDataSet, fetchSize);
boolean hasResultSet = !result.getRecords().isEmpty();
- System.out.println("hasResultSet : " + hasResultSet);
if (!hasResultSet && queryRet.get() != null) {
queryRet.get().remove(statement);
}
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/service/Utils.java
b/iotdb/src/main/java/org/apache/iotdb/db/service/Utils.java
index 03a5a2f..75826da 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/service/Utils.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/service/Utils.java
@@ -47,11 +47,8 @@ public class Utils {
tsQueryDataSet.setRecords(new ArrayList<>());
for (int i = 0; i < fetchsize; i++) {
if (queryDataSet.hasNext()) {
- System.out.println("Get value in convertQueryDataSetByFetchSize");
RowRecord rowRecord = queryDataSet.next();
- System.out.println(rowRecord);
tsQueryDataSet.getRecords().add(convertToTSRecord(rowRecord));
- System.out.println("Get value success in
convertQueryDataSetByFetchSize");
} else {
break;
}
