Question about stop in SystemProducer

[舒琦]

Hi,

        I write a SystemProducer for HDFS and everything is fine. When samza 
job is shutdown, the stop method in SystemProducer is called, but the close 
files operation(may need some time, there may be cache data to be flushed) in 
stop method is not executed completely.

        How can I resolve this problem?

        Thanks!

————————
Qi Shu