DynamicNewField SMT: Output Default Value Fixed

Signed-off-by: Lalith Kota <[email protected]>
OpenG2P · Oct 22, 2024 · ca94545 · ca94545
1 parent 18931be
commit ca94545
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...rms/src/test/java/org/openg2p/reporting/kafka/connect/transforms/DynamicNewFieldTest.java b/...rms/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);