[beam] branch master updated: BEAM-14187 Fix NPE (#17454)

[lcwik]

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 74d8fd54c9e BEAM-14187 Fix NPE (#17454)
74d8fd54c9e is described below

commit 74d8fd54c9e360ca4360fdc42f1c4c2a47cff9b9
Author: Minbo Bae <49642083+baemi...@users.noreply.github.com>
AuthorDate: Tue Apr 26 19:34:34 2022 -0700

    BEAM-14187 Fix NPE (#17454)
---
 .../java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java
 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java
index bcf7a18b0ec..a01714bfff4 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java
@@ -551,7 +551,8 @@ public class IsmReaderImpl<V> extends IsmReader<V> {
               resourceId);
 
           try {
-            SeekableByteChannel rawChannel = 
openIfNeeded(Optional.of(rawChannelReference.get()));
+            SeekableByteChannel rawChannel =
+                openIfNeeded(Optional.fromNullable(rawChannelReference.get()));
             rawChannelReference.set(rawChannel);
             return readIndexBlockForShard(resourceId, shardWithIndex, 
startOfNextBlock, rawChannel);
           } catch (IOException e) {