Skip to content

Commit 6abdeaf

Browse files
committed
When serverless mode is enabled, write to the single endpoint
1 parent caaeb50 commit 6abdeaf

1 file changed

Lines changed: 10 additions & 0 deletions

File tree

mr/src/main/java/org/opensearch/hadoop/rest/RestService.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -657,6 +657,16 @@ private static RestRepository initSingleIndex(Settings settings, long currentIns
657657
}
658658

659659
RestRepository repository = new RestRepository(settings);
660+
661+
if (settings.getServerlessMode()) {
662+
String node = SettingsUtils.getPinnedNode(settings);
663+
if (log.isDebugEnabled()) {
664+
log.debug(String.format("Partition writer instance [%s] assigned to [%s]", currentInstance, node));
665+
}
666+
667+
return repository;
668+
}
669+
660670
// create the index if needed
661671
if (repository.touch()) {
662672
if (repository.waitForYellow()) {

0 commit comments

Comments
 (0)