Repository: atlas Updated Branches: refs/heads/branch-0.8 a0986f302 -> 55f8b78fd
ATLAS-2897: Better handling of empty zip files. Project: http://git-wip-us.apache.org/repos/asf/atlas/repo Commit: http://git-wip-us.apache.org/repos/asf/atlas/commit/55f8b78f Tree: http://git-wip-us.apache.org/repos/asf/atlas/tree/55f8b78f Diff: http://git-wip-us.apache.org/repos/asf/atlas/diff/55f8b78f Branch: refs/heads/branch-0.8 Commit: 55f8b78fdd7f84fdf5fdc007cfd3e3c63a4392ae Parents: a0986f3 Author: Ashutosh Mestry <[email protected]> Authored: Thu Oct 4 14:38:21 2018 -0700 Committer: Ashutosh Mestry <[email protected]> Committed: Thu Oct 4 14:38:21 2018 -0700 ---------------------------------------------------------------------- .../atlas/repository/impexp/AtlasServerService.java | 1 - .../org/apache/atlas/repository/impexp/ZipSource.java | 12 ++++++++---- 2 files changed, 8 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/atlas/blob/55f8b78f/repository/src/main/java/org/apache/atlas/repository/impexp/AtlasServerService.java ---------------------------------------------------------------------- diff --git a/repository/src/main/java/org/apache/atlas/repository/impexp/AtlasServerService.java b/repository/src/main/java/org/apache/atlas/repository/impexp/AtlasServerService.java index b5e416e..417e405 100644 --- a/repository/src/main/java/org/apache/atlas/repository/impexp/AtlasServerService.java +++ b/repository/src/main/java/org/apache/atlas/repository/impexp/AtlasServerService.java @@ -65,7 +65,6 @@ public class AtlasServerService { try { return dataAccess.load(server); } catch (AtlasBaseException e) { - LOG.error("dataAccess", e); throw e; } } http://git-wip-us.apache.org/repos/asf/atlas/blob/55f8b78f/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSource.java ---------------------------------------------------------------------- diff --git a/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSource.java b/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSource.java index a974249..016acd7 100644 --- a/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSource.java +++ b/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSource.java @@ -72,10 +72,14 @@ public class ZipSource implements EntityImportStream { } private boolean isZipFileEmpty() { - return MapUtils.isEmpty(guidEntityJsonMap) || - (guidEntityJsonMap.containsKey(ZipExportFileNames.ATLAS_EXPORT_ORDER_NAME.toString()) && - (guidEntityJsonMap.get(ZipExportFileNames.ATLAS_EXPORT_ORDER_NAME.toString()) == null) - ); + if (MapUtils.isEmpty(guidEntityJsonMap)) { + return true; + } + + String key = ZipExportFileNames.ATLAS_EXPORT_ORDER_NAME.toString(); + return (guidEntityJsonMap.containsKey(key) && + StringUtils.isNotEmpty(guidEntityJsonMap.get(key)) && + guidEntityJsonMap.get(key).equals("[]")); } public ImportTransforms getImportTransform() { return this.importTransform; }
