This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a commit to branch xkf_tpc_test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/xkf_tpc_test by this push:
new a4ffe54 fix bug
a4ffe54 is described below
commit a4ffe544943eabd3ef2ad264a9eeb369eb581200
Author: 151250176 <[email protected]>
AuthorDate: Mon Jan 4 14:23:48 2021 +0800
fix bug
---
.../src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java | 9 +--------
1 file changed, 1 insertion(+), 8 deletions(-)
diff --git
a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
index 5cf8a08..d0d23b7 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
@@ -1498,12 +1498,11 @@ public class TSServiceImpl implements TSIService.Iface,
ServerContext {
@Override
public TSStatus insertTablets(TSInsertTabletsReq req) {
- logger.error("!!!!" + req.isFinal);
// transfer to another
if(!req.isFinal){
TSInsertTabletsReq transferReq = new TSInsertTabletsReq();
transferReq.deviceIds = req.deviceIds;
- transferReq.isFinal = true;
+ transferReq.setIsFinal(true);
transferReq.measurementsList = req.measurementsList;
transferReq.typesList = req.typesList;
transferReq.sizeList = new ArrayList<>(req.sizeList);
@@ -1522,13 +1521,7 @@ public class TSServiceImpl implements TSIService.Iface,
ServerContext {
AsyncInsertPool.getInstance().submit(transferReq);
}
- else{
- for(ByteBuffer byteBuffer : req.timestampsList){
- logger.error("!!!!" + byteBuffer);
- System.out.println(byteBuffer);
- }
- }
//
long t1 = System.currentTimeMillis();
try {
