tprelle commented on a change in pull request #3242:
URL: https://github.com/apache/iceberg/pull/3242#discussion_r731860368
##########
File path:
mr/src/main/java/org/apache/iceberg/mr/mapreduce/IcebergInputFormat.java
##########
@@ -216,7 +216,12 @@ public void initialize(InputSplit split,
TaskAttemptContext newContext) {
this.reuseContainers =
conf.getBoolean(InputFormatConfig.REUSE_CONTAINERS, false);
this.inMemoryDataModel =
conf.getEnum(InputFormatConfig.IN_MEMORY_DATA_MODEL,
InputFormatConfig.InMemoryDataModel.GENERIC);
- this.currentIterator = open(tasks.next(), expectedSchema).iterator();
+ if (tasks.hasNext()) {
Review comment:
@pvary The issue it's link to the mock with mockito in the test.
Tasks can no be null in non-test because it's mean they have no files in the
split so the input format it's not launched.
--
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]
