crp-order-quantity-kpi-service - Details for Stage 191226 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 1 s
Locality Level Summary: Process local: 30
Input Size / Records: 6.5 MiB / 60
Shuffle Write Size / Records: 6.6 MiB / 351756
Associated Job Ids: 52791

digraph G { id="graph_191226"; subgraph graph_stage_191226 { id="graph_stage_191226"; isCluster="true"; label="Stage 191226"; subgraph cluster_1113637 { id="cluster_1113637"; isCluster="true"; label="Exchange"; 426200 [id="node_426200" labelType="html" label="ShuffledRowRDD [426200] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113634 { id="cluster_1113634"; isCluster="true"; label="WholeStageCodegen (7)"; 426201 [id="node_426201" labelType="html" label="MapPartitionsRDD [426201] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113633 { id="cluster_1113633"; isCluster="true"; label="SortAggregate"; 426202 [id="node_426202" labelType="html" label="MapPartitionsRDD [426202] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113632 { id="cluster_1113632"; isCluster="true"; label="InMemoryTableScan"; 426203 [id="node_426203" labelType="html" label="MapPartitionsRDD [426203] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426204 [id="node_426204" labelType="html" label="SortAggregate(key=[demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289], functions=[first(kpis#6873317, false)], output=[shardId#6552497, worklistShardItemId#6552498L, qty#6873308, demandChannel#6873288, demandStream#6873289, kpis#6873430])\n+- *(7) Sort [demandChannel#6873288 ASC NULLS FIRST, shardId#6552497 ASC NULLS FIRST, qty#6873308 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST, demandStream#6873289 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L, demandStream#6873289, 30), ENSURE_REQUIREMENTS, [plan_id=29068862]\n +- SortAggregate(key=[demandChannel#6873288, shardId#6552497, knownfloatingpointnormalized(normalizenanandzero(qty#6873308)) AS qty#6873308, worklistShardItemId#6552498L, demandStream#6873289], functions=[partial_first(kpis#6873317, false)], output=[demandChannel#6873288, shardId#6552497, qty#6873308, worklistShardItemId#6552498L... [426204] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113744 { id="cluster_1113744"; isCluster="true"; label="InMemoryTableScan"; 426211 [id="node_426211" labelType="html" label="MapPartitionsRDD [426211] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426212 [id="node_426212" labelType="html" label="MapPartitionsRDD [426212] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 426213 [id="node_426213" labelType="html" label="MapPartitionsRDD [426213] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113741 { id="cluster_1113741"; isCluster="true"; label="WholeStageCodegen (1)"; 426214 [id="node_426214" labelType="html" label="MapPartitionsRDD [426214] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113740 { id="cluster_1113740"; isCluster="true"; label="Exchange"; 426215 [id="node_426215" labelType="html" label="MapPartitionsRDD [426215] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 426200->426201; 426201->426202; 426202->426203; 426203->426204; 426204->426211; 426211->426212; 426212->426213; 426213->426214; 426214->426215; }

426199,426200

426204

Event Timeline

Enable zooming