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

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

digraph G { subgraph clusterstage_57 { label="Stage 57"; 592 [labelType="html" label="SQLExecutionRDD [592] run at <unknown>:0"]; 606 [labelType="html" label="SQLExecutionRDD [606] toJavaRDD at <unknown>:0"]; 608 [labelType="html" label="PythonRDD [608] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1321 { label="MicroBatchScan"; 588 [labelType="html" label="DataSourceRDD [588] run at <unknown>:0"]; 589 [labelType="html" label="MapPartitionsRDD [589] run at <unknown>:0"]; } subgraph cluster1320 { label="Project"; 590 [labelType="html" label="MapPartitionsRDD [590] run at <unknown>:0"]; } subgraph cluster1316 { label="WholeStageCodegen (1)"; 591 [labelType="html" label="MapPartitionsRDD [591] run at <unknown>:0"]; } subgraph cluster1338 { label="WholeStageCodegen (1)"; 599 [labelType="html" label="MapPartitionsRDD [599] toJavaRDD at <unknown>:0"]; } subgraph cluster1337 { label="Filter"; 600 [labelType="html" label="MapPartitionsRDD [600] toJavaRDD at <unknown>:0"]; } subgraph cluster1336 { label="Project"; 601 [labelType="html" label="MapPartitionsRDD [601] toJavaRDD at <unknown>:0"]; } subgraph cluster1333 { label="WholeStageCodegen (2)"; 602 [labelType="html" label="MapPartitionsRDD [602] toJavaRDD at <unknown>:0"]; } subgraph cluster1332 { label="Project"; 603 [labelType="html" label="MapPartitionsRDD [603] toJavaRDD at <unknown>:0"]; } subgraph cluster1331 { label="DeserializeToObject"; 604 [labelType="html" label="MapPartitionsRDD [604] toJavaRDD at <unknown>:0"]; } subgraph cluster1330 { label="MapPartitions"; 605 [labelType="html" label="MapPartitionsRDD [605] toJavaRDD at <unknown>:0"]; } subgraph cluster1340 { label="mapPartitions"; 607 [labelType="html" label="MapPartitionsRDD [607] toJavaRDD at <unknown>:0"]; } } 588->589; 589->590; 590->591; 591->592; 592->599; 599->600; 600->601; 601->602; 602->603; 603->604; 604->605; 605->606; 606->607; 607->608; }

Event Timeline

Enable zooming