Merge pull request #121 from Nicole00/v2.5.0

cherrypick to v2.5
vesoft-inc · Aug 5, 2021 · 6a1a0e1 · 6a1a0e1
2 parents 4d4bb7a + 2c95a5a
commit 6a1a0e1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/nebula-exchange/src/main/scala/com/vesoft/nebula/exchange/Exchange.scala b/nebula-exchange/src/main/scala/com/vesoft/nebula/exchange/Exchange.scala
@@ -151,7 +151,7 @@ object Exchange {
             batchSuccess,
             batchFailure)
           processor.process()
-          val costTime = ((System.currentTimeMillis() - startTime) / 1000).formatted("%.2f")
+          val costTime = ((System.currentTimeMillis() - startTime) / 1000.0).formatted("%.2f")
           LOG.info(
             s"data source count: ${count}, " +
               s"import for tag ${tagConfig.name} cost time: ${costTime} s")
@@ -194,7 +194,7 @@ object Exchange {
             batchFailure
           )
           processor.process()
-          val costTime = ((System.currentTimeMillis() - startTime) / 1000).formatted("%.2f")
+          val costTime = ((System.currentTimeMillis() - startTime) / 1000.0).formatted("%.2f")
           LOG.info(
             s"data source count: ${count}, " +
               s"import for edge ${edgeConfig.name} cost time: ${costTime} s")
@@ -220,7 +220,7 @@ object Exchange {
       val startTime    = System.currentTimeMillis()
       val processor    = new ReloadProcessor(data, configs, batchSuccess, batchFailure)
       processor.process()
-      val costTime = ((System.currentTimeMillis() - startTime) / 1000).formatted("%.2f")
+      val costTime = ((System.currentTimeMillis() - startTime) / 1000.0).formatted("%.2f")
       LOG.info(s"reimport ngql count: ${count}, cost time: ${costTime}")
       LOG.info(s"batchSuccess.reimport: ${batchSuccess.value}")
       LOG.info(s"batchFailure.reimport: ${batchFailure.value}")