On Fri, Jan 20, 2017 at 12:47 PM, Raghu Angadi <rang...@google.com> wrote: > > On Fri, Jan 20, 2017 at 11:45 AM, Amit Sela <amitsel...@gmail.com> wrote: > >> The WakeupException is being logged and not thrown (it is OK since the >> reader was closed due to end-of-microbatch), > > > To avoid such confusion, it is better for KafkaIO not to log it at all, > especially if it is already closing (usual case). I will send a PR. >
A small fix : https://github.com/apache/beam/pull/1804
