2、实现对流式SQL查询优化、运行时优化、问题诊断分析。3、实现实时计算在业务上的应用，如报表开发、事件开发、实时分析、实时异常监控等一项或多项。4、参与流计算引擎flink的调度优化、执行优化，支撑高吞吐、大状态作业的稳定运行。