Merge pull request #35 from lalithkota/develop

DynamicNewField SMT: Output Default Value Fixed
OpenG2P · Oct 22, 2024 · c85619b · c85619b
2 parents 55979a4 + ca94545
commit c85619b
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);