[
https://issues.apache.org/jira/browse/STORM-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Wang updated STORM-2198:
----------------------------
Description:
I have a _HdfsBolt_ with _TimedRotationPolicy_ and _MoveFileAction_. I found
the bolt didn't move files when I stopped the HdfsBolt, then _RotationPolicy_
was not triggered,
Look at the code, the _rotateOutputFile_ method just be called when
_RotationPolicy_ is triggered or _writer.needsRotation_. I will add some logic
in _cleanup_ method.
was:
I have a _HdfsBolt_ with _TimedRotationPolicy_ and _MoveFileAction_. I find the
bolt don't move file when I stop the HdfsBolt and then _RotationPolicy_ is not
triggered,
Look at the code, the _rotateOutputFile_ method just be called when
_RotationPolicy_ is triggered or _writer.needsRotation_. I will add some logic
in _cleanup_ method.
> perform RotationAction when stopping HdfsBolt
> ---------------------------------------------
>
> Key: STORM-2198
> URL: https://issues.apache.org/jira/browse/STORM-2198
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-hdfs
> Reporter: Xin Wang
> Assignee: Xin Wang
>
> I have a _HdfsBolt_ with _TimedRotationPolicy_ and _MoveFileAction_. I found
> the bolt didn't move files when I stopped the HdfsBolt, then _RotationPolicy_
> was not triggered,
> Look at the code, the _rotateOutputFile_ method just be called when
> _RotationPolicy_ is triggered or _writer.needsRotation_. I will add some
> logic in _cleanup_ method.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
