3.5.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
DataHubScheduler
application UI
Details for Stage 34015 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.7 s
Locality Level Summary:
Process local: 1
Input Size / Records:
10.5 KiB / 1
Associated Job Ids:
24270
DAG Visualization
digraph G { subgraph clusterstage_34015 { label="Stage 34015"; subgraph cluster361485 { label="Exchange"; 149637 [labelType="html" label="ShuffledRowRDD [149637] [Unordered]<br>count at <unknown>:0"]; } subgraph cluster361486 { label="mapPartitionsInternal"; 149638 [labelType="html" label="MapPartitionsRDD [149638] [Unordered]<br>count at <unknown>:0"]; } subgraph cluster361487 { label="mapPartitionsInternal"; 149639 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=4247782]\n +- Project [brand_context_id#14300060, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, NetworkID#14300061, 64, true, false, true) AS NetworkID#14300104, Child_Node#14300062, Parent_id#14300063, supplier_id#14300064, preferrd_supplier_id#14300065, supplier_ref_id#14300066, supplier_uid#14300067, supplier_name#14300068, supplier_country#14300069, direct_indirect#14300070, source_type#14300071, product_name#14300072, tier#14300073, is_latest#14300074, is_latest_submitted#14300075, is_unknown_supplier#14300076, company_id#14300077, config_name#14300078, direct_supplier_name#14300079, launch_request_name#14300080, launch_config_ref#14300081, revision_version#14300082, submission_status#14300083, ... 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... [149639] [Cached] [Unordered]<br>count at <unknown>:0"]; } subgraph cluster361544 { label="InMemoryTableScan"; 149656 [labelType="html" label="MapPartitionsRDD [149656] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; 149657 [labelType="html" label="MapPartitionsRDD [149657] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; 149658 [labelType="html" label="MapPartitionsRDD [149658] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; } subgraph cluster361540 { label="WholeStageCodegen (1)"; 149659 [labelType="html" label="MapPartitionsRDD [149659] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; } subgraph cluster361539 { label="FlatMapGroupsInPandas"; 149660 [labelType="html" label="MapPartitionsRDD [149660] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; } subgraph cluster361533 { label="WholeStageCodegen (2)"; 149661 [labelType="html" label="MapPartitionsRDD [149661] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; } subgraph cluster361545 { label="mapPartitionsInternal"; 149662 [labelType="html" label="MapPartitionsRDD [149662] [Unordered]<br>collect at /opt/app/scheduler/jobs/memgraph_declared_loader_job.py:1104"]; } } 149637->149638; 149638->149639; 149639->149656; 149656->149657; 149657->149658; 149658->149659; 149659->149660; 149660->149661; 149661->149662; }
149636,149637
149639
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