streams-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ryan Ebanks (JIRA)" <j...@apache.org>
Subject [jira] [Created] (STREAMS-80) StreamsProcressorTask and StreamsPersistWriterTask are BROKEN
Date Fri, 16 May 2014 10:31:21 GMT
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)

Mime
View raw message