pvary commented on a change in pull request #2161:
URL: https://github.com/apache/hive/pull/2161#discussion_r617491058
##########
File path:
iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/HiveIcebergOutputCommitter.java
##########
@@ -346,25 +372,23 @@ private static ExecutorService
tableExecutor(Configuration conf, int maxThreadNu
/**
* Get the committed data files for this table and job.
+ *
+ * @param numTasks Number of writer tasks that produced a forCommit file
* @param executor The executor used for reading the forCommit files parallel
* @param location The location of the table
* @param jobContext The job context
* @param io The FileIO used for reading a files generated for commit
* @param throwOnFailure If <code>true</code> then it throws an exception on
failure
* @return The list of the committed data files
*/
- private static Collection<DataFile> dataFiles(ExecutorService executor,
String location, JobContext jobContext,
- FileIO io, boolean throwOnFailure) {
+ private static Collection<DataFile> dataFiles(int numTasks, ExecutorService
executor, String location,
+ JobContext jobContext, FileIO
io, boolean throwOnFailure) {
Review comment:
Fun stuff 😄
Whatever!
--
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:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
