You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flume.apache.org by "gonglinglei (JIRA)" <ji...@apache.org> on 2018/01/24 05:08:00 UTC

[jira] [Updated] (FLUME-3215) abortRemainingTxns when txnBatch is already closed

     [ https://issues.apache.org/jira/browse/FLUME-3215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

gonglinglei updated FLUME-3215:
-------------------------------
    Component/s: Sinks+Sources

> abortRemainingTxns when txnBatch is already closed
> --------------------------------------------------
>
>                 Key: FLUME-3215
>                 URL: https://issues.apache.org/jira/browse/FLUME-3215
>             Project: Flume
>          Issue Type: Bug
>          Components: Sinks+Sources
>            Reporter: gonglinglei
>            Priority: Major
>
> using hive sink in hive version greater than 2.0.0, when write to a timeouted txn, it will mark the whole txnBatch as dead, and doing abortRemaingingTxns in a closed txnBatch is apparently illegal
>  
> TransactionBatch in version 1.0.0 didn't provide the close check, but I think it can still cause HiveWriter close error maybe as a StreamingException, so my suggestion is to upgrade hive api version to 2.0.0, and add close check in abortRemaingingTxns method



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@flume.apache.org
For additional commands, e-mail: issues-help@flume.apache.org