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: [email protected] With regards, Apache Git Services
