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