This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch dev-1.0.1
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
commit cccf6b5f84581d5d783ce8f8ebf20c66467e49ec
Author: leo65535 <leo65...@163.com>
AuthorDate: Thu Apr 14 10:03:37 2022 +0800
[improvement] Use System.currentTimeMillis() to get the current millisecond
(#8828)
---
.../src/main/java/org/apache/doris/load/sync/canal/CanalUtils.java | 6 +++---
.../src/main/java/org/apache/doris/planner/StreamLoadPlanner.java | 2 +-
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 4 ++--
.../src/main/java/org/apache/doris/rewrite/FoldConstantsRule.java | 2 +-
4 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/load/sync/canal/CanalUtils.java
b/fe/fe-core/src/main/java/org/apache/doris/load/sync/canal/CanalUtils.java
index 86c5124eeb..02dd6da573 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/sync/canal/CanalUtils.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/sync/canal/CanalUtils.java
@@ -116,7 +116,7 @@ public class CanalUtils {
public static void printRow(CanalEntry.RowChange rowChange,
CanalEntry.Header header) {
long executeTime = header.getExecuteTime();
- long delayTime = new Date().getTime() - executeTime;
+ long delayTime = System.currentTimeMillis() - executeTime;
Date date = new Date(executeTime);
CanalEntry.EventType eventType = rowChange.getEventType();
logger.info(row_format, header.getLogfileName(),
@@ -187,7 +187,7 @@ public class CanalUtils {
public static void transactionBegin(CanalEntry.Entry entry) {
long executeTime = entry.getHeader().getExecuteTime();
- long delayTime = new Date().getTime() - executeTime;
+ long delayTime = System.currentTimeMillis() - executeTime;
Date date = new Date(executeTime);
CanalEntry.TransactionBegin begin = null;
try {
@@ -206,7 +206,7 @@ public class CanalUtils {
public static void transactionEnd(CanalEntry.Entry entry) {
long executeTime = entry.getHeader().getExecuteTime();
- long delayTime = new Date().getTime() - executeTime;
+ long delayTime = System.currentTimeMillis() - executeTime;
Date date = new Date(executeTime);
CanalEntry.TransactionEnd end = null;
try {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
index a454647b1c..602ed433bc 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
@@ -194,7 +194,7 @@ public class StreamLoadPlanner {
params.setQueryOptions(queryOptions);
TQueryGlobals queryGlobals = new TQueryGlobals();
queryGlobals.setNowString(DATE_FORMAT.format(new Date()));
- queryGlobals.setTimestampMs(new Date().getTime());
+ queryGlobals.setTimestampMs(System.currentTimeMillis());
queryGlobals.setTimeZone(taskInfo.getTimezone());
queryGlobals.setLoadZeroTolerance(taskInfo.getMaxFilterRatio() <= 0.0);
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
index 502b3bfa39..4502d9d597 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -235,7 +235,7 @@ public class Coordinator {
setFromUserProperty(analyzer);
this.queryGlobals.setNowString(DATE_FORMAT.format(new Date()));
- this.queryGlobals.setTimestampMs(new Date().getTime());
+ this.queryGlobals.setTimestampMs(System.currentTimeMillis());
this.queryGlobals.setLoadZeroTolerance(false);
if (context.getSessionVariable().getTimeZone().equals("CST")) {
this.queryGlobals.setTimeZone(TimeUtils.DEFAULT_TIME_ZONE);
@@ -263,7 +263,7 @@ public class Coordinator {
this.scanNodes = scanNodes;
this.queryOptions = new TQueryOptions();
this.queryGlobals.setNowString(DATE_FORMAT.format(new Date()));
- this.queryGlobals.setTimestampMs(new Date().getTime());
+ this.queryGlobals.setTimestampMs(System.currentTimeMillis());
this.queryGlobals.setTimeZone(timezone);
this.queryGlobals.setLoadZeroTolerance(loadZeroTolerance);
this.tResourceInfo = new TResourceInfo("", "");
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/rewrite/FoldConstantsRule.java
b/fe/fe-core/src/main/java/org/apache/doris/rewrite/FoldConstantsRule.java
index 918eeebad1..6f9bfa8042 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/rewrite/FoldConstantsRule.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/rewrite/FoldConstantsRule.java
@@ -350,7 +350,7 @@ public class FoldConstantsRule implements ExprRewriteRule {
TQueryGlobals queryGlobals = new TQueryGlobals();
queryGlobals.setNowString(DATE_FORMAT.format(new Date()));
- queryGlobals.setTimestampMs(new Date().getTime());
+ queryGlobals.setTimestampMs(System.currentTimeMillis());
queryGlobals.setTimeZone(TimeUtils.DEFAULT_TIME_ZONE);
if (context.getSessionVariable().getTimeZone().equals("CST")) {
queryGlobals.setTimeZone(TimeUtils.DEFAULT_TIME_ZONE);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
