[hudi] branch master updated: [MINOR] Disable the MDT for flink by default (#9375)

[danny0405]

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 e0af843cb9c [MINOR] Disable the MDT for flink by default (#9375)
e0af843cb9c is described below

commit e0af843cb9c1e530703d780a4f7067014f6aae4c
Author: Danny Chan <yuzhao....@gmail.com>
AuthorDate: Sun Aug 6 17:12:59 2023 +0800

    [MINOR] Disable the MDT for flink by default (#9375)
    
    Disable because there are some cross-engine issues that are stil suspended.
---
 .../src/main/java/org/apache/hudi/configuration/FlinkOptions.java     | 4 ++--
 .../src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java      | 2 ++
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
index 556d0b2ef2b..b57ca259f13 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
@@ -189,9 +189,9 @@ public class FlinkOptions extends HoodieConfig {
   public static final ConfigOption<Boolean> METADATA_ENABLED = ConfigOptions
       .key("metadata.enabled")
       .booleanType()
-      .defaultValue(true)
+      .defaultValue(false)
       .withFallbackKeys(HoodieMetadataConfig.ENABLE.key())
-      .withDescription("Enable the internal metadata table which serves table 
metadata like level file listings, default enabled");
+      .withDescription("Enable the internal metadata table which serves table 
metadata like level file listings, default disabled");
 
   public static final ConfigOption<Integer> METADATA_COMPACTION_DELTA_COMMITS 
= ConfigOptions
       .key("metadata.compaction.delta_commits")
diff --git 
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java
 
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java
index 94214661ea8..c899b1bb234 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java
@@ -26,6 +26,7 @@ import org.apache.hudi.configuration.FlinkOptions;
 import org.apache.hudi.utils.TestData;
 
 import org.apache.flink.configuration.Configuration;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
@@ -164,6 +165,7 @@ public class TestWriteMergeOnRead extends 
TestWriteCopyOnWrite {
   }
 
   @Test
+  @Disabled("HUDI-6655")
   public void testConsistentBucketIndex() throws Exception {
     conf.setString(FlinkOptions.INDEX_TYPE, "BUCKET");
     conf.setString(FlinkOptions.BUCKET_INDEX_ENGINE_TYPE, 
"CONSISTENT_HASHING");