This is an automated email from the ASF dual-hosted git repository. srdo pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/master by this push: new 362b3b6 [STORM-3375] change Date.getTime() to System.currentTimeMillis() new b48e105 Merge branch 'STORM-3375' of https://github.com/bd2019us/storm into asfgit-master 362b3b6 is described below commit 362b3b6a41c784eccc2f9362b403c45623a3ea51 Author: bd2019us <bd201...@126.com> AuthorDate: Thu Apr 11 23:40:58 2019 -0500 [STORM-3375] change Date.getTime() to System.currentTimeMillis() --- .../org/apache/storm/hive/bolt/mapper/DelimitedRecordHiveMapper.java | 3 +-- .../java/org/apache/storm/hive/bolt/mapper/JsonRecordHiveMapper.java | 3 +-- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/DelimitedRecordHiveMapper.java b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/DelimitedRecordHiveMapper.java index d67ec67..f6e3612 100644 --- a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/DelimitedRecordHiveMapper.java +++ b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/DelimitedRecordHiveMapper.java @@ -132,8 +132,7 @@ public class DelimitedRecordHiveMapper implements HiveMapper { } private String getPartitionsByTimeFormat() { - Date d = new Date(); - return parseDate.format(d.getTime()); + return parseDate.format(System.currentTimeMillis()); } @VisibleForTesting diff --git a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/JsonRecordHiveMapper.java b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/JsonRecordHiveMapper.java index 3a43b7c..59c1bb7 100644 --- a/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/JsonRecordHiveMapper.java +++ b/external/storm-hive/src/main/java/org/apache/storm/hive/bolt/mapper/JsonRecordHiveMapper.java @@ -119,7 +119,6 @@ public class JsonRecordHiveMapper implements HiveMapper { } private String getPartitionsByTimeFormat() { - Date d = new Date(); - return parseDate.format(d.getTime()); + return parseDate.format(System.currentTimeMillis()); } }