  @Test
  public void testInvalidMapSchemalessNullValue() {

    Map kafkaConnectMap = new HashMap<Object, Object>(){{
      put("f1", "abc");
      put("f2", "abc");
      put("f3", null);
    }};

    SinkRecord kafkaConnectRecord = spoofSinkRecord(null, kafkaConnectMap, true);
    Map<String, Object> stringObjectMap = new BigQueryRecordConverter(SHOULD_CONVERT_DOUBLE).convertRecord(kafkaConnectRecord, KafkaSchemaRecordType.KEY);
    Assert.assertEquals(kafkaConnectMap, stringObjectMap
    );
  }