3.5.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
DataHubScheduler
application UI
Details for Stage 26693 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.5 s
Locality Level Summary:
Process local: 1
Input Size / Records:
9.6 KiB / 1
Associated Job Ids:
17919
DAG Visualization
digraph G { subgraph clusterstage_26693 { label="Stage 26693"; subgraph cluster294752 { label="Exchange"; 117625 [labelType="html" label="ShuffledRowRDD [117625] [Unordered]<br>count at <unknown>:0"]; } subgraph cluster294753 { label="mapPartitionsInternal"; 117626 [labelType="html" label="MapPartitionsRDD [117626] [Unordered]<br>count at <unknown>:0"]; } subgraph cluster294754 { label="mapPartitionsInternal"; 117627 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=3993705]\n +- Project [brand_context_id#12010729, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#12010730, 64, true, false, true) AS NetworkID#12010773, Child_Node#12010731, Parent_id#12010732, supplier_id#12010733, preferrd_supplier_id#12010734, supplier_ref_id#12010735, supplier_uid#12010736, supplier_name#12010737, supplier_country#12010738, direct_indirect#12010739, source_type#12010740, product_name#12010741, tier#12010742, is_latest#12010743, is_latest_submitted#12010744, is_unknown_supplier#12010745, company_id#12010746, config_name#12010747, direct_supplier_name#12010748, launch_request_name#12010749, launch_config_ref#12010750, revision_version#12010751, submission_status#12010752, ... 23 more fields]\n +- Scan JDBCRelation((\nSELECT\n c.brand_context_id,\n c.NetworkID,\n c.Child_Node,\n c.Parent_id,\n ISNULL(c.supplier_i... [117627] [Cached] [Unordered]<br>count at <unknown>:0"]; } subgraph cluster294811 { label="InMemoryTableScan"; 117644 [labelType="html" label="MapPartitionsRDD [117644] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; 117645 [labelType="html" label="MapPartitionsRDD [117645] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; 117646 [labelType="html" label="MapPartitionsRDD [117646] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; } subgraph cluster294807 { label="WholeStageCodegen (1)"; 117647 [labelType="html" label="MapPartitionsRDD [117647] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; } subgraph cluster294806 { label="FlatMapGroupsInPandas"; 117648 [labelType="html" label="MapPartitionsRDD [117648] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; } subgraph cluster294800 { label="WholeStageCodegen (2)"; 117649 [labelType="html" label="MapPartitionsRDD [117649] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; } subgraph cluster294812 { label="mapPartitionsInternal"; 117650 [labelType="html" label="MapPartitionsRDD [117650] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; } } 117625->117626; 117626->117627; 117627->117644; 117644->117645; 117645->117646; 117646->117647; 117647->117648; 117648->117649; 117649->117650; }
117624,117625
117627
Event Timeline
Enable zooming
Tasks: 1. 1 Pages. Jump to
. Show
items in a page.
Go
Scheduler Delay
Task Deserialization Time
Shuffle Read Time
Executor Computing Time
Shuffle Write Time
Result Serialization Time
Getting Result Time