syhily commented on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-960414913
> > @wsz94 I have created a patch by using `consumer.receive(timeout, timeunit)`. Can you confirm this fix works? > > [gist.github.com/syhily/fbf47b581257f94869c59660002bbfa1](https://gist.github.com/syhily/fbf47b581257f94869c59660002bbfa1)_ (too large to embed)_ > > You can checkout a brand new branch and run the command below: > > ```shell > > curl https://gist.githubusercontent.com/syhily/fbf47b581257f94869c59660002bbfa1/raw/072f26a8946a753b41be832c54f1c54f342a41e8/FLINK-24733.patch | git apply > > ``` > > Thanks. According to your suggestion, I modified the commit to fix the `PulsarOrderedPartitionSplitReader ` too. Could you help me to confirm this PR? We may need some tests to confirm this issue has been fixed. -- 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. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
