You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Ankit Jhalaria (Jira)" <ji...@apache.org> on 2019/09/23 17:44:00 UTC
[jira] [Created] (BEAM-8300) KinesisIO.write causes NPE as the
producer is null
Ankit Jhalaria created BEAM-8300:
------------------------------------
Summary: KinesisIO.write causes NPE as the producer is null
Key: BEAM-8300
URL: https://issues.apache.org/jira/browse/BEAM-8300
Project: Beam
Issue Type: Bug
Components: io-java-kinesis
Affects Versions: 2.15.0
Reporter: Ankit Jhalaria
Assignee: Ankit Jhalaria
Fix For: Not applicable
While using KinesisIO.write(), we encountered a NPE with the following stack trace
```java
org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper.run(UnboundedSourceWrapper.java:297)\n\tat org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:93)\n\tat org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)\n\tat org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:97)\n\tat org.apache.flink.streaming.runtime.tasks.StoppableSourceStreamTask.run(StoppableSourceStreamTask.java:45)\n\tat org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)\n\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)\n\tat java.lang.Thread.run(Thread.java:748)\nCaused by: java.lang.NullPointerException: null\n\tat org.apache.beam.sdk.io.kinesis.KinesisIO$Write$KinesisWriterFn.flushBundle(KinesisIO.java:685)\n\tat org.apache.beam.sdk.io.kinesis.KinesisIO$Write$KinesisWriterFn.finishBundle(KinesisIO.java:669)
```
--
This message was sent by Atlassian Jira
(v8.3.4#803005)