[HUDI-5221] Make the decision for flink sql bucket index case-insensi…

…tive (#7207)
apache · Nov 16, 2022 · 7e7b3a8 · 7e7b3a8
1 parent 6b0b03b
commit 7e7b3a8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...nk-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java b/...nk-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java
@@ -122,7 +122,7 @@ public static boolean isPartitionedTable(Configuration conf) {
   }
 
   public static boolean isBucketIndexType(Configuration conf) {
-    return conf.getString(FlinkOptions.INDEX_TYPE).equals(HoodieIndex.IndexType.BUCKET.name());
+    return conf.getString(FlinkOptions.INDEX_TYPE).equalsIgnoreCase(HoodieIndex.IndexType.BUCKET.name());
   }
 
   /**