[GitHub] [flink] JunRuiLee commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

JunRuiLee commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r1113790013 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java: ## @@ -402,7 +402,7 @@ public Optional getCoordinatorProvider(

[GitHub] [flink] JunRuiLee commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

JunRuiLee commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r1113777681 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java: ## @@ -402,7 +402,7 @@ public Optional getCoordinatorProvider(

[GitHub] [flink] JunRuiLee commented on a diff in pull request #21977: [FLINK-31132] Compact without setting parallelism does not follow the configured sink parallelism for HiveTableSink

JunRuiLee commented on code in PR #21977: URL: https://github.com/apache/flink/pull/21977#discussion_r111259 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkTest.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the