[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110493361 [Test build #34531 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/34531/consoleFull) for PR 6423 at commit [`7e8e0fe`](https://gith

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110492305 Merged build started. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110492262 Merged build triggered. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread massie
Github user massie commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110490995 @JoshRosen Makes sense: I'll update the title. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your pro

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread massie
Github user massie commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110490313 @squito Just pushed an update which includes all your suggestions. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32057774 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -97,14 +96,12 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32057745 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,17 +34,52 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32057720 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,17 +34,52 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread JoshRosen
Github user JoshRosen commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110484641 Can we update the PR title to better reflect the changes here? Maybe something succinct that explains how we're pulling the deserialization higher up the read path st

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110477498 @massie my sailing lingo is pretty rusty, but I'll try to keep it going -- the PR's telltales are smoothly streaming aft now --- If your project is set up for it, you ca

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110467002 [Test build #34517 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/34517/console) for PR 6423 at commit [`7c8f73e`](https://github.

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110467019 Merged build finished. Test PASSed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110466570 I left a few more minor comments, but otherwise this lgtm --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32050912 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,17 +34,52 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32050679 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -272,7 +275,7 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32048775 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -97,14 +96,12 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32048671 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,17 +34,52 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110461297 ack, sorry @massie the code sample I gave you had bad style ... I always forget the spaces after `,` ... --- If your project is set up for it, you can reply to this emai

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110457618 [Test build #34522 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/34522/console) for PR 6423 at commit [`01e8721`](https://github.

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110457622 Merged build finished. Test FAILed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110457264 [Test build #34522 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/34522/consoleFull) for PR 6423 at commit [`01e8721`](https://gith

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110456826 Merged build triggered. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110456897 Merged build started. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32046806 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,11 +33,34 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32042413 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,11 +33,34 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32040367 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,11 +33,34 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110439557 [Test build #34517 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/34517/consoleFull) for PR 6423 at commit [`7c8f73e`](https://gith

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110438915 Merged build started. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110438887 Merged build triggered. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread massie
Github user massie commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110438760 @squito I fixed the Scala style issue and updated the `HashShuffleReader` to close each Block `InputStream` sooner -- immediately after all records are read. I h

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32038003 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,11 +33,34 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32017015 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,11 +33,34 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110364223 thanks @massie. That makes more sense now -- in fact I should have seen the jira had a link to https://issues.apache.org/jira/browse/SPARK-7263 , my mistake. --- If

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-09 Thread squito
Github user squito commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r32013943 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,11 +33,34 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110184535 Merged build finished. Test PASSed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110184510 [Test build #34471 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/34471/console) for PR 6423 at commit [`208b7a5`](https://github.

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110167932 [Test build #34471 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/34471/consoleFull) for PR 6423 at commit [`208b7a5`](https://gith

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110167831 Merged build triggered. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110167852 Merged build started. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread massie
Github user massie commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110166232 @squito I appreciate the feedback. No need to apologize for asking for an explanation of why this PR is important. This work is only indirectly related to Parquet

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31966729 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -79,11 +78,11 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31966686 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,11 +33,34 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread squito
Github user squito commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31963930 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,11 +33,34 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread squito
Github user squito commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31963587 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -79,11 +78,11 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread squito
Github user squito commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-110151707 I really appreciate keeping the PR small in scope to make it easier to review -- but I am also a little torn that I have a hard time seeing concretely the advantage of th

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-08 Thread squito
Github user squito commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31962636 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -298,11 +294,9 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-02 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-108137660 [Test build #34026 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/34026/consoleFull) for PR 6423 at commit [`b70c945`](https://git

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-02 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-108137667 Merged build finished. Test PASSed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-02 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-108114244 [Test build #34026 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/34026/consoleFull) for PR 6423 at commit [`b70c945`](https://gith

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-02 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-108113358 Merged build triggered. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-02 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-108113372 Merged build started. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-02 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31542306 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -290,22 +287,15 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-02 Thread massie
Github user massie commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-108002390 Thanks for the tip. I'll make sure to leave the commits separate moving forward. I looked into the use of `Try` between the `BlockStoreShuffleFetcher` and `Shuff

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-02 Thread JoshRosen
Github user JoshRosen commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107998999 By the way, you don't need to squash your commits together, since our merge script will now take care of it when we commit things. Leaving them separate makes it easi

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107821941 [Test build #33954 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/33954/consoleFull) for PR 6423 at commit [`19135f2`](https://git

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107821971 Merged build finished. Test PASSed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107798074 Merged build started. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107798174 [Test build #33954 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/33954/consoleFull) for PR 6423 at commit [`19135f2`](https://gith

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107798025 Merged build triggered. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread massie
Github user massie commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107796875 Jenkins, test this please. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have t

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread massie
Github user massie commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107764072 I understand what it causing the tests to fail. I've have an update soon. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107733961 [Test build #33919 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/33919/consoleFull) for PR 6423 at commit [`e2078e8`](https://git

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107733973 Merged build finished. Test FAILed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread massie
Github user massie commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107712346 I fixed the broken unit test, scala style issues, addressed the concerns that were raised, squashed the commits and rebased on the top of master. Keep the comment

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107711802 [Test build #33919 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/33919/consoleFull) for PR 6423 at commit [`e2078e8`](https://gith

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107710109 Merged build triggered. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-107710144 Merged build started. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-06-01 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31448383 --- Diff: core/src/test/scala/org/apache/spark/storage/ShuffleBlockFetcherIteratorSuite.scala --- @@ -17,21 +17,20 @@ package org.apache.spark.stor

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread kayousterhout
Github user kayousterhout commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31374250 --- Diff: core/src/test/scala/org/apache/spark/storage/ShuffleBlockFetcherIteratorSuite.scala --- @@ -17,21 +17,20 @@ package org.apache.spa

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106963545 Merged build finished. Test FAILed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106963534 [Test build #33778 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/33778/consoleFull) for PR 6423 at commit [`418b103`](https://git

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31371578 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala --- @@ -17,23 +17,22 @@ package org.apache.spark.shuffle

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31371560 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala --- @@ -53,12 +52,13 @@ private[hash] object BlockStoreShuffleFetch

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31371544 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,11 +33,34 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31371478 --- Diff: core/src/test/scala/org/apache/spark/storage/ShuffleBlockFetcherIteratorSuite.scala --- @@ -17,21 +17,20 @@ package org.apache.spark.stor

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31371407 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -313,6 +303,33 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31371387 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -313,6 +303,33 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread massie
Github user massie commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106952818 I rebased this work on ToT and added a new commit that uses an InputStream decorator to ensure that the buffer is released on `close()`. The code is a lot more cleaner wi

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106952736 [Test build #33778 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/33778/consoleFull) for PR 6423 at commit [`418b103`](https://gith

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106952623 Merged build triggered. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106952638 Merged build started. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31371101 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala --- @@ -17,23 +17,22 @@ package org.apache.spark.shuf

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31371083 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala --- @@ -53,12 +52,13 @@ private[hash] object BlockStoreShuffleFe

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31371019 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala --- @@ -33,11 +33,34 @@ private[spark] class HashShuffleReader[K, C](

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31370901 --- Diff: core/src/test/scala/org/apache/spark/storage/ShuffleBlockFetcherIteratorSuite.scala --- @@ -17,21 +17,20 @@ package org.apache.spark.s

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31370848 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -17,22 +17,23 @@ package org.apache.spark.storag

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31370774 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -290,22 +287,15 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31370568 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -313,6 +303,33 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31370480 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -313,6 +303,33 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106951335 Merged build finished. Test FAILed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106951332 [Test build #33777 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/33777/consoleFull) for PR 6423 at commit [`b12f912`](https://git

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31370405 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -313,6 +303,33 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31370342 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -313,6 +303,33 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106950972 Merged build started. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread SparkQA
Github user SparkQA commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106951064 [Test build #33777 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/33777/consoleFull) for PR 6423 at commit [`b12f912`](https://gith

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread AmplabJenkins
Github user AmplabJenkins commented on the pull request: https://github.com/apache/spark/pull/6423#issuecomment-106950963 Merged build triggered. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not h

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread massie
Github user massie commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31364286 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -298,11 +294,9 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31363983 --- Diff: core/src/main/scala/org/apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala --- @@ -17,23 +17,22 @@ package org.apache.spark.shuf

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31363070 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -298,11 +294,9 @@ final class ShuffleBlockFetcherIterator(

[GitHub] spark pull request: [SPARK-7884] Allow Spark shuffle APIs to be mo...

2015-05-29 Thread JoshRosen
Github user JoshRosen commented on a diff in the pull request: https://github.com/apache/spark/pull/6423#discussion_r31362756 --- Diff: core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala --- @@ -298,11 +294,9 @@ final class ShuffleBlockFetcherIterator(

  1   2   >