最近使用Flink实时告警项目，开始case by case硬编码定义算子，进行实时计算告警是没问题。但是业务场景结合规则引擎动态增删改规则并实时生效计算并告警。Flink并不支持动态添加，修改算子计算规则，开始利用动态类加载机制勉强实现。但是对于Flink这套就不太优雅。下面来介绍下怎么利用Flink优雅实现动态增删改算子规则。
未完待续。。。
免责声明！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。