You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2019/12/25 05:01:48 UTC

[GitHub] [pulsar] subbu107 commented on issue #5866: Flink event time based windowing functions not working with pulsar

subbu107 commented on issue #5866: Flink event time based windowing functions not working with pulsar
URL: https://github.com/apache/pulsar/issues/5866#issuecomment-568838901
 
 
   Hi @yjshen , I did also try with default trigger, it still didn't work.
   
   Basically it can be simulated in the following way :
    - set flink env parallelism to 4 
    - set consumerConfigurationData.setSubscriptionType(SubscriptionType.Failover); .
    - number of partitions of source/ sink topics = 2
    - If I increase the number of partitions on  my source and sink topics to 4, it works. Basically if I have fewer partitions than the parallelism that I have set in flink, it stops working.
    
    
    - when I set 
    consumerConfigurationData.setSubscriptionType(SubscriptionType.Shared);, it always works.
   However, since we want to maintain processing order, we want to use SubscriptionType.Failover
   
   
   I will attach the logs shortly

----------------------------------------------------------------
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