From 2441eab5c4f0ed13cf38c686f8bf2f44f9fd3e5a Mon Sep 17 00:00:00 2001 From: Yui Numazawa Date: Mon, 1 Sep 2025 13:28:33 +0000 Subject: [PATCH] enable pit 4 serverless Signed-off-by: Yui Numazawa --- .../opensearch/worker/client/SearchAccessorStrategy.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) mode change 100644 => 100755 data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/source/opensearch/worker/client/SearchAccessorStrategy.java diff --git a/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/source/opensearch/worker/client/SearchAccessorStrategy.java b/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/source/opensearch/worker/client/SearchAccessorStrategy.java old mode 100644 new mode 100755 index 6a3b1fa609..f45a5c23c5 --- a/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/source/opensearch/worker/client/SearchAccessorStrategy.java +++ b/data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/source/opensearch/worker/client/SearchAccessorStrategy.java @@ -149,9 +149,8 @@ private SearchAccessor createSearchAccessorForServerlessCollection(final PluginC return new OpenSearchAccessor(clientRefresher, SearchContextType.NONE); } else { - if (SearchContextType.POINT_IN_TIME.equals(openSearchSourceConfiguration.getSearchConfiguration().getSearchContextType()) || - SearchContextType.SCROLL.equals(openSearchSourceConfiguration.getSearchConfiguration().getSearchContextType())) { - throw new InvalidPluginConfigurationException("A search_context_type of point_in_time or scroll is not supported for serverless collections"); + if ( SearchContextType.SCROLL.equals(openSearchSourceConfiguration.getSearchConfiguration().getSearchContextType())) { + throw new InvalidPluginConfigurationException("A search_context_type of scroll is not supported for serverless collections"); } LOG.info("Using search_context_type set in the config: '{}'", openSearchSourceConfiguration.getSearchConfiguration().getSearchContextType().toString().toLowerCase());