check for null etag

Author: ahmarsuhail

hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/impl/streams/AnalyticsStream.java

@@ -203,14 +203,18 @@ private void onReadFailure(IOException ioe) throws IOException {
   }
 
   private OpenStreamInformation buildOpenStreamInformation(ObjectReadParameters parameters) {
-    OpenStreamInformation openFileInformation = OpenStreamInformation.builder().inputPolicy(mapS3AInputPolicyToAAL(parameters.getContext()
-        .getInputPolicy()))
-        .objectMetadata(ObjectMetadata.builder()
-            .contentLength(parameters.getObjectAttributes().getLen())
-            .etag(parameters.getObjectAttributes().getETag()).build())
-        .build();
-
-    return openFileInformation;
+    OpenStreamInformation.OpenStreamInformationBuilder openStreamInformationBuilder =
+        OpenStreamInformation.builder()
+            .inputPolicy(mapS3AInputPolicyToAAL(parameters.getContext()
+            .getInputPolicy()));
+
+    if (parameters.getObjectAttributes().getETag() != null) {
+      openStreamInformationBuilder.objectMetadata(ObjectMetadata.builder()
+          .contentLength(parameters.getObjectAttributes().getLen())
+          .etag(parameters.getObjectAttributes().getETag()).build());
+    }
+
+    return openStreamInformationBuilder.build();
   }
 
   /**