start-cluster.sh每次就是会启动一个Standalone集群的,由于都是一个flink conf,所以新起的JM
肯定会因为端口冲突起不来,TM会注册在之前已经running的JM上。
如果你只是测试,用完以后,需要stop-cluster.sh停掉
如果是想在一个JVM里面进行测试,那可以用MiniCluster,所有的组件都会以线程模式启动
Best,
Yang
naisili Yuan <
[hidden email]> 于2020年6月30日周二 下午7:09写道:
> 不好意思没说清楚,跟提交任务没关系,只是执行start-cluster.sh后taskmanager就自动加一
>
> 发自我的iPhone
>
> > 在 2020年6月30日,18:54,"
[hidden email]" <
[hidden email]> 写道:
> >
> > 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
>