Merge pull request #713 from data-integrations/CDAP-21024

CDAP-21024: Return null when there is no outputfield
data-integrations · May 7, 2024 · 637cf06 · 637cf06
2 parents 564f734 + f4b8805
commit 637cf06
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/wrangler-core/src/main/java/io/cdap/wrangler/schema/DirectiveOutputSchemaGenerator.java b/wrangler-core/src/main/java/io/cdap/wrangler/schema/DirectiveOutputSchemaGenerator.java
@@ -103,6 +103,9 @@ private Schema generateDirectiveOutputSchema(Schema inputSchema)
         outputFields.add(Schema.Field.of(fieldName, Schema.of(Schema.Type.NULL)));
       }
     }
+    if (outputFields.isEmpty()) {
+      return null;
+    }
     return Schema.recordOf("output", outputFields);
   }