关于local cluster的问题

[naisili Yuan <yu...@gmail.com>]

Hi all
我这边有写一个java服务去自动拉起本地flink cluster（单机模式）用来调试使用。我是直接调用的bin/start-cluster.sh脚本。
现在问题是每次重新发布服务之后，发现这个启动的会话jobmanager会自动增加一个，导致slots总数越来越高。研究半天始终没找到原因，希望获得帮助！
flink版本1.10.0

Re: 关于local cluster的问题

[Yang Wang <da...@gmail.com>]

start-cluster.sh每次就是会启动一个Standalone集群的，由于都是一个flink conf，所以新起的JM
肯定会因为端口冲突起不来，TM会注册在之前已经running的JM上。
如果你只是测试，用完以后，需要stop-cluster.sh停掉

如果是想在一个JVM里面进行测试，那可以用MiniCluster，所有的组件都会以线程模式启动


Best,
Yang

naisili Yuan <yu...@gmail.com> 于2020年6月30日周二 下午7:09写道：

> 不好意思没说清楚，跟提交任务没关系，只是执行start-cluster.sh后taskmanager就自动加一
>
> 发自我的iPhone
>
> > 在 2020年6月30日，18:54，"17610775726@163.com" <17...@163.com> 写道：
> >
> > hi
> > 你这个问题没有描述清楚啊 是提交一个任务jm就会自动启动一个?
> >
> >
> >
> > Best
> > JasonLee
> >
> > 发件人： naisili Yuan
> > 发送时间： 2020-06-30 18:29
> > 收件人： user-zh
> > 主题： 关于local cluster的问题
> > Hi all
> > 我这边有写一个java服务去自动拉起本地flink
> cluster（单机模式）用来调试使用。我是直接调用的bin/start-cluster.sh脚本。
> >
> 现在问题是每次重新发布服务之后，发现这个启动的会话jobmanager会自动增加一个，导致slots总数越来越高。研究半天始终没找到原因，希望获得帮助！
> > flink版本1.10.0
>

Re: 关于local cluster的问题

[naisili Yuan <yu...@gmail.com>]

不好意思没说清楚，跟提交任务没关系，只是执行start-cluster.sh后taskmanager就自动加一

发自我的iPhone

> 在 2020年6月30日，18:54，"17610775726@163.com" <17...@163.com> 写道：
> 
> hi 
> 你这个问题没有描述清楚啊 是提交一个任务jm就会自动启动一个?
> 
> 
> 
> Best
> JasonLee
> 
> 发件人： naisili Yuan
> 发送时间： 2020-06-30 18:29
> 收件人： user-zh
> 主题： 关于local cluster的问题
> Hi all
> 我这边有写一个java服务去自动拉起本地flink cluster（单机模式）用来调试使用。我是直接调用的bin/start-cluster.sh脚本。
> 现在问题是每次重新发布服务之后，发现这个启动的会话jobmanager会自动增加一个，导致slots总数越来越高。研究半天始终没找到原因，希望获得帮助！
> flink版本1.10.0

Re: 关于local cluster的问题

["17610775726@163.com" <17...@163.com>]

hi 
你这个问题没有描述清楚啊 是提交一个任务jm就会自动启动一个?



Best
JasonLee
 
发件人： naisili Yuan
发送时间： 2020-06-30 18:29
收件人： user-zh
主题： 关于local cluster的问题
Hi all
我这边有写一个java服务去自动拉起本地flink cluster（单机模式）用来调试使用。我是直接调用的bin/start-cluster.sh脚本。
现在问题是每次重新发布服务之后，发现这个启动的会话jobmanager会自动增加一个，导致slots总数越来越高。研究半天始终没找到原因，希望获得帮助！
flink版本1.10.0