[GitHub] [pulsar] subbu107 opened a new issue #5866: Flink event time based windowing functions not working with pulsar

[GitBox <gi...@apache.org>]

subbu107 opened a new issue #5866: Flink event time based windowing functions not working with pulsar
URL: https://github.com/apache/pulsar/issues/5866
 
 
   We are using Event time based windowing functions in Flink. The source is a partitioned Pulsar topic . The timestamp field is decided by the processing function in flink.
   The event time is extracted from the message by attaching a TimeStampExtractor to the stream which extracts time from the message 
   
   #### Expected behavior
   
   The window should get triggered once the watermark is crossed.
   
   #### Actual behavior
   
   We noticed that the window does not triggered though the watermark is crossed.
   
   #### Steps to reproduce
   
   Attaching the sample code. 
   [pulsar-flink-preload-new.zip](https://github.com/apache/pulsar/files/3968426/pulsar-flink-preload-new.zip)
   
   #### System configuration
   **Pulsar version**: 2.4.2
   Flink version : 1.8.2

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services