Skip to content

Commit 892da74

Browse files
committed
delete duplicate check logic
1 parent ff7304e commit 892da74

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalBlockHandler.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -296,10 +296,6 @@ private int[] shuffleMapIdAndReduceIds(String[] blockIds, int shuffleId) {
296296
final int[] mapIdAndReduceIds = new int[2 * blockIds.length];
297297
for (int i = 0; i < blockIds.length; i++) {
298298
String[] blockIdParts = blockIds[i].split("_");
299-
if (blockIdParts.length == 5) {
300-
throw new IllegalArgumentException("Continuous shuffle block fetching only works for " +
301-
"new fetch protocol.");
302-
}
303299
if (blockIdParts.length != 4 || !blockIdParts[0].equals("shuffle")) {
304300
throw new IllegalArgumentException("Unexpected shuffle block id format: " + blockIds[i]);
305301
}

0 commit comments

Comments
 (0)