<BUG>String source1MulitJoinInput = "source1";String source2MultiJoinInput = "source2";String source3MultiJoinInput = "source3";ETLBatchConfig etlConfig = ETLBatchConfig.builder("* * * * *")</BUG><CONTEXT>Schema.Field.of("item_id", Schema.nullableOf(Schema.of(Schema.Type.STRING))),Schema.Field.of("item_price", Schema.nullableOf(Schema.of(Schema.Type.LONG))),Schema.Field.of("cust_id", Schema.nullableOf(Schema.of(Schema.Type.STRING))),Schema.Field.of("cust_name", Schema.nullableOf(Schema.of(Schema.Type.STRING))));<extra_id_0>.addStage(new ETLStage("source1", MockSource.getPlugin(source1MulitJoinInput)))</CONTEXT>
String source1MulitJoinInput = "multiJoinSource1-" + engine;String source2MultiJoinInput = "multiJoinSource2-" + engine;String source3MultiJoinInput = "multiJoinSource3-" + engine;String outputName = "multiJoinOutput-" + engine;String sinkName = "multiJoinOutputSink-" + engine;String outerJoinName = "multiJoinOuter-" + engine;ETLBatchConfig etlConfig = ETLBatchConfig.builder("* * * * *")