[QIYI] feat(coordinator): log app on partition reassign

zuston · May 27, 2024 · 8e6d2a9 · 8e6d2a9
1 parent c0ec474
commit 8e6d2a9
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorGrpcService.java b/coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorGrpcService.java
@@ -119,16 +119,22 @@ public void getShuffleAssignments(
  final int estimateTaskConcurrency = request.getEstimateTaskConcurrency();
  final Set<String> faultyServerIds = new HashSet<>(request.getFaultyServerIdsList());
 
+ if (partitionNum == 1 && partitionNumPerRange == 1 && estimateTaskConcurrency == 1) {
+ LOG.info("AppId: {}, ShuffleId: {} triggers the partition reassign", appId, shuffleId);
+ }
+
  LOG.info(
  "Request of getShuffleAssignments for appId[{}], shuffleId[{}], partitionNum[{}], "
- + " partitionNumPerRange[{}], replica[{}], requiredTags[{}], requiredShuffleServerNumber[{}],faultyServerIds[{}]",
+ + " partitionNumPerRange[{}], replica[{}], requiredTags[{}], requiredShuffleServerNumber[{}], "
+ + " estimateTaskConcurrency[{}], faultyServerIds[{}]",
  appId,
  shuffleId,
  partitionNum,
  partitionNumPerRange,
  replica,
  requiredTags,
  requiredShuffleServerNumber,
+ estimateTaskConcurrency,
  faultyServerIds.size());
 
  GetShuffleAssignmentsResponse response;