Skip to content

Commit e9cbfa9

Browse files
authored
enable pit 4 serverless (#6050)
Signed-off-by: Yui Numazawa <[email protected]>
1 parent 7d75fc0 commit e9cbfa9

File tree

1 file changed

+2
-3
lines changed
  • data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/source/opensearch/worker/client

1 file changed

+2
-3
lines changed

data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/source/opensearch/worker/client/SearchAccessorStrategy.java

100644100755
Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -149,9 +149,8 @@ private SearchAccessor createSearchAccessorForServerlessCollection(final PluginC
149149
return new OpenSearchAccessor(clientRefresher,
150150
SearchContextType.NONE);
151151
} else {
152-
if (SearchContextType.POINT_IN_TIME.equals(openSearchSourceConfiguration.getSearchConfiguration().getSearchContextType()) ||
153-
SearchContextType.SCROLL.equals(openSearchSourceConfiguration.getSearchConfiguration().getSearchContextType())) {
154-
throw new InvalidPluginConfigurationException("A search_context_type of point_in_time or scroll is not supported for serverless collections");
152+
if ( SearchContextType.SCROLL.equals(openSearchSourceConfiguration.getSearchConfiguration().getSearchContextType())) {
153+
throw new InvalidPluginConfigurationException("A search_context_type of scroll is not supported for serverless collections");
155154
}
156155

157156
LOG.info("Using search_context_type set in the config: '{}'", openSearchSourceConfiguration.getSearchConfiguration().getSearchContextType().toString().toLowerCase());

0 commit comments

Comments
 (0)