Skip to content

Commit 9fa0078

Browse files
Saurabh DubeySaurabh Dubey
authored andcommitted
Change TimeZone offset
1 parent f7a95b9 commit 9fa0078

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

pinot-common/src/main/java/org/apache/pinot/common/minion/TaskGeneratorMostRecentRunInfo.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import com.google.common.annotations.VisibleForTesting;
2323
import java.time.Instant;
2424
import java.time.OffsetDateTime;
25-
import java.time.ZoneId;
2625
import java.time.ZoneOffset;
2726
import java.util.ArrayList;
2827
import java.util.Collections;
@@ -71,7 +70,7 @@ public String getTaskType() {
7170
public TreeMap<String, String> getMostRecentErrorRunMessages() {
7271
TreeMap<String, String> result = new TreeMap<>();
7372
_mostRecentErrorRunMessages.forEach((timestamp, error) -> result.put(
74-
OffsetDateTime.ofInstant(Instant.ofEpochMilli(timestamp), ZoneId.of(ZoneOffset.UTC.toString())).toString(),
73+
OffsetDateTime.ofInstant(Instant.ofEpochMilli(timestamp), ZoneOffset.UTC).toString(),
7574
error));
7675
return result;
7776
}
@@ -93,7 +92,7 @@ public void addErrorRunMessage(long ts, String message) {
9392
*/
9493
public List<String> getMostRecentSuccessRunTS() {
9594
return _mostRecentSuccessRunTS.stream().map(
96-
timestamp -> OffsetDateTime.ofInstant(Instant.ofEpochMilli(timestamp), ZoneId.of(ZoneOffset.UTC.toString()))
95+
timestamp -> OffsetDateTime.ofInstant(Instant.ofEpochMilli(timestamp), ZoneOffset.UTC)
9796
.toString())
9897
.collect(Collectors.toList());
9998
}

0 commit comments

Comments
 (0)