DTStack / DTStack/chunjun

关于flinkx自定义jobmanager,taskmanager内存bug

Open
#517 9 comments 0 reactions 0 assignees View on GitHub
bug
Dominant language
Java
Stars
4.1k
Forks
1.7k
PR merge metrics
No merged PRs in 30d

Description

在flinkx中自定义jobmanager,taskmanger内存使用的是flink官方参数:
jobmanager.memory.process.size
taskmanager.memory.process.size

在flink官方中,这两个参数值类型为String,如果不加上单位m,g。 则默认为字节单位
然而在flinkx中,这两个参数值类型为String,无法设置单位,且flinkx中对于这两个参数的单位是MB
这里存在两个参数单位不统一的bug,会导致任务报错启动不了

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.