《3.2 Receiver, ReceiverSupervisor, BlockGenerator, ReceivedBlockHandler 详解.md》讨论区

[lw-lin]

这里是 《3.2 Receiver, ReceiverSupervisor, BlockGenerator, ReceivedBlockHandler 详解.md》 讨论区。

如需要贴代码，请复制以下内容并修改：

public static final thisIsJavaCode;

val thisIsScalaCode

谢谢！

[jacksu]

里面有几个图挂了

[taojiang1982]

这里有个typo，“这 4 中 签名的 store() 的实现都是直接数据转给 ReceiverSupervisor”，“中” 应该改成“种”。

[lw-lin]

@taojiang1982 typo 已修正，感谢指出！

[endymecy]

有些图片出不来

[wongxingjun]

多个图片缺失，在imgs文件夹找不到，应该不是typo

[TopSpoofer]

@lw-lin

// 【开始执行两个 future、等待两个 future 都结束】
  val combinedFuture = storeInBlockManagerFuture.zip(storeInWriteAheadLogFuture).map(_._2)
  val walRecordHandle = Await.result(combinedFuture, blockStoreTimeout)

这里为什么是等待两个future结束？Await.result 不是等待storeInWriteAheadLogFuture 吗？

[lw-lin]

@TopSpoofer zip(...).map(...) 的过程，会执行两个 future，只不过 map 出来第 2 个的结果。具体的 Future 实现请见这里。

Hope it helps!

[klion26]

3 张图片显示不了的问题，提交了一个 PR，有空 review 下 https://github.com/lw-lin/CoolplaySpark/pull/24