conf/worker里的localhost改成四行就好了,会启动四个taskMananger和conf/conf/flink-conf.yaml 的配置项taskmanager.numberOfTaskSlots: 4 对应, 代表在本机启动的worker数。
欢迎分享,转载请注明来源:内存溢出
conf/worker里的localhost改成四行就好了,会启动四个taskMananger和conf/conf/flink-conf.yaml 的配置项taskmanager.numberOfTaskSlots: 4 对应, 代表在本机启动的worker数。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)