processing-stream-kafka-raw-to-minio - Details for Stage 47 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 3
Input Size / Records: 0.0 B / 482
Associated Job Ids: 47

digraph G { subgraph clusterstage_47 { label="Stage 47"; 493 [labelType="html" label="SQLExecutionRDD [493] run at <unknown>:0"]; 501 [labelType="html" label="SQLExecutionRDD [501] toJavaRDD at <unknown>:0"]; 503 [labelType="html" label="PythonRDD [503] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1094 { label="MicroBatchScan"; 489 [labelType="html" label="DataSourceRDD [489] run at <unknown>:0"]; 490 [labelType="html" label="MapPartitionsRDD [490] run at <unknown>:0"]; } subgraph cluster1093 { label="Project"; 491 [labelType="html" label="MapPartitionsRDD [491] run at <unknown>:0"]; } subgraph cluster1089 { label="WholeStageCodegen (1)"; 492 [labelType="html" label="MapPartitionsRDD [492] run at <unknown>:0"]; } subgraph cluster1103 { label="WholeStageCodegen (1)"; 494 [labelType="html" label="MapPartitionsRDD [494] toJavaRDD at <unknown>:0"]; } subgraph cluster1102 { label="Filter"; 495 [labelType="html" label="MapPartitionsRDD [495] toJavaRDD at <unknown>:0"]; } subgraph cluster1101 { label="Project"; 496 [labelType="html" label="MapPartitionsRDD [496] toJavaRDD at <unknown>:0"]; } subgraph cluster1098 { label="WholeStageCodegen (2)"; 497 [labelType="html" label="MapPartitionsRDD [497] toJavaRDD at <unknown>:0"]; } subgraph cluster1097 { label="Project"; 498 [labelType="html" label="MapPartitionsRDD [498] toJavaRDD at <unknown>:0"]; } subgraph cluster1096 { label="DeserializeToObject"; 499 [labelType="html" label="MapPartitionsRDD [499] toJavaRDD at <unknown>:0"]; } subgraph cluster1095 { label="MapPartitions"; 500 [labelType="html" label="MapPartitionsRDD [500] toJavaRDD at <unknown>:0"]; } subgraph cluster1105 { label="mapPartitions"; 502 [labelType="html" label="MapPartitionsRDD [502] toJavaRDD at <unknown>:0"]; } } 489->490; 490->491; 491->492; 492->493; 493->494; 494->495; 495->496; 496->497; 497->498; 498->499; 499->500; 500->501; 501->502; 502->503; }

Event Timeline

Enable zooming