https://github.com/datafusion-contrib/StreamFusion This is a new flink native engine based on datafusion. Support most sql stream ing operator and performance is great