You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2022/04/27 02:34:42 UTC
[beam] branch master updated: BEAM-14187 Fix NPE (#17454)
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 <49...@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) {