Skip to content

Commit 965be75

Browse files
[Enhancement] Add one config for hudi lib internal metadata table (backport #67540) (#67581)
Signed-off-by: trueeyu <lxhhust350@qq.com> Co-authored-by: trueeyu <lxhhust350@qq.com>
1 parent f1c439f commit 965be75

2 files changed

Lines changed: 6 additions & 1 deletion

File tree

fe/fe-core/src/main/java/com/starrocks/common/Config.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3586,4 +3586,7 @@ public class Config extends ConfigBase {
35863586
*/
35873587
@ConfField
35883588
public static int deploy_serialization_queue_size = -1;
3589+
3590+
@ConfField(mutable = true)
3591+
public static boolean enable_hudi_lib_internal_metadata_table = true;
35893592
}

fe/fe-core/src/main/java/com/starrocks/connector/hudi/HudiRemoteFileIO.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import com.google.common.collect.ImmutableList;
1919
import com.google.common.collect.ImmutableMap;
2020
import com.google.common.collect.Lists;
21+
import com.starrocks.common.Config;
2122
import com.starrocks.connector.RemoteFileDesc;
2223
import com.starrocks.connector.RemoteFileIO;
2324
import com.starrocks.connector.RemoteFileScanContext;
@@ -67,7 +68,8 @@ private void createHudiContext(RemoteFileScanContext ctx) {
6768
ctx.usedCount++;
6869
if (ctx.usedCount == 1) {
6970
HoodieLocalEngineContext engineContext = new HoodieLocalEngineContext(configuration);
70-
HoodieMetadataConfig metadataConfig = HoodieMetadataConfig.newBuilder().enable(true).build();
71+
HoodieMetadataConfig metadataConfig = HoodieMetadataConfig.newBuilder()
72+
.enable(Config.enable_hudi_lib_internal_metadata_table).build();
7173
HoodieTableMetaClient metaClient =
7274
HoodieTableMetaClient.builder().setConf(configuration).setBasePath(ctx.tableLocation).build();
7375
// metaClient.reloadActiveTimeline();

0 commit comments

Comments
 (0)