There may be a different java version. Also there is a Flink lineage tracing capability that we may want to take advantage of. The dev list has a post proposing lots of deliverables for v1 pre lineage and V1 with lineage and V2 Kafka connector.