[GitHub] [flink] godfreyhe commented on a diff in pull request #21556: [FLINK-30491][hive] Hive table partition supports deserializing later during runtime

2023-01-08 Thread GitBox
godfreyhe commented on code in PR #21556: URL: https://github.com/apache/flink/pull/21556#discussion_r1064264590 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/util/HivePartitionUtils.java: ## @@ -290,4 +291,33 @@ private static void

[GitHub] [flink] godfreyhe commented on a diff in pull request #21556: [FLINK-30491][hive] Hive table partition supports deserializing later during runtime

2023-01-08 Thread GitBox
godfreyhe commented on code in PR #21556: URL: https://github.com/apache/flink/pull/21556#discussion_r1064257049 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceFileEnumerator.java: ## @@ -222,19 +225,24 @@ private static int