Fix wrong most recent date was set (#1126)

Signed-off-by: Chun Han Hsiao <[email protected]>
apache · Nov 22, 2023 · 3bd2d7a · 3bd2d7a
1 parent 857bf09
commit 3bd2d7a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/.../main/java/com/digitalpebble/stormcrawler/elasticsearch/persistence/AggregationSpout.java b/.../main/java/com/digitalpebble/stormcrawler/elasticsearch/persistence/AggregationSpout.java
@@ -301,7 +301,7 @@ public void onResponse(SearchResponse response) {
         // within n mins in which case we'll keep it
         if (mostRecentDateFound != null && recentDateIncrease >= 0) {
             Calendar potentialNewDate = Calendar.getInstance();
-            potentialNewDate.setTimeInMillis(mostRecentDateFound.getEpochSecond());
+            potentialNewDate.setTimeInMillis(mostRecentDateFound.toEpochMilli());
             potentialNewDate.add(Calendar.MINUTE, recentDateIncrease);
             Date oldDate = null;
             // check boundaries

diff --git a/...src/main/java/com/digitalpebble/stormcrawler/opensearch/persistence/AggregationSpout.java b/...src/main/java/com/digitalpebble/stormcrawler/opensearch/persistence/AggregationSpout.java
@@ -304,7 +304,7 @@ public void onResponse(SearchResponse response) {
         // within n mins in which case we'll keep it
         if (mostRecentDateFound != null && recentDateIncrease >= 0) {
             Calendar potentialNewDate = Calendar.getInstance();
-            potentialNewDate.setTimeInMillis(mostRecentDateFound.getEpochSecond());
+            potentialNewDate.setTimeInMillis(mostRecentDateFound.toEpochMilli());
             potentialNewDate.add(Calendar.MINUTE, recentDateIncrease);
             Date oldDate = null;
             // check boundaries