Skip to content

Commit

Permalink
spotlessApply
Browse files Browse the repository at this point in the history
Signed-off-by: Jackie Han <[email protected]>
  • Loading branch information
jackiehanyang committed Oct 6, 2023
1 parent 13ec2f8 commit 5e1fe8e
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -271,7 +271,9 @@ public static Template parse(XContentParser parser) throws IOException {
resourcesCreated.put(resourcesCreatedField, parseStringToStringMap(parser));
break;
default:
throw new IOException("Unable to parse field [" + resourcesCreatedField + "] in a resources_created object.");
throw new IOException(
"Unable to parse field [" + resourcesCreatedField + "] in a resources_created object."
);
}
}
break;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -126,7 +126,6 @@ public void initIndexIfAbsent(FlowFrameworkIndex index, ActionListener<Boolean>
String indexName = index.getIndexName();
String mapping = index.getMapping();


try (ThreadContext.StoredContext threadContext = client.threadPool().getThreadContext().stashContext()) {
ActionListener<Boolean> internalListener = ActionListener.runBefore(listener, () -> threadContext.restore());
if (!clusterService.state().metadata().hasIndex(indexName)) {
Expand Down Expand Up @@ -178,7 +177,7 @@ public void initIndexIfAbsent(FlowFrameworkIndex index, ActionListener<Boolean>
}));
} else {
internalListener.onFailure(
new FlowFrameworkException("Failed to update index: " + indexName, INTERNAL_SERVER_ERROR)
new FlowFrameworkException("Failed to update index: " + indexName, INTERNAL_SERVER_ERROR)
);
}
}, exception -> {
Expand Down

0 comments on commit 5e1fe8e

Please sign in to comment.