- Dec 28, 2010
-
-
Mosharaf Chowdhury authored
Updating reception stats before consuming. Can create trouble if there is any exception during consumption (less likely,) but this frees up splits that threads can connect to instead of idling around.
-
Mosharaf Chowdhury authored
- Fixed several bugs. (Copy-paste is the bane of coding :|)
-
Mosharaf Chowdhury authored
- Moved ShuffleTrackerStrategy to a separate file.
-
Mosharaf Chowdhury authored
-
- Dec 27, 2010
-
-
Mosharaf Chowdhury authored
- Why ShuffleClient and ShuffleServerThread are crashing is still unknown.
-
Mosharaf Chowdhury authored
Bug fix: tracker (running in Spark master) wasn't initializing Shuffle object and was using inconsistent config values.
-
Mosharaf Chowdhury authored
-
- Dec 26, 2010
-
-
Mosharaf Chowdhury authored
Conflicts: conf/java-opts
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
Tracker framework is in place that supports pluggable tracker strategy. There are several bugs along with performance problems. - For larger data shuffle ShuffleServerThread gets "Broken Pipe" and ShuffleClient gets "Connection Reset" - There is a bug in the accounting counters of BalanceConnectionsShuffleTrackerStrategy. Some of them go below zero while decrementing which is not supposed to happen.
-
- Dec 24, 2010
-
-
Mosharaf Chowdhury authored
-
- Dec 22, 2010
-
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
CustomBlockedLocalFileShuffle has been added. This is essentially ManualBlockedLocalFileShuffle with our servers.
-
Mosharaf Chowdhury authored
There will be a new CustomBlockedLocalFileShuffle where 'Custom' will mean ManualBlockedLocalFileShuffle with custom server instead of jetty.
-
Mosharaf Chowdhury authored
We were serializing one (the wrong) thing, trying to deserialize another (the right thing).
-
Mosharaf Chowdhury authored
Added an in-memory implementation of CustomParalleLFS. There is a serialization/deserialization bug in the implementation.
-
Mosharaf Chowdhury authored
Fixed an indexing bug in HttpBlockedLocalFileShuffle. It still doesn't work on EC2 with >5 nodes cluster.
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
HttpBlockedLocalFileShuffle has also been converted to have per-reducer consumption thread. Works in local mesos, but NOT on EC2 :|
-
- Dec 21, 2010
-
-
Mosharaf Chowdhury authored
Upside: No synchronized blocking on "combiners" variable. 3x faster :) Downside: Inefficient implementation. Requiring too much temporary data. Approx. 2x increase in memory requirement :( Should be fixed at some point.
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
- Fixed config param loading bug in CustomParallelLFS
-
Mosharaf Chowdhury authored
-
- Dec 19, 2010
-
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
Conflicts: conf/java-opts src/scala/spark/BasicLocalFileShuffle.scala
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
Conflicts: conf/java-opts src/scala/spark/BlockedLocalFileShuffle.scala src/scala/spark/CustomBlockedLocalFileShuffle.scala src/scala/spark/HttpBlockedLocalFileShuffle.scala
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
Renamed BlockedLocalFileShuffle to HttpBlockedLocalFileShuffle for merging with the mos-shuffle branch.
-
- Dec 18, 2010
-
-
Mosharaf Chowdhury authored
- Clients now request for byte ranges to the server using an INDEX file.
-
- Dec 16, 2010
-
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
-
Mosharaf Chowdhury authored
- Config option related to pipelining has been removed. - Summary: Basic -> Pipelining / Parallel -> NO pipelining
-