Your understanding is correct: Punctuate is not triggered base on wall-clock time, but based in internally tracked "stream time" that is derived from TimestampExtractor. Even if you use WallclockTimestampExtractor, "stream time" is only advance if there are input records.
Not sure why punctuate() is not triggered as you say that you do have arriving data. Can you share your code? -Matthias On 11/23/16 4:48 AM, shahab wrote: > Hello, > > I am using low level processor and I set the context.schedule(10000), > assuming that punctuate() method is invoked every 10 sec . > I have set > configProperties.put(StreamsConfig.TIMESTAMP_EXTRACTOR_CLASS_CONFIG, > WallclockTimestampExtractor.class.getCanonicalName()) ) > > Although data is keep coming to the topology (as I have logged the incoming > tuples to process() ), punctuate() is never executed. > > What I am missing? > > best, > Shahab >
signature.asc
Description: OpenPGP digital signature
