用的是table , LOG里资源申请情况:

ResourceProfile{cpuCores=0.6, heapMemoryInMB=96, directMemoryInMB=0, 
nativeMemoryInMB=0, networkMemoryInMB=2, MANAGED_MEMORY_MB=0.0, 
FLOATING_MANAGED_MEMORY_MB=0.0} from resource manager (request = 
5ac9229acae1e6ef90563a5a0bf3fe21).
ResourceProfile{cpuCores=0.6, heapMemoryInMB=96, directMemoryInMB=0, 
nativeMemoryInMB=0, networkMemoryInMB=2, MANAGED_MEMORY_MB=0.0, 
FLOATING_MANAGED_MEMORY_MB=0.0} from resource manager (request = 
2e39ec9bb22b2afe2baa15a87d854796).
ResourceProfile{cpuCores=0.6, heapMemoryInMB=96, directMemoryInMB=0, 
nativeMemoryInMB=0, networkMemoryInMB=2, MANAGED_MEMORY_MB=0.0, 
FLOATING_MANAGED_MEMORY_MB=0.0} for job e40415828bbe184dc051e422e85e98c3 with 
allocation id 1a8a3b10d3c235dcb64b4b91e0a22bc8.
ResourceProfile{cpuCores=0.6, heapMemoryInMB=96, directMemoryInMB=0, 
nativeMemoryInMB=0, networkMemoryInMB=2, MANAGED_MEMORY_MB=0.0, 
FLOATING_MANAGED_MEMORY_MB=0.0} from resource manager (request = 
ce1a10fca1c7a9f6f93dcd248ebce56c).
ResourceProfile{cpuCores=0.6, heapMemoryInMB=96, directMemoryInMB=0, 
nativeMemoryInMB=0, networkMemoryInMB=2, MANAGED_MEMORY_MB=0.0, 
FLOATING_MANAGED_MEMORY_MB=0.0} for job e40415828bbe184dc051e422e85e98c3 with 
allocation id b9ea06e5ba61013ead29424b72e8535c.
ResourceProfile{cpuCores=0.6, heapMemoryInMB=96, directMemoryInMB=0, 
nativeMemoryInMB=0, networkMemoryInMB=2, MANAGED_MEMORY_MB=0.0, 
FLOATING_MANAGED_MEMORY_MB=0.0} for job e40415828bbe184dc051e422e85e98c3 with 
allocation id c3742a90378a264341e8d1a573c67535.

 
发件人: Guowei Ma
发送时间: 2019-03-29 17:12
收件人: user-zh
主题: Re: Re: 请教一下Blink资源分配问题
用的什么api,DataStream还是Table?
如果是DataStream的话,申请什么样的资源?
详细列下。
 
Best,
Guowei
 
 
邓成刚【qq】 <[email protected]> 于2019年3月29日周五 下午5:09写道:
 
> 是的。
>
> 发件人: moxian
> 发送时间: 2019-03-29 17:06
> 收件人: user-zh
> 主题: Re: 请教一下Blink资源分配问题
> standalone 模式?
>
> 邓成刚【qq】 <[email protected]> 于2019年3月29日周五 上午9:59写道:
>
> > 请教一下Blink资源分配问题:
> > blink 任务并行度设置 20  提示0个满足:Batch request 40 slots, but only 0 are
> fulfilled.
> > 调整到 3 并行度 提示:Batch request 6 slots, but only 4 are fulfilled.,
> > 但是我的TASK SLOTS有配 48,没有其它任务,
> > 按理説没有资源问题啊,集群配置情况:
> >
> > 其它的都是默认配置:
> >
> > taskmanager.numberOfTaskSlots: 24
> >
> > jobmanager.heap.size: 20480m
> >
> > # The heap size for the TaskManager JVM
> >
> > taskmanager.heap.size: 40960m
> >
> >
> > 服务器 2 台:每台 48核,256G
> >
> >
> >

回复