Flink CE循环模式API