Skip to content

Commit a6cd773

Browse files
authored
Update ExportService.java
1 parent 21b86fb commit a6cd773

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

repository/src/main/java/org/apache/atlas/repository/impexp/ExportService.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -289,15 +289,8 @@ private List<String> getStartingEntity(AtlasObjectId item, ExportContext context
289289
private void processEntityGuid(String guid, ExportContext context) throws AtlasBaseException {
290290
LOG.debug("==> processEntityGuid({})", guid);
291291

292-
boolean resumeExportForStartingEntity = false;
293-
if ((context.fetchType == ExportFetchType.CONNECTED
294-
|| (context.fetchType == ExportFetchType.INCREMENTAL && context.changeMarker <= 0))
295-
&& guid.equals(context.startingEntityGuid)) {
296-
resumeExportForStartingEntity = true;
297-
}
298-
299292
if (context.guidsProcessed.contains(guid)) {
300-
if (resumeExportForStartingEntity) {
293+
if (guid.equals(context.startingEntityGuid) && (context.fetchType == ExportFetchType.CONNECTED || (context.fetchType == ExportFetchType.INCREMENTAL && context.changeMarker <= 0))) {
301294
LOG.info("Resuming export for {}", guid);
302295
} else {
303296
return;

0 commit comments

Comments
 (0)