Hey Ankur, If the output after cancelling the job is correct, I assume the changes haven't been flushed to disk before. For further investigation, could you share some code with us?
Cheers, Max On Wed, Feb 24, 2016 at 8:54 PM, Ankur Sharma <an...@stud.uni-saarland.de> wrote: > Hey, > > I am trying to use ContinuousProcessingTimeTrigger which fires TimeWindow > every 5 seconds. But even though I explicitly state that the output of > apply() method should be dumped to file every 10 seconds, I don’t see the > file getting appended. When I cancel the job, I see all the dumps which are > not visible earlier. > > I also tried writing the result to socket but it also has same effect. > > Please help. > > Best, > Ankur Sharma > Information Systems Group > 3.15 E1.1 Universität des Saarlandes > 66123, Saarbrücken Germany > Email: ankur.sha...@mpi-inf.mpg.de > an...@stud.uni-saarland.de
