You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by yu...@apache.org on 2023/01/17 05:41:55 UTC
[hudi] branch master updated: [MINOR] Add database config for flink (#7682)
This is an automated email from the ASF dual-hosted git repository.
yuzhaojing 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 d2a3d11977d [MINOR] Add database config for flink (#7682)
d2a3d11977d is described below
commit d2a3d11977d277202eba002ae75090284694655f
Author: Zhaojing Yu <yu...@bytedance.com>
AuthorDate: Tue Jan 17 13:41:49 2023 +0800
[MINOR] Add database config for flink (#7682)
---
.../src/main/java/org/apache/hudi/configuration/FlinkOptions.java | 6 ++++++
.../hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java | 1 +
2 files changed, 7 insertions(+)
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 ad0af39d65b..c1812b79e38 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
@@ -84,6 +84,12 @@ public class FlinkOptions extends HoodieConfig {
// Common Options
// ------------------------------------------------------------------------
+ public static final ConfigOption<String> DATABASE_NAME = ConfigOptions
+ .key(HoodieTableConfig.DATABASE_NAME.key())
+ .stringType()
+ .noDefaultValue()
+ .withDescription("Database name to register to Hive metastore");
+
public static final ConfigOption<String> TABLE_NAME = ConfigOptions
.key(HoodieWriteConfig.TBL_NAME.key())
.stringType()
diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
index de37b790159..a6bddf1e82f 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
@@ -191,6 +191,7 @@ public class StreamerUtil {
.setTableCreateSchema(conf.getString(FlinkOptions.SOURCE_AVRO_SCHEMA))
.setTableType(conf.getString(FlinkOptions.TABLE_TYPE))
.setTableName(conf.getString(FlinkOptions.TABLE_NAME))
+ .setDatabaseName(conf.getString(FlinkOptions.DATABASE_NAME))
.setRecordKeyFields(conf.getString(FlinkOptions.RECORD_KEY_FIELD, null))
.setPayloadClassName(conf.getString(FlinkOptions.PAYLOAD_CLASS_NAME))
.setPreCombineField(OptionsResolver.getPreCombineField(conf))