This is an automated email from the ASF dual-hosted git repository.
htowaileb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git
The following commit(s) were added to refs/heads/master by this push:
new b744be6dc2 [NO ISSUE][EXT]: avoid closing resources on non-initialized
tasks
b744be6dc2 is described below
commit b744be6dc26e8be1f7ca034bb36a6734b540e384
Author: Hussain Towaileb <[email protected]>
AuthorDate: Fri Feb 13 16:00:49 2026 +0300
[NO ISSUE][EXT]: avoid closing resources on non-initialized tasks
Ext-ref: MB-70518
Change-Id: Ide795ea6b0cebf2415a38f09090440ba3792d6c1
Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20889
Reviewed-by: Hussain Towaileb <[email protected]>
Reviewed-by: Ali Alsuliman <[email protected]>
Integration-Tests: Jenkins <[email protected]>
Tested-by: Jenkins <[email protected]>
---
.../java/org/apache/asterix/external/util/iceberg/IcebergUtils.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/iceberg/IcebergUtils.java
b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/iceberg/IcebergUtils.java
index 20ce57b5ad..c9a4e5bd0b 100644
---
a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/iceberg/IcebergUtils.java
+++
b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/iceberg/IcebergUtils.java
@@ -348,8 +348,10 @@ public class IcebergUtils {
} catch (Exception ex) {
throw CompilationException.create(ErrorCode.EXTERNAL_SOURCE_ERROR,
ex, ex.getMessage());
} finally {
- String awsClientsFactoryId =
catalogProperties.get(FACTORY_INSTANCE_ID_KEY);
- EnsureCloseClientsFactoryRegistry.closeAll(awsClientsFactoryId);
+ if (catalogProperties != null) {
+ String awsClientsFactoryId =
catalogProperties.get(FACTORY_INSTANCE_ID_KEY);
+
EnsureCloseClientsFactoryRegistry.closeAll(awsClientsFactoryId);
+ }
}
}
