公开了基于可视化动态构建Flink SQL的方法和系统，包括将算子划分为源端算子、处理算子和目标算子，从数据源栏拖取源端算子到画板并配置算子信息；基于处理业务，在算子栏选择多个处理算子到画板中，并对算子的处理顺序进行编排；目标端栏中拖取相应的目标端算子到画板并配置算子信息。本申请的方法和系统只需在平台中拖取相应算子即可自动同时生成多个不同的复杂度SQL语句，SQL的正确性和便捷性都得到了提升，加快了数据治理实施人员在数据接入处理的速度。