Repository: incubator-unomi Updated Branches: refs/heads/master 11d9efdb5 -> eed5bec78
UNOMI-102 : Add check for hasDeleteColumn when splitting lines Project: http://git-wip-us.apache.org/repos/asf/incubator-unomi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-unomi/commit/eed5bec7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-unomi/tree/eed5bec7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-unomi/diff/eed5bec7 Branch: refs/heads/master Commit: eed5bec78d2ad2bac70ac9dc0a8e266d006a197c Parents: 11d9efd Author: Abdelkader Midani <amid...@apache.org> Authored: Tue Jul 11 10:54:04 2017 +0200 Committer: Abdelkader Midani <amid...@apache.org> Committed: Tue Jul 11 10:54:18 2017 +0200 ---------------------------------------------------------------------- .../org/apache/unomi/router/core/processor/LineSplitProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-unomi/blob/eed5bec7/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitProcessor.java ---------------------------------------------------------------------- diff --git a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitProcessor.java b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitProcessor.java index 2eadb91..33332bb 100644 --- a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitProcessor.java +++ b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitProcessor.java @@ -69,7 +69,7 @@ public class LineSplitProcessor implements Processor { profileToImport.setItemType("profile"); profileToImport.setScope(RouterConstants.SYSTEM_SCOPE); if (profileData.length > 0 && StringUtils.isNotBlank(profileData[0])) { - if (fieldsMapping.size() != (profileData.length - 1)) { + if (hasDeleteColumn && (fieldsMapping.size() != (profileData.length - 1))) { throw new BadProfileDataFormatException("The mapping does not match the number of column : line [" + ((Integer) exchange.getProperty("CamelSplitIndex") + 1) + "]", new Throwable("MAPPING_COLUMN_MATCH")); } Map<String, Object> properties = new HashMap<>();
