wuchong commented on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-616655734
Thanks @godfreyhe and @libenchao for the reviewing. I have addressed the comments. I would appreciate if @beyond1920 could help to review the TopN operator and tests change, because I changed the logic of TopN to always produce UPDATE_BEFORE and UPDATE_AFTER for primary key (partitionKey+rownum). ---------------------------------------------------------------- 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]
