Hi Qi, >> 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
Are you seeing the *close()* method hang? SystemProducer.*close* is a synchronous operation, and will block for the *close* method to finish. Best, Jagadish On Wed, Aug 23, 2017 at 11:17 PM, 舒琦 <sh...@eefung.com> wrote: > 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 > > -- Jagadish V, Graduate Student, Department of Computer Science, Stanford University
