[iotdb] branch guonengtest updated: spotless

[xingtanzjr]

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

xingtanzjr pushed a commit to branch guonengtest
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/guonengtest by this push:
     new 08f3db0139 spotless
08f3db0139 is described below

commit 08f3db01397a29a239063ba62bf442f3c9f3ae5c
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Tue Apr 18 12:35:09 2023 +0800

    spotless
---
 example/session/src/main/java/org/apache/iotdb/WriterTest.java | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/example/session/src/main/java/org/apache/iotdb/WriterTest.java 
b/example/session/src/main/java/org/apache/iotdb/WriterTest.java
index ac12b5a67f..7136ce7207 100644
--- a/example/session/src/main/java/org/apache/iotdb/WriterTest.java
+++ b/example/session/src/main/java/org/apache/iotdb/WriterTest.java
@@ -97,16 +97,18 @@ public class WriterTest {
       }
     }
 
-    protected void finishInsertAndWait() throws InterruptedException {
+    protected void finishInsertAndWait(int loopIndex) throws 
InterruptedException {
       CountDownLatch currentLatch = latch;
       synchronized (this) {
         currentLatch.countDown();
         if (currentLatch.getCount() == 0) {
           needResetLatch = true;
           LOGGER.info(
-              "one loop finished. cost: {}ms. total rows: {}",
+              "write loop[{}] finished. cost: {}ms. total rows: {}. total 
points: {}",
+              loopIndex,
               (System.currentTimeMillis() - currentTimestamp),
-              totalRowNumber.get());
+              totalRowNumber.get(),
+              totalRowNumber.get() * SENSOR_NUMBER);
         }
       }
       currentLatch.await();
@@ -129,7 +131,7 @@ public class WriterTest {
         try {
           int insertDeviceCount = insertRecords(index, 
signal.currentTimestamp);
           totalRowNumber.addAndGet(insertDeviceCount);
-          signal.finishInsertAndWait();
+          signal.finishInsertAndWait(j);
         } catch (Exception e) {
           LOGGER.error("insert error. Thread: {}. Error:", index, e);
         }