lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2092] Fix NPE caused by FlinkStreamerConfig#writePartitionUrlEncode null value (#3176)

Browse Source
This commit is contained in:
wangxianghu
2021-06-30 09:21:06 +08:00
committed by GitHub
parent f665db071f
commit 202887b8ca
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java
View File

@@ -162,7 +162,7 @@ public class FlinkStreamerConfig extends Configuration {
public Boolean utcTimezone = true; public Boolean utcTimezone = true;
@Parameter(names = {"--write-partition-url-encode"}, description = "Whether to encode the partition path url, default false") @Parameter(names = {"--write-partition-url-encode"}, description = "Whether to encode the partition path url, default false")
public Boolean writePartitionUrlEncode; public Boolean writePartitionUrlEncode = false;
@Parameter(names = {"--hive-style-partitioning"}, description = "Whether to use Hive style partitioning.\n" @Parameter(names = {"--hive-style-partitioning"}, description = "Whether to use Hive style partitioning.\n"
+ "If set true, the names of partition folders follow <partition_column_name>=<partition_value> format.\n" + "If set true, the names of partition folders follow <partition_column_name>=<partition_value> format.\n"