kennknowles commented on PR #30545: URL: https://github.com/apache/beam/pull/30545#issuecomment-1998810708
The new translation for `Redistribute.arbitrarily()` in the portable batch Flink runner caused a problem. I think there may be a bug in how composites are implemented because it still had transforms that consumed PCollections that had been eliminated. It is feature creep anyhow. Just translating `Redistribute.byKey()` brings it to parity. So I removed the special translation in the portable runner. Since it passed tests in the non-portable runner, I left it there. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
