alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-6543 Fix NPE due to optional fields in PartitionRouting SMT

Browse Source
This commit is contained in:
mfvitale 2023-06-13 10:37:57 +02:00 committed by Jiri Pechanec
parent 56580c3b17
commit b7eb4b5c62
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-core/src/main/java/io/debezium/transforms/partitions/PartitionRouting.java
View File

@ -189,7 +189,7 @@ private Optional<Object> toValue(String fieldName, Struct envelope) {
String[] subFields = Arrays.stream(fieldName.split(NESTING_SEPARATOR)).map(String::trim).toArray(String[]::new);
if (subFields.length == 1) {
return Optional.of(envelope.get(subFields[0]));
return Optional.ofNullable(envelope.get(subFields[0]));
}
Struct lastStruct = getLastStruct(envelope, subFields);