[incubator-iotdb] branch dev_merge updated: change session example generate v2

[ejttianyu]

This is an automated email from the ASF dual-hosted git repository.

ejttianyu pushed a commit to branch dev_merge
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/dev_merge by this push:
     new 51251a6  change session example generate v2
51251a6 is described below

commit 51251a640c5b0879879c2c6ccd81f7160a792121
Author: EJTTianyu <1653503...@qq.com>
AuthorDate: Thu May 14 11:50:30 2020 +0800

    change session example generate v2
---
 cli/src/main/java/org/apache/iotdb/cli/SessionTest.java | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git a/cli/src/main/java/org/apache/iotdb/cli/SessionTest.java 
b/cli/src/main/java/org/apache/iotdb/cli/SessionTest.java
index 677caeb..035108d 100644
--- a/cli/src/main/java/org/apache/iotdb/cli/SessionTest.java
+++ b/cli/src/main/java/org/apache/iotdb/cli/SessionTest.java
@@ -71,11 +71,13 @@ public class SessionTest {
 
       long time = 0;
       while (true) {
-//        try {
-//          Thread.sleep(1000);
-//        } catch (InterruptedException e) {
-//          e.printStackTrace();
-//        }
+        if (device >= 4) {
+          try {
+            Thread.sleep(100);
+          } catch (InterruptedException e) {
+            e.printStackTrace();
+          }
+        }
         long start = System.currentTimeMillis();
         time += 5000;
         String deviceId = "root.sg.d1";
@@ -86,11 +88,11 @@ public class SessionTest {
 
         List<String> values = new ArrayList<>();
         for (int i = 0; i < 50000; i++) {
-          values.add(random.nextInt(1000) + "");
+          values.add("1");
         }
 
         try {
-          session.insertRecord(deviceId, time - random.nextInt(10000), 
measurements, values);
+          session.insertRecord(deviceId, time, measurements, values);
         } catch (IoTDBConnectionException e) {
           e.printStackTrace();
         } catch (StatementExecutionException e) {