在使用1.2的版本的过程中,内存过一段时间就会升高,只要重启be节点就会释放掉;通过查看日志,怀疑是与Kaka版本不适配导致了Routineload的时候不断重试的去拿Kafka的数据,没有释放掉内存导致,然后把Kafka降低到和源码适配的版本号还是有问题,目前还不知道怎么解决这个问题
Kafka源码的版本号
在使用1.2的版本的过程中,内存过一段时间就会升高,只要重启be节点就会释放掉;通过查看日志,怀疑是与Kaka版本不适配导致了Routineload的时候不断重试的去拿Kafka的数据,没有释放掉内存导致,然后把Kafka降低到和源码适配的版本号还是有问题,目前还不知道怎么解决这个问题
Kafka源码的版本号