processing-stream-kafka-raw-to-minio - Details for Stage 143 (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 / 510
Associated Job Ids: 143

digraph G { subgraph clusterstage_143 { label="Stage 143"; 1495 [labelType="html" label="SQLExecutionRDD [1495] run at <unknown>:0"]; 1509 [labelType="html" label="SQLExecutionRDD [1509] toJavaRDD at <unknown>:0"]; 1511 [labelType="html" label="PythonRDD [1511] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3342 { label="MicroBatchScan"; 1491 [labelType="html" label="DataSourceRDD [1491] run at <unknown>:0"]; 1492 [labelType="html" label="MapPartitionsRDD [1492] run at <unknown>:0"]; } subgraph cluster3341 { label="Project"; 1493 [labelType="html" label="MapPartitionsRDD [1493] run at <unknown>:0"]; } subgraph cluster3337 { label="WholeStageCodegen (1)"; 1494 [labelType="html" label="MapPartitionsRDD [1494] run at <unknown>:0"]; } subgraph cluster3359 { label="WholeStageCodegen (1)"; 1502 [labelType="html" label="MapPartitionsRDD [1502] toJavaRDD at <unknown>:0"]; } subgraph cluster3358 { label="Filter"; 1503 [labelType="html" label="MapPartitionsRDD [1503] toJavaRDD at <unknown>:0"]; } subgraph cluster3357 { label="Project"; 1504 [labelType="html" label="MapPartitionsRDD [1504] toJavaRDD at <unknown>:0"]; } subgraph cluster3354 { label="WholeStageCodegen (2)"; 1505 [labelType="html" label="MapPartitionsRDD [1505] toJavaRDD at <unknown>:0"]; } subgraph cluster3353 { label="Project"; 1506 [labelType="html" label="MapPartitionsRDD [1506] toJavaRDD at <unknown>:0"]; } subgraph cluster3352 { label="DeserializeToObject"; 1507 [labelType="html" label="MapPartitionsRDD [1507] toJavaRDD at <unknown>:0"]; } subgraph cluster3351 { label="MapPartitions"; 1508 [labelType="html" label="MapPartitionsRDD [1508] toJavaRDD at <unknown>:0"]; } subgraph cluster3361 { label="mapPartitions"; 1510 [labelType="html" label="MapPartitionsRDD [1510] toJavaRDD at <unknown>:0"]; } } 1491->1492; 1492->1493; 1493->1494; 1494->1495; 1495->1502; 1502->1503; 1503->1504; 1504->1505; 1505->1506; 1506->1507; 1507->1508; 1508->1509; 1509->1510; 1510->1511; }

Event Timeline

Enable zooming