Skip to content

GitLab

Explore

Sign in

Primary navigation

Project

S

spark
- Activity
- Members
- Labels
- Issues
- Issue boards
- Milestones
- Wiki
- Releases
- Model registry
- Environments
- Incidents

Snippets Groups Projects

5d3e917d

Commit 5d3e917d authored 12 years ago by Charles Reiss

Downloads
- Patches
- Plain Diff

Use Akka scheduler for BlockManager heart beats.

Adds required ActorSystem argument to BlockManager constructors.

parent b53dd28c

No related branches found

No related tags found

No related merge requests found

Changes 4

Hide whitespace changes

Inline Side-by-side

Showing

core/src/main/scala/spark/SparkEnv.scala 1 addition, 1 deletion

core/src/main/scala/spark/SparkEnv.scala
core/src/main/scala/spark/storage/BlockManager.scala 14 additions, 22 deletions

core/src/main/scala/spark/storage/BlockManager.scala
core/src/main/scala/spark/storage/ThreadingTest.scala 1 addition, 1 deletion

core/src/main/scala/spark/storage/ThreadingTest.scala
core/src/test/scala/spark/storage/BlockManagerSuite.scala 25 additions, 25 deletions

core/src/test/scala/spark/storage/BlockManagerSuite.scala

with 41 additions and 49 deletions

Loading

0% Loading or .

You are about to add 0 people to the discussion. Proceed with caution.

Finish editing this message first!

Please register or sign in to comment