prathit06 commented on code in PR #10313:
URL: https://github.com/apache/hudi/pull/10313#discussion_r1423664817
##########
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeInputFormatUtils.java:
##########
@@ -86,7 +86,7 @@ private static Configuration addProjectionField(Configuration
conf, String field
public static void addProjectionField(Configuration conf, String[]
fieldName) {
if (fieldName.length > 0) {
- List<String> columnNameList =
Arrays.stream(conf.get(serdeConstants.LIST_COLUMNS).split(",")).collect(Collectors.toList());
+ List<String> columnNameList =
Arrays.stream(conf.get(serdeConstants.LIST_COLUMNS,
"").split(",")).collect(Collectors.toList());
Arrays.stream(fieldName).forEach(field -> {
Review Comment:
- It will be used when columns list is passed in Job Configuration
- It wont be used in cases where Configuration is created with empty params
such as `val jobConf = new JobConf()` ( this is what we are doing currently in
our Flink job to read a hoodie table) , due to this when
`conf.get(serdeConstants.LIST_COLUMNS)` is invoked, it returns NPE so this
particular fix will handle such cases
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
