From c2e255f6d1acfb683223a6dadeee0fdeaef0840e Mon Sep 17 00:00:00 2001 From: MaBiao Date: Sat, 16 Jul 2016 17:15:10 +0800 Subject: [PATCH] [SPARK-16587] Add the missing annotation --- .../spark/network/shuffle/protocol/BlockTransferMessage.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/BlockTransferMessage.java b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/BlockTransferMessage.java index 9af6759f5d5f3..de54a81b0f2fb 100644 --- a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/BlockTransferMessage.java +++ b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/BlockTransferMessage.java @@ -35,6 +35,9 @@ * shuffle service. It returns a StreamHandle. * - UploadBlock is only handled by the NettyBlockTransferService. * - RegisterExecutor is only handled by the external shuffle service. + * - StreamHandle is only handled by the OneForOneBlockFetcher. + * - RegisterDriver is only handled by the MesosExternalShuffleService. + * - HearBeat is only handled by the MesosExternalShuffleService. */ public abstract class BlockTransferMessage implements Encodable { protected abstract Type type();