xccui commented on issue #6003: [FLINK-9289][Dataset] Parallelism of generated operators should have max parallelism of input URL: https://github.com/apache/flink/pull/6003#issuecomment-411472064 Thanks for the explanation @fhueske. It's true that the key extractors cannot be chained for a union operator unless we manually specify them for inputs (with different parallelisms), specifically. Maybe it's worth to give this operator "special treatment" 😄I'll update the PR according to your suggestion. Thanks, Xingcan
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on 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
