diff --git a/wrangler-core/src/main/java/io/cdap/directives/column/SetType.java b/wrangler-core/src/main/java/io/cdap/directives/column/SetType.java index 1ecc3b159..c4434ca44 100644 --- a/wrangler-core/src/main/java/io/cdap/directives/column/SetType.java +++ b/wrangler-core/src/main/java/io/cdap/directives/column/SetType.java @@ -114,6 +114,7 @@ public Mutation lineage() { @Override public Schema getOutputSchema(SchemaResolutionContext context) { + String changeHere ="BranchtoForcePushto"; Schema inputSchema = context.getInputSchema(); return Schema.recordOf( "outputSchema",