DBZ-6637 use the right column name when checking for columnQueryBindingFromField
This commit is contained in:
parent
74948cfaf0
commit
215ccf70ac
@ -621,7 +621,8 @@ protected void addColumnDefaultValue(FieldDescriptor field, StringBuilder column
|
|||||||
}
|
}
|
||||||
|
|
||||||
protected String columnQueryBindingFromField(String fieldName, TableDescriptor table, SinkRecordDescriptor record) {
|
protected String columnQueryBindingFromField(String fieldName, TableDescriptor table, SinkRecordDescriptor record) {
|
||||||
final String columnName = columnNameFromField(fieldName, record);
|
|
||||||
|
final String columnName = getColumnNamingStrategy().resolveColumnName(fieldName);
|
||||||
|
|
||||||
if (record.getNonKeyFieldNames().contains(columnName)) {
|
if (record.getNonKeyFieldNames().contains(columnName)) {
|
||||||
Struct source = record.getAfterStruct();
|
Struct source = record.getAfterStruct();
|
||||||
|
Loading…
Reference in New Issue
Block a user