From ca94545e2f27b75dfebeaddc3b7896f263a8e458 Mon Sep 17 00:00:00 2001 From: Lalith Kota Date: Tue, 22 Oct 2024 19:12:32 +0530 Subject: [PATCH] DynamicNewField SMT: Output Default Value Fixed Signed-off-by: Lalith Kota --- .../kafka/connect/transforms/DynamicNewFieldTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/opensearch-kafka-connector/kafka-connect-transforms/src/test/java/org/openg2p/reporting/kafka/connect/transforms/DynamicNewFieldTest.java b/opensearch-kafka-connector/kafka-connect-transforms/src/test/java/org/openg2p/reporting/kafka/connect/transforms/DynamicNewFieldTest.java index 5ba5784..773ff9b 100644 --- a/opensearch-kafka-connector/kafka-connect-transforms/src/test/java/org/openg2p/reporting/kafka/connect/transforms/DynamicNewFieldTest.java +++ b/opensearch-kafka-connector/kafka-connect-transforms/src/test/java/org/openg2p/reporting/kafka/connect/transforms/DynamicNewFieldTest.java @@ -32,7 +32,7 @@ public void testWithSchema() { config.put(DynamicNewField.ES_INPUT_FIELDS_CONFIG, "id,lang_code"); config.put(DynamicNewField.ES_OUTPUT_FIELDS_CONFIG, "name"); config.put(DynamicNewField.INPUT_FIELDS_CONFIG, "regcntr_id,lang_code"); - config.put(DynamicNewField.DEFAULT_VALUE_CONFIG, "null,null"); + config.put(DynamicNewField.INPUT_DEFAULT_VALUE_CONFIG, "null,null"); config.put(DynamicNewField.OUTPUT_FIELDS_CONFIG, "regcntr_name"); xformValue.configure(config); @@ -71,7 +71,7 @@ public void testSchemaless() { config.put(DynamicNewField.ES_INPUT_FIELDS_CONFIG, "id,lang_code"); config.put(DynamicNewField.ES_OUTPUT_FIELDS_CONFIG, "name"); config.put(DynamicNewField.INPUT_FIELDS_CONFIG, "regcntr_id,lang_code"); - config.put(DynamicNewField.DEFAULT_VALUE_CONFIG, "null,null"); + config.put(DynamicNewField.INPUT_DEFAULT_VALUE_CONFIG, "null,null"); config.put(DynamicNewField.OUTPUT_FIELDS_CONFIG, "regcntr_name"); xformValue.configure(config); @@ -110,7 +110,7 @@ public void testSchemalessNullField() { config.put(DynamicNewField.ES_INPUT_FIELDS_CONFIG, "id"); config.put(DynamicNewField.ES_OUTPUT_FIELDS_CONFIG, "name"); config.put(DynamicNewField.INPUT_FIELDS_CONFIG, "regcntr_id"); - config.put(DynamicNewField.DEFAULT_VALUE_CONFIG, ""); + config.put(DynamicNewField.INPUT_DEFAULT_VALUE_CONFIG, ""); config.put(DynamicNewField.OUTPUT_FIELDS_CONFIG, "regcntr_name"); xformValue.configure(config);