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: [email protected] <mailto:[email protected]> [email protected] <mailto:[email protected]>
smime.p7s
Description: S/MIME cryptographic signature
