Actually it should not be, !this.inQueue.isEmpty(). It should be, datum != null
On Wed, May 14, 2014 at 5:19 PM, Ryan Ebanks <[email protected]> wrote: > I can't seem to log into Jira at the moment create the bug ticket. But > this bug breaks the local runtime. > > A recent commit seems to have introduced this. Its a simple fix, but the > while statement on line 70 of StreamsProviderTask should read > while(this.keepRunning.get() || !this.inQueue.isEmpty()) { > > And line 75 in StreamsPersist writer task should read > while(this.keepRunning.get() || !this.inQueue.isEmpty()) { > > > Both lines are missing the !this.inQueue.isEmpty() statement. This causes > tasks to be shutdown before data is processed and data is orphaned in the > stream. In the worst case only the provider runs. > > -Ryan Ebanks >
