SourabhBadhya commented on code in PR #4520:
URL: https://github.com/apache/hive/pull/4520#discussion_r1304516500
##########
ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverMergeFiles.java:
##########
@@ -271,6 +300,12 @@ private void generateActualTasks(HiveConf conf,
List<Task<?>> resTsks,
Utilities.FILE_OP_LOGGER.debug("merge resolver will merge " +
status[i].getPath());
work.resolveDynamicPartitionStoredAsSubDirsMerge(conf,
status[i].getPath(), tblDesc,
aliases, pDesc);
+ // Do not add input file since its already added when the manifest
file is present.
+ if (!manifestFilePresent) {
+ List<Path> inputPaths = work.getPaths();
+ inputPaths.add(status[i].getPath());
Review Comment:
Added `toMerge` to keep track of what needs to be changed. And do final
update on the `work` object.
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
