---
fix up
This commit is contained in:
aalehin 2023-05-30 18:08:29 +03:00
parent 5c3c287bf4
commit f99398ea12
2 changed files with 4 additions and 6 deletions

View file

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

View file

@ -108,12 +108,12 @@ S_DF_13
String line = scanner.nextLine();
String[] separetedLine = line.split(":");
if (separetedLine.length < 5) {
return new String[0];
return null;
}
return separetedLine;
case S_DF_13:
default:
return new String[0];
return null;
}
}