diff --git a/external/opensearch-java/src/main/java/org/apache/stormcrawler/opensearch/persistence/AggregationSpout.java b/external/opensearch-java/src/main/java/org/apache/stormcrawler/opensearch/persistence/AggregationSpout.java
index 84d46e950..a6272f368 100644
--- a/external/opensearch-java/src/main/java/org/apache/stormcrawler/opensearch/persistence/AggregationSpout.java
+++ b/external/opensearch-java/src/main/java/org/apache/stormcrawler/opensearch/persistence/AggregationSpout.java
@@ -423,5 +423,10 @@ protected void handleResponse(SearchResponse<JsonData> response) {
         markQueryReceivedNow();
     }
 
+    /**
+     * Receives the sort values of the last hit returned for a bucket, as the {@link FieldValue}
+     * instances of the client. Subclasses can pass them to {@code search_after} to read the bucket
+     * from that position.
+     */
     protected void sortValuesForKey(String key, Object[] sortValues) {}
 }
diff --git a/external/opensearch-java/src/main/java/org/apache/stormcrawler/opensearch/persistence/HybridSpout.java b/external/opensearch-java/src/main/java/org/apache/stormcrawler/opensearch/persistence/HybridSpout.java
index 17a5575b6..b3301e5c3 100644
--- a/external/opensearch-java/src/main/java/org/apache/stormcrawler/opensearch/persistence/HybridSpout.java
+++ b/external/opensearch-java/src/main/java/org/apache/stormcrawler/opensearch/persistence/HybridSpout.java
@@ -142,7 +142,7 @@ public void emptyQueue(String queueName) {
         Object[] searchAfterValues = searchAfterCache.getIfPresent(queueName);
         if (searchAfterValues != null) {
             for (Object sav : searchAfterValues) {
-                requestBuilder.searchAfter(FieldValue.of(sav.toString()));
+                requestBuilder.searchAfter((FieldValue) sav);
             }
         }