---
fix up
This commit is contained in:
aalehin 2023-05-30 18:03:27 +03:00
parent a934befc3d
commit 5c3c287bf4

View file

@ -60,7 +60,9 @@ public class ImportToDB extends Stage {
log.warn("record index {} null", counter);
continue;
}
table.injectEntity(table.getEntity(swtHeaderData, entity));
if (entity.length > 0) {
table.injectEntity(table.getEntity(swtHeaderData, entity));
}
}
kafkaMessenger.notifySystemIfNeeded(currTable, fileId);
} catch (IOException exception) {