Java也得写flink了嘛