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

digraph G { subgraph clusterstage_130 { label="Stage 130"; 1369 [labelType="html" label="SQLExecutionRDD [1369] run at <unknown>:0"]; 1377 [labelType="html" label="SQLExecutionRDD [1377] toJavaRDD at <unknown>:0"]; 1379 [labelType="html" label="PythonRDD [1379] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3060 { label="MicroBatchScan"; 1365 [labelType="html" label="DataSourceRDD [1365] run at <unknown>:0"]; 1366 [labelType="html" label="MapPartitionsRDD [1366] run at <unknown>:0"]; } subgraph cluster3059 { label="Project"; 1367 [labelType="html" label="MapPartitionsRDD [1367] run at <unknown>:0"]; } subgraph cluster3055 { label="WholeStageCodegen (1)"; 1368 [labelType="html" label="MapPartitionsRDD [1368] run at <unknown>:0"]; } subgraph cluster3069 { label="WholeStageCodegen (1)"; 1370 [labelType="html" label="MapPartitionsRDD [1370] toJavaRDD at <unknown>:0"]; } subgraph cluster3068 { label="Filter"; 1371 [labelType="html" label="MapPartitionsRDD [1371] toJavaRDD at <unknown>:0"]; } subgraph cluster3067 { label="Project"; 1372 [labelType="html" label="MapPartitionsRDD [1372] toJavaRDD at <unknown>:0"]; } subgraph cluster3064 { label="WholeStageCodegen (2)"; 1373 [labelType="html" label="MapPartitionsRDD [1373] toJavaRDD at <unknown>:0"]; } subgraph cluster3063 { label="Project"; 1374 [labelType="html" label="MapPartitionsRDD [1374] toJavaRDD at <unknown>:0"]; } subgraph cluster3062 { label="DeserializeToObject"; 1375 [labelType="html" label="MapPartitionsRDD [1375] toJavaRDD at <unknown>:0"]; } subgraph cluster3061 { label="MapPartitions"; 1376 [labelType="html" label="MapPartitionsRDD [1376] toJavaRDD at <unknown>:0"]; } subgraph cluster3071 { label="mapPartitions"; 1378 [labelType="html" label="MapPartitionsRDD [1378] toJavaRDD at <unknown>:0"]; } } 1365->1366; 1366->1367; 1367->1368; 1368->1369; 1369->1370; 1370->1371; 1371->1372; 1372->1373; 1373->1374; 1374->1375; 1375->1376; 1376->1377; 1377->1378; 1378->1379; }

Event Timeline

Enable zooming