You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@gobblin.apache.org by "Zihan Li (Jira)" <ji...@apache.org> on 2021/01/26 21:05:00 UTC

[jira] [Commented] (GOBBLIN-1359) Fix the error that IOException thrown by writer be swallowed by Reactivex

    [ 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)