在不停止flink任务的情况下,在外部通过配置,来达到修改flink输出特征逻辑的变化、新增和删除。
碎碎念:
网上找了好久都没有,很多动态加载UDF,也是在启动的时候加载。我想要达到在运行过程中加载udf。 只能自己写了。 这是真的真的真的真的 动态业务规则。 还有一种方案是,在方法中调用接口,通过改变接口的实现逻辑来实现。 但是这种方法不符合分布式计算,把计算的工作全
京公网安备 11010502049817号