all testcase add system time zone property " user.timezone = UTC "

skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/httpserver/AbstractGet.java

@@ -14,7 +14,7 @@ import java.util.Map;
  */
 public abstract class AbstractGet extends AbstractLocalSyncWorker {
 
-    public AbstractGet(Role role, ClusterWorkerContext clusterContext, LocalWorkerContext selfContext) {
+    protected AbstractGet(Role role, ClusterWorkerContext clusterContext, LocalWorkerContext selfContext) {
         super(role, clusterContext, selfContext);
     }
 

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/datamerge/JsonDataMerge.java

@@ -20,7 +20,7 @@ public enum JsonDataMerge {
 
     private String path = this.getClass().getResource("/").getPath();
 
-    public void merge(String expectJsonFile, JsonArray actualData) throws FileNotFoundException{
+    public void merge(String expectJsonFile, JsonArray actualData) throws FileNotFoundException {
         Gson gson = new Gson();
         String jsonStrData = JsonFileReader.INSTANCE.read(path + expectJsonFile);
         JsonArray expectJsonArray = gson.fromJson(jsonStrData, JsonArray.class);
@@ -45,10 +45,15 @@ public enum JsonDataMerge {
             if (entry.getValue().isJsonNull()) {
                 Assert.assertEquals(true, actualData.get(key).isJsonNull());
             } else {
-                if (key.equals("timeSlice") || key.equals("startTime") || key.equals("endTime") || key.equals("minute") || key.equals("hour") || key.equals("day")) {
+                if (key.equals("timeSlice") || key.equals("minute") || key.equals("hour") || key.equals("day")) {
                     value = String.valueOf(DateTools.changeToUTCSlice(Long.valueOf(value)));
                 }
-                Assert.assertEquals(value, actualData.get(key).getAsString());
+                if (SpecialTimeColumn.INSTANCE.isSpecialTimeColumn(key)) {
+                    String changedValue = SpecialTimeColumn.INSTANCE.specialTimeColumnChange(value);
+                    Assert.assertEquals(changedValue, actualData.get(key).getAsString());
+                } else {
+                    Assert.assertEquals(value, actualData.get(key).getAsString());
+                }
             }
         }
     }

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/datamerge/MetricDataMergeJson.java

@@ -61,10 +61,12 @@ public enum MetricDataMergeJson {
             if (entry.getValue().isJsonNull()) {
                 Assert.assertEquals(true, actualData.get(key).isJsonNull());
             } else {
+                String actualValue = actualData.get(key).getAsString();
                 if (key.equals("timeSlice")) {
                     value = String.valueOf(DateTools.changeToUTCSlice(Long.valueOf(value)));
+                    actualValue = String.valueOf(DateTools.changeToUTCSlice(Long.valueOf(actualValue)));
                 }
-                Assert.assertEquals(value, actualData.get(key).getAsString());
+                Assert.assertEquals(value, actualValue);
             }
         }
     }
@@ -74,7 +76,7 @@ public enum MetricDataMergeJson {
         Gson gson = new Gson();
         for (MetricData metricData : recordDataList) {
             JsonObject jsonObject = gson.fromJson(gson.toJson(metricData.toMap()), JsonObject.class);
-            recordDataMap.put(metricData.getId(), jsonObject);
+            recordDataMap.put(id2UTCSlice(metricData.getId()), jsonObject);
         }
         return recordDataMap;
     }

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/datamerge/SpecialTimeColumn.java

+package com.a.eye.skywalking.collector.worker.datamerge;
+
+import com.a.eye.skywalking.collector.worker.Const;
+import com.a.eye.skywalking.collector.worker.tools.DateTools;
+
+/**
+ * @author pengys5
+ */
+public enum SpecialTimeColumn {
+    INSTANCE;
+
+    public String specialTimeColumnChange(String value) {
+        String[] values = value.split(Const.IDS_SPLIT);
+        long changedTime = DateTools.changeToUTCSlice(Long.valueOf(values[0]));
+
+        String changedValue = "";
+        for (int i = 1; i < values.length; i++) {
+            changedValue = changedValue + Const.ID_SPLIT + values[i];
+        }
+        return String.valueOf(changedTime) + changedValue;
+    }
+
+    public boolean isSpecialTimeColumn(String columnName) {
+        String[] specialTimeColumns = {"nodeRefId"};
+        for (String column : specialTimeColumns) {
+            if (column.equals(columnName)) {
+                return true;
+            }
+        }
+        return false;
+    }
+}

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/globaltrace/analysis/GlobalTraceAnalysisTestCase.java

@@ -19,6 +19,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.mock;
 import static org.powermock.api.mockito.PowerMockito.when;
@@ -38,6 +40,9 @@ public class GlobalTraceAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new MergeDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/globaltrace/persistence/GlobalTraceAggTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -36,6 +38,9 @@ public class GlobalTraceAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         LocalWorkerContext localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/globaltrace/persistence/GlobalTraceSaveTestCase.java

@@ -9,6 +9,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -18,6 +20,9 @@ public class GlobalTraceSaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new GlobalTraceSave(GlobalTraceSave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/globaltrace/persistence/GlobalTraceSearchWithGlobalIdTestCase.java

@@ -18,6 +18,8 @@ import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 import org.powermock.reflect.Whitebox;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 
@@ -36,6 +38,9 @@ public class GlobalTraceSearchWithGlobalIdTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         getResponseFromEs = PowerMockito.mock(GetResponseFromEs.class);
         Whitebox.setInternalState(GetResponseFromEs.class, "INSTANCE", getResponseFromEs);
     }

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/analysis/NodeCompAnalysisTestCase.java

@@ -21,6 +21,7 @@ import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
 import java.util.List;
+import java.util.TimeZone;
 
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.mock;
@@ -41,6 +42,9 @@ public class NodeCompAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new RecordDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/analysis/NodeMappingDayAnalysisTestCase.java

@@ -23,6 +23,7 @@ import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
 import java.util.List;
+import java.util.TimeZone;
 
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.mock;
@@ -43,6 +44,9 @@ public class NodeMappingDayAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new RecordDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/analysis/NodeMappingHourAnalysisTestCase.java

@@ -21,6 +21,7 @@ import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
 import java.util.List;
+import java.util.TimeZone;
 
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.mock;
@@ -40,6 +41,9 @@ public class NodeMappingHourAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new RecordDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/analysis/NodeMappingMinuteAnalysisTestCase.java

@@ -21,6 +21,7 @@ import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
 import java.util.List;
+import java.util.TimeZone;
 
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.mock;
@@ -40,6 +41,9 @@ public class NodeMappingMinuteAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new RecordDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeCompAggTestCase.java

@@ -22,6 +22,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -39,6 +41,9 @@ public class NodeCompAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeCompSaveTestCase.java

@@ -10,6 +10,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -19,6 +21,9 @@ public class NodeCompSaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new NodeCompSave(NodeCompSave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingDayAggTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -36,6 +38,9 @@ public class NodeMappingDayAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         LocalWorkerContext localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingDaySaveTestCase.java

@@ -9,6 +9,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -18,6 +20,9 @@ public class NodeMappingDaySaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new NodeMappingDaySave(NodeMappingDaySave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingHourAggTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -36,6 +38,9 @@ public class NodeMappingHourAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         LocalWorkerContext localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingHourSaveTestCase.java

@@ -9,6 +9,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -18,6 +20,9 @@ public class NodeMappingHourSaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new NodeMappingHourSave(NodeMappingHourSave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingMinuteAggTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -36,6 +38,9 @@ public class NodeMappingMinuteAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         LocalWorkerContext localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/node/persistence/NodeMappingMinuteSaveTestCase.java

@@ -9,6 +9,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -18,6 +20,9 @@ public class NodeMappingMinuteSaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+        
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new NodeMappingMinuteSave(NodeMappingMinuteSave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/NodeRefResSumGetGroupWithTimeSliceTestCase.java

@@ -22,6 +22,7 @@ import org.powermock.modules.junit4.PowerMockRunner;
 
 import java.util.HashMap;
 import java.util.Map;
+import java.util.TimeZone;
 
 import static org.mockito.Mockito.*;
 
@@ -39,6 +40,9 @@ public class NodeRefResSumGetGroupWithTimeSliceTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         LocalWorkerContext localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/analysis/NodeRefDayAnalysisTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 import static org.powermock.api.mockito.PowerMockito.when;
 
@@ -38,6 +40,9 @@ public class NodeRefDayAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new RecordDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/analysis/NodeRefHourAnalysisTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 import static org.powermock.api.mockito.PowerMockito.when;
 
@@ -38,6 +40,9 @@ public class NodeRefHourAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new RecordDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/analysis/NodeRefMinuteAnalysisTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 import static org.powermock.api.mockito.PowerMockito.when;
 
@@ -38,6 +40,9 @@ public class NodeRefMinuteAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new RecordDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/analysis/NodeRefResSumDayAnalysisTestCase.java

@@ -18,6 +18,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.mock;
 import static org.powermock.api.mockito.PowerMockito.when;
@@ -35,6 +37,9 @@ public class NodeRefResSumDayAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new MetricDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/analysis/NodeRefResSumHourAnalysisTestCase.java

@@ -18,6 +18,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.mock;
 import static org.powermock.api.mockito.PowerMockito.when;
@@ -35,6 +37,9 @@ public class NodeRefResSumHourAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new MetricDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/analysis/NodeRefResSumMinuteAnalysisTestCase.java

@@ -18,6 +18,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.mock;
 import static org.powermock.api.mockito.PowerMockito.when;
@@ -35,6 +37,9 @@ public class NodeRefResSumMinuteAnalysisTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         WorkerRefs workerRefs = mock(WorkerRefs.class);
         answer = new MetricDataAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefDayAggTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -37,6 +39,9 @@ public class NodeRefDayAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefDaySaveTestCase.java

@@ -9,6 +9,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -18,6 +20,9 @@ public class NodeRefDaySaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new NodeRefDaySave(NodeRefDaySave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefHourAggTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -37,6 +39,9 @@ public class NodeRefHourAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefHourSaveTestCase.java

@@ -9,6 +9,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -18,6 +20,9 @@ public class NodeRefHourSaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new NodeRefHourSave(NodeRefHourSave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefMinuteAggTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -37,6 +39,9 @@ public class NodeRefMinuteAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefMinuteSaveTestCase.java

@@ -9,6 +9,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -18,6 +20,9 @@ public class NodeRefMinuteSaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new NodeRefMinuteSave(NodeRefMinuteSave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefResSumDayAggTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -37,6 +39,9 @@ public class NodeRefResSumDayAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefResSumDaySaveTestCase.java

@@ -9,6 +9,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -17,6 +19,9 @@ public class NodeRefResSumDaySaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new NodeRefResSumDaySave(NodeRefResSumDaySave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefResSumHourAggTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -37,6 +39,9 @@ public class NodeRefResSumHourAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefResSumHourSaveTestCase.java

@@ -9,6 +9,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -18,6 +20,9 @@ public class NodeRefResSumHourSaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new NodeRefResSumHourSave(NodeRefResSumHourSave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefResSumMinuteAggTestCase.java

@@ -20,6 +20,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 
 /**
@@ -37,6 +39,9 @@ public class NodeRefResSumMinuteAggTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/noderef/persistence/NodeRefResSumMinuteSaveTestCase.java

@@ -10,6 +10,8 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.TimeZone;
+
 /**
  * @author pengys5
  */
@@ -19,6 +21,9 @@ public class NodeRefResSumMinuteSaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         ClusterWorkerContext cluster = new ClusterWorkerContext(null);
         LocalWorkerContext local = new LocalWorkerContext();
         save = new NodeRefResSumMinuteSave(NodeRefResSumMinuteSave.Role.INSTANCE, cluster, local);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/segment/SegmentPostTestCase.java

@@ -32,6 +32,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.*;
 import static org.mockito.Mockito.when;
 import static org.powermock.api.mockito.PowerMockito.doAnswer;
@@ -55,6 +57,9 @@ public class SegmentPostTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         segmentMock = new SegmentMock();
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
         localWorkerContext = new LocalWorkerContext();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/segment/SegmentTopGetWithGlobalTraceIdTestCase.java

@@ -23,6 +23,7 @@ import org.powermock.modules.junit4.PowerMockRunner;
 
 import java.util.HashMap;
 import java.util.Map;
+import java.util.TimeZone;
 
 import static org.mockito.Mockito.*;
 
@@ -40,6 +41,9 @@ public class SegmentTopGetWithGlobalTraceIdTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         LocalWorkerContext localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/segment/SegmentTopGetWithTimeSliceTestCase.java

@@ -23,6 +23,7 @@ import org.powermock.modules.junit4.PowerMockRunner;
 
 import java.util.HashMap;
 import java.util.Map;
+import java.util.TimeZone;
 
 import static org.mockito.Mockito.*;
 
@@ -40,6 +41,9 @@ public class SegmentTopGetWithTimeSliceTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         LocalWorkerContext localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/segment/persistence/SegmentCostSaveTestCase.java

@@ -25,6 +25,7 @@ import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
 import java.util.List;
+import java.util.TimeZone;
 
 import static org.powermock.api.mockito.PowerMockito.when;
 
@@ -44,6 +45,9 @@ public class SegmentCostSaveTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         mockEsBulkClient.createMock();
 
         saveToEsSourceAnswer = new SaveToEsSourceAnswer();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/segment/persistence/SegmentExceptionSaveTestCase.java

@@ -27,6 +27,7 @@ import org.powermock.modules.junit4.PowerMockRunner;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.TimeZone;
 
 import static org.powermock.api.mockito.PowerMockito.when;
 
@@ -47,6 +48,9 @@ public class SegmentExceptionSaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         mockEsBulkClient.createMock();
 
         saveToEsSource = new SaveToEsSource();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/segment/persistence/SegmentSaveTestCase.java

@@ -21,6 +21,8 @@ import org.powermock.core.classloader.annotations.PowerMockIgnore;
 import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 
+import java.util.TimeZone;
+
 import static org.powermock.api.mockito.PowerMockito.when;
 
 /**
@@ -37,6 +39,9 @@ public class SegmentSaveTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         mockEsBulkClient.createMock();
 
         saveToEsSource = new SaveToEsSource();

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/span/SpanGetWithIdTestCase.java

@@ -22,6 +22,7 @@ import org.powermock.modules.junit4.PowerMockRunner;
 
 import java.util.HashMap;
 import java.util.Map;
+import java.util.TimeZone;
 
 import static org.mockito.Mockito.*;
 
@@ -39,6 +40,9 @@ public class SpanGetWithIdTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         LocalWorkerContext localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/span/persistence/SpanSearchWithIdTestCase.java

@@ -21,6 +21,8 @@ import org.powermock.core.classloader.annotations.PrepareForTest;
 import org.powermock.modules.junit4.PowerMockRunner;
 import org.powermock.reflect.Whitebox;
 
+import java.util.TimeZone;
+
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 
@@ -36,6 +38,9 @@ public class SpanSearchWithIdTestCase {
 
     @Before
     public void init() {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         getResponseFromEs = PowerMockito.mock(GetResponseFromEs.class);
         Whitebox.setInternalState(GetResponseFromEs.class, "INSTANCE", getResponseFromEs);
     }

skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/tracedag/TraceDagGetWithTimeSliceTestCase.java

@@ -24,6 +24,7 @@ import org.powermock.modules.junit4.PowerMockRunner;
 
 import java.util.HashMap;
 import java.util.Map;
+import java.util.TimeZone;
 
 import static org.mockito.Mockito.*;
 
@@ -40,6 +41,9 @@ public class TraceDagGetWithTimeSliceTestCase {
 
     @Before
     public void init() throws Exception {
+        System.setProperty("user.timezone", "UTC");
+        TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+
         clusterWorkerContext = PowerMockito.mock(ClusterWorkerContext.class);
 
         LocalWorkerContext localWorkerContext = PowerMockito.mock(LocalWorkerContext.class);