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
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