flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ankur Sharma <an...@stud.uni-saarland.de>
Subject Flink Streaming - WriteAsText
Date Wed, 24 Feb 2016 19:54:39 GMT
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.sharma@mpi-inf.mpg.de <mailto:ankur.sharma@mpi-inf.mpg.de> 
            ankur@stud.uni-saarland.de <mailto:ankur@stud.uni-saarland.de>
Mime
View raw message