[ 
https://issues.apache.org/jira/browse/GOBBLIN-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272416#comment-17272416
 ] 

Zihan Li commented on GOBBLIN-1359:
-----------------------------------

After the first change, we still see the job hang. And after investigating, we 
see the ConnectableFlowable.connect() which is supposed to return immediately 
does not return even the flowable is finished. So the solution will be make the 
call in another thread, and let the sequence code get executed which is to 
periodically check whether the job finished.

> Fix the error that IOException thrown by writer be swallowed by Reactivex 
> --------------------------------------------------------------------------
>
>                 Key: GOBBLIN-1359
>                 URL: https://issues.apache.org/jira/browse/GOBBLIN-1359
>             Project: Apache Gobblin
>          Issue Type: Task
>            Reporter: Zihan Li
>            Priority: Major
>          Time Spent: 1.5h
>  Remaining Estimate: 0h
>
> we have a bug in Reactivex code which swallows the exception and leaves the 
> task hanging



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to