yanghua commented on a change in pull request #3151: URL: https://github.com/apache/hudi/pull/3151#discussion_r658572030
########## File path: hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java ########## @@ -130,6 +131,183 @@ @Parameter(names = {"--write-task-num"}, description = "Parallelism of tasks that do actual write, default is 4.") public Integer writeTaskNum = 4; + @Parameter(names = {"--partition-default-name"}, + description = "The default partition name in case the dynamic partition column value is null/empty string") + public String partitionDefaultName = "__DEFAULT_PARTITION__"; + + @Parameter(names = {"--index-bootstrap-enabled"}, + description = "Whether to bootstrap the index state from existing hoodie table, default false") + public Boolean indexBootstrapEnabled = false; + + @Parameter(names = {"--index-state-ttl"}, description = "Index state ttl in days, default 1.5 day") + public Double indexStateTtl = 1.5D; + + @Parameter(names = {"--index-global-enabled"}, description = "Whether to update index for the old partition path " + + "if same key record with different partition path came in, default false") + public Boolean indexGlobalEnabled = false; + + @Parameter(names = {"--index-partition-regex"}, + description = "Whether to load partitions in state if partition path matching, default *") + public String indexPartitionRegex = ".*"; + + @Parameter(names = {"--read-tasks-parallelism"}, description = "Parallelism of tasks that do actual read, default is 4") + public Integer readTasksParallelism = 4; + + @Parameter(names = {"--avro-schema-path"}, description = "Avro schema file path, the parsed schema is used for deserialization") + public String avroSchemaPath; + + @Parameter(names = {"--avro-schema"}, description = "Avro schema string, the parsed schema is used for deserialization") + public String avroSchema; Review comment: It has no default value, and is not required. It would cause NPE when copying. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org