marton-bod opened a new pull request #2150: URL: https://github.com/apache/iceberg/pull/2150
In case we experience a failure during task commit (`HiveIcebergOutputCommitter#commitTask`), we'll have a problem during task abortion (`HiveIcebergOutputCommitter#abortTask`) because the committer has already removed its writer from the `HiveIcebergRecordWriter`'s static map, therefore `abortTask` will run into NPE when dereferencing the writer. To solve this, the `commitTask` should call Map#get instead of Map#remove initially, and only remove the reference from the map once it has successfully completed. ---------------------------------------------------------------- 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]
