[GitHub] [flink] pltbkd commented on pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

2022-02-10 Thread GitBox
pltbkd commented on pull request #18699: URL: https://github.com/apache/flink/pull/18699#issuecomment-1035839159 Noted. Thanks @dmvk and @zentol for the review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [flink] pltbkd commented on pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

2022-02-10 Thread GitBox
pltbkd commented on pull request #18699: URL: https://github.com/apache/flink/pull/18699#issuecomment-1034673667 @dmvk Sure. I have added a test to verify this. The case will fail if I revert the change of this PR. But I am not sure if it's at the right place. Since no trans