Ryan Ebanks created STREAMS-80:
----------------------------------
Summary: StreamsProcressorTask and StreamsPersistWriterTask are
BROKEN
Key: STREAMS-80
URL: https://issues.apache.org/jira/browse/STREAMS-80
Project: Streams
Issue Type: Bug
Reporter: Ryan Ebanks
Priority: Critical
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() || datum != null) {
And line 75 in StreamsPersist writer task should read
while(this.keepRunning.get() || datum != null) {
Both lines are missing the datum != null 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.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
