Skip to content

Conversation

@sarutak
Copy link
Member

@sarutak sarutak commented Nov 3, 2015

When we call AsyncRDDActions#takeAsync, actually another DAGScheduler#runJob is called from another thread so we cannot get proper callsite infomation.

Following screenshots are before this patch applied and after.

Before:
2015-11-04 1 26 40
2015-11-04 1 26 52

After:
2015-11-04 0 48 07
2015-11-04 0 48 26

@SparkQA
Copy link

SparkQA commented Nov 3, 2015

Test build #44935 has finished for PR 9437 at commit cb38f14.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@andrewor14
Copy link
Contributor

Is this also a problem for collectAsync and countAsync?

@sarutak
Copy link
Member Author

sarutak commented Nov 15, 2015

I don't think collectAsync and countAsync cause this issue.
It's because takeAsync calls ComplexFutureAction#run.

@andrewor14
Copy link
Contributor

retest this please

@SparkQA
Copy link

SparkQA commented Nov 16, 2015

Test build #46007 has finished for PR 9437 at commit cb38f14.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds no public classes.

@andrewor14
Copy link
Contributor

Merging into master 1.6, thanks!

asfgit pushed a commit that referenced this pull request Nov 17, 2015
…ncRDDActions#takeAsync

When we call AsyncRDDActions#takeAsync, actually another DAGScheduler#runJob is called from another thread so we cannot get proper callsite infomation.

Following screenshots are before this patch applied and after.

Before:
<img width="1268" alt="2015-11-04 1 26 40" src="https://cloud.githubusercontent.com/assets/4736016/10914069/0ffc1306-8294-11e5-8e89-c4fadf58dd12.png">
<img width="1258" alt="2015-11-04 1 26 52" src="https://cloud.githubusercontent.com/assets/4736016/10914070/0ffe84ce-8294-11e5-8b2a-69d36276bedb.png">

After:
<img width="1268" alt="2015-11-04 0 48 07" src="https://cloud.githubusercontent.com/assets/4736016/10914080/1d8cfb7a-8294-11e5-9e09-ede25c2563e8.png">
<img width="1269" alt="2015-11-04 0 48 26" src="https://cloud.githubusercontent.com/assets/4736016/10914081/1d934e3a-8294-11e5-8b5e-e3dc37aaced3.png">

Author: Kousuke Saruta <[email protected]>

Closes #9437 from sarutak/SPARK-11480.

(cherry picked from commit 30f3cfd)
Signed-off-by: Andrew Or <[email protected]>
@asfgit asfgit closed this in 30f3cfd Nov 17, 2015
@sarutak sarutak deleted the SPARK-11480 branch June 4, 2021 20:46
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants