search

lw-lin / CoolplaySpark

酷玩 Spark: Spark 源代码解析、Spark 类库等
3.46k stars 1.41k forks source link

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

Open lw-lin opened 8 years ago

lw-lin commented 8 years ago

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

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

public static final thisIsJavaCode;
val thisIsScalaCode

谢谢！

jacksu commented 8 years ago

里面有几个图挂了

taojiang1982 commented 8 years ago

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

lw-lin commented 8 years ago

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

endymecy commented 8 years ago

有些图片出不来

wongxingjun commented 8 years ago

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

TopSpoofer commented 7 years ago

@lw-lin 

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

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

lw-lin commented 7 years ago

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

Hope it helps!

klion26 commented 7 years ago

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