|
@@ -568,9 +568,10 @@ public class ProjectConsumer {
|
|
log.info("------- ProjectConsumer 发送消息成功, 主题 topic 为:" + topic + " 分区 partition 为:"
|
|
log.info("------- ProjectConsumer 发送消息成功, 主题 topic 为:" + topic + " 分区 partition 为:"
|
|
+ partition + " 偏移量为:" + offset + " 消息体为:" + taskJson);
|
|
+ partition + " 偏移量为:" + offset + " 消息体为:" + taskJson);
|
|
//4-6 发送成功过的同时创建 pod.yaml 文件并把文件地址存到 redis
|
|
//4-6 发送成功过的同时创建 pod.yaml 文件并把文件地址存到 redis
|
|
- // 选一个count 最少的 node
|
|
|
|
|
|
+ // 选一个 count 最少的 node
|
|
String currentNodeName = "";
|
|
String currentNodeName = "";
|
|
int currentCount = Integer.MAX_VALUE;
|
|
int currentCount = Integer.MAX_VALUE;
|
|
|
|
+ log.info("parseProject() 各节点已经预定的任务个数为:" + nodeListToCount);
|
|
for (NodeTO nodeTO : nodeListToCount) {
|
|
for (NodeTO nodeTO : nodeListToCount) {
|
|
int tempCount = nodeTO.getCount();
|
|
int tempCount = nodeTO.getCount();
|
|
String tempNodeName = nodeTO.getNodeName();
|
|
String tempNodeName = nodeTO.getNodeName();
|