flink1.11启动问题

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

flink1.11启动问题

酷酷的浑蛋
现在是为什么啊?启动任务自动占用所有core?core数量一直在增加,直到达到队列最大值,然后就卡住了,这flink1.11啥情况啊?  



Reply | Threaded
Open this post in threaded view
|

回复:flink1.11启动问题

酷酷的浑蛋
这是我的启动命令:./bin/flink run -m yarn-cluster -p 2 -ys 2 -yqu rt_constant -c com.xx.Main -yjm 1024 -ynm RTC_TEST xx.jar
任务到yarn上后就一直在占用core,core数量和内存数量一直在增加




在2020年07月22日 12:48,JasonLee<[hidden email]> 写道:
HI
你使用的什么模式?启动任务的命令发出来看一下吧


| |
JasonLee
|
|
邮箱:[hidden email]
|

Signature is customized by Netease Mail Master

在2020年07月22日 12:44,酷酷的浑蛋 写道:
现在是为什么啊?启动任务自动占用所有core?core数量一直在增加,直到达到队列最大值,然后就卡住了,这flink1.11啥情况啊?  



Reply | Threaded
Open this post in threaded view
|

回复:flink1.11启动问题

酷酷的浑蛋
我找到问题了,我觉得我发现了一个bug,很严重,会导致flink持续占资源,一直增加




在2020年07月22日 14:08,酷酷的浑蛋<[hidden email]> 写道:
这是我的启动命令:./bin/flink run -m yarn-cluster -p 2 -ys 2 -yqu rt_constant -c com.xx.Main -yjm 1024 -ynm RTC_TEST xx.jar
任务到yarn上后就一直在占用core,core数量和内存数量一直在增加




在2020年07月22日 12:48,JasonLee<[hidden email]> 写道:
HI
你使用的什么模式?启动任务的命令发出来看一下吧


| |
JasonLee
|
|
邮箱:[hidden email]
|

Signature is customized by Netease Mail Master

在2020年07月22日 12:44,酷酷的浑蛋 写道:
现在是为什么啊?启动任务自动占用所有core?core数量一直在增加,直到达到队列最大值,然后就卡住了,这flink1.11啥情况啊?  



Reply | Threaded
Open this post in threaded view
|

Re: flink1.11启动问题

Leonard Xu
Hello,
可以描述下这个问题吗? 如果确认是bug的话可以去jira上开个issue的。

祝好
Leonard Xu

> 在 2020年7月22日,20:46,酷酷的浑蛋 <[hidden email]> 写道:
>
> 我找到问题了,我觉得我发现了一个bug,很严重,会导致flink持续占资源,一直增加
>
>
>
>
> 在2020年07月22日 14:08,酷酷的浑蛋<[hidden email]> 写道:
> 这是我的启动命令:./bin/flink run -m yarn-cluster -p 2 -ys 2 -yqu rt_constant -c com.xx.Main -yjm 1024 -ynm RTC_TEST xx.jar
> 任务到yarn上后就一直在占用core,core数量和内存数量一直在增加
>
>
>
>
> 在2020年07月22日 12:48,JasonLee<[hidden email]> 写道:
> HI
> 你使用的什么模式?启动任务的命令发出来看一下吧
>
>
> | |
> JasonLee
> |
> |
> 邮箱:[hidden email]
> |
>
> Signature is customized by Netease Mail Master
>
> 在2020年07月22日 12:44,酷酷的浑蛋 写道:
> 现在是为什么啊?启动任务自动占用所有core?core数量一直在增加,直到达到队列最大值,然后就卡住了,这flink1.11啥情况啊?  
>
>
>