This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 7e7b3a866b [HUDI-5221] Make the decision for flink sql bucket index 
case-insensitive (#7207)
7e7b3a866b is described below

commit 7e7b3a866b549021c5a7ad9f89f0da90aff7da68
Author: Danny Chan <[email protected]>
AuthorDate: Wed Nov 16 09:43:57 2022 +0800

    [HUDI-5221] Make the decision for flink sql bucket index case-insensitive 
(#7207)
---
 .../src/main/java/org/apache/hudi/configuration/OptionsResolver.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java
index e0102ef7ab..76d775557f 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java
@@ -122,7 +122,7 @@ public class OptionsResolver {
   }
 
   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());
   }
 
   /**

Reply via email to