Skip to content

Commit c68b1e4

Browse files
author
Bingqin Zhou
committed
Resolve conflicts.
2 parents 8cb0857 + 77d2b6e commit c68b1e4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/convert/BigQueryRecordConverterTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -613,8 +613,8 @@ public void testInvalidMapSchemalessNullValue() {
613613
put("f3", null);
614614
}};
615615

616-
SinkRecord kafkaConnectRecord = spoofSinkRecord(null, kafkaConnectMap, false);
617-
Map<String, Object> stringObjectMap = new BigQueryRecordConverter(SHOULD_CONVERT_DOUBLE).convertRecord(kafkaConnectRecord, KafkaSchemaRecordType.VALUE);
616+
SinkRecord kafkaConnectRecord = spoofSinkRecord(null, kafkaConnectMap, true);
617+
Map<String, Object> stringObjectMap = new BigQueryRecordConverter(SHOULD_CONVERT_DOUBLE).convertRecord(kafkaConnectRecord, KafkaSchemaRecordType.KEY);
618618
Assert.assertEquals(kafkaConnectMap, stringObjectMap
619619
);
620620
}

0 commit comments

Comments
 (0)