[HUDI-2088] Missing Partition Fields And PreCombineField In Hoodie Properties For Table Written By Flink (#3171)

2021-07-01 17:25:18 +08:00
parent d07def1290
commit b34d53fa9c
3 changed files with 77 additions and 0 deletions
--- a/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
@@ -210,6 +210,8 @@ public class StreamerUtil {
          .setTableName(conf.getString(FlinkOptions.TABLE_NAME))
          .setPayloadClassName(conf.getString(FlinkOptions.PAYLOAD_CLASS))
          .setArchiveLogFolder(HOODIE_ARCHIVELOG_FOLDER_PROP.defaultValue())
+          .setPartitionColumns(conf.getString(FlinkOptions.PARTITION_PATH_FIELD, null))
+          .setPreCombineField(conf.getString(FlinkOptions.PRECOMBINE_FIELD))
          .setTimelineLayoutVersion(1)
          .initTable(hadoopConf, basePath);
      LOG.info("Table initialized under base path {}", basePath);