Skip to content

Commit cc0aeb9

Browse files
committed
limit reason message
1 parent 4eca23f commit cc0aeb9

File tree

1 file changed

+12
-4
lines changed

1 file changed

+12
-4
lines changed

server/src/main/java/org/elasticsearch/action/admin/indices/rollover/TransportRolloverAction.java

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@
3434
import org.elasticsearch.cluster.routing.allocation.AllocationService;
3535
import org.elasticsearch.cluster.service.ClusterService;
3636
import org.elasticsearch.common.Priority;
37+
import org.elasticsearch.common.Strings;
3738
import org.elasticsearch.common.inject.Inject;
3839
import org.elasticsearch.common.unit.ByteSizeValue;
3940
import org.elasticsearch.core.Nullable;
@@ -101,10 +102,17 @@ public TransportRolloverAction(
101102
builder.failure(task, e);
102103
}
103104
}
104-
String reason = "bulk rollover ["
105-
+ tasks.stream().map(t -> t.sourceIndex.get() + "->" + t.rolloverIndex.get()).collect(Collectors.joining())
106-
+ "]";
107-
state = allocationService.reroute(state, reason);
105+
106+
var reason = new StringBuilder();
107+
Strings.collectionToDelimitedStringWithLimit(
108+
(Iterable<String>) () -> tasks.stream().map(t -> t.sourceIndex.get() + "->" + t.rolloverIndex.get()).iterator(),
109+
",",
110+
"bulk rollover [",
111+
"]",
112+
1024,
113+
reason
114+
);
115+
state = allocationService.reroute(state, reason.toString());
108116
return builder.build(state);
109117
};
110118
}

0 commit comments

Comments
 (0)