Apply suggestions from code review

Co-authored-by: Szymon Bialkowski <[email protected]>

Author: lukewhiting

server/src/main/java/org/elasticsearch/action/bulk/TransportAbstractBulkAction.java

@@ -413,16 +413,16 @@ private void applyPipelinesAndDoInternalExecute(
         for (StreamType streamType : enabledStreamTypes) {
             for (int i = 0; i < bulkRequest.requests.size(); i++) {
                 DocWriteRequest<?> req = bulkRequestModifier.bulkRequest.requests.get(i);
-                String prefix = streamType.getStreamName() + ".";
+                String StreamTypePrefix = streamType.getStreamName() + ".";
 
                 if (req instanceof IndexRequest ir && ir.index().startsWith(prefix) && ir.isPipelineResolved() == false) {
                     IllegalArgumentException e = new IllegalArgumentException(
                         "Direct writes to child streams are prohibited. Index directly into the ["
                             + streamType.getStreamName()
                             + "] stream instead"
                     );
-                    Boolean failureStore = resolveFailureStore(req.index(), projectMetadata, threadPool.absoluteTimeInMillis());
-                    if (failureStore != null && failureStore) {
+                    Boolean failureStoreEnabled = resolveFailureStore(req.index(), projectMetadata, threadPool.absoluteTimeInMillis());
+                    if (Boolean.TRUE.equals(failureStore)) {
                         bulkRequestModifier.markItemForFailureStore(i, req.index(), e);
                     } else {
                         bulkRequestModifier.markItemAsFailed(i, e, IndexDocFailureStoreStatus.NOT_ENABLED);