opensearch-java: fix the search_after values sent by HybridSpout

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) {}
 }

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);
             }
         }