flink-extended ai-flow