Re: Re: K8s Appliaction模式无法支持flinkjar中Java动态编译？

依赖的jar包，有编译到启动jar包里面吗 周坤 <18679131...@163.com>于2023年8月30日 周三11:15写道： > > 你好！在K8s模式中，动态编译缺失运行在UserJar中，启动的时候通过RIch算子的Open方法从第三方拉取原始class文件，然后进行动态编译进行缓存内存中， > 按照YARN PER模式该方式是没有问题， 但是在K8s > Apllication模式，会找不到原始class文件中的依赖，其实在UserJar中有该文件的类依赖的； > 目前发现这个依赖类单独打jar包放在在lib目录下在框架运行时就加载才能找到依赖类，但是又不太符合规范；

flink任务重启后监控指标从0开始重新统计

我在flink任务中添加了metric，并定时通过日志的方式输出。 现在发现在flink任务由于异常原因重启后，监控指标从0开始重新统计了。 针对自己实现的算子，我在metric中添加了部分信息，可以将多次指标进行合并。 但针对使用到的连接器中的指标，好像没法这么弄。大家有什么好的方案么？