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) {