Skip to content

Commit aa2b112

Browse files
committed
remove dead code
1 parent abf0f97 commit aa2b112

File tree

1 file changed

+0
-13
lines changed

1 file changed

+0
-13
lines changed

server/src/main/java/org/elasticsearch/upgrades/SystemIndexMigrator.java

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -468,19 +468,6 @@ private void migrateSingleIndex(ClusterState clusterState, Consumer<BulkByScroll
468468
}
469469
}
470470

471-
// ActionListener<BulkByScrollResponse> innerListener = ActionListener.wrap(listener::accept, this::markAsFailed);
472-
private <T> void retryAfterFailureHandler(
473-
ActionListener<T> listener,
474-
Consumer<ActionListener<T>> retryableAction,
475-
Consumer<Exception> failureHandler
476-
) {
477-
retryableAction.accept(ActionListener.wrap(listener::onResponse, e -> {
478-
logger.error("error occurred while executing retryable action", e);
479-
failureHandler.accept(e);
480-
listener.onFailure(e);
481-
}));
482-
}
483-
484471
private void createIndex(SystemIndexMigrationInfo migrationInfo, ActionListener<ShardsAcknowledgedResponse> listener) {
485472
logger.info("creating new system index [{}] from feature [{}]", migrationInfo.getNextIndexName(), migrationInfo.getFeatureName());
486473

0 commit comments

Comments
 (0)