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

digraph G { subgraph clusterstage_1942 { label="Stage 1942"; 20396 [labelType="html" label="SQLExecutionRDD [20396] run at <unknown>:0"]; 20410 [labelType="html" label="SQLExecutionRDD [20410] toJavaRDD at <unknown>:0"]; 20412 [labelType="html" label="PythonRDD [20412] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45638 { label="MicroBatchScan"; 20392 [labelType="html" label="DataSourceRDD [20392] run at <unknown>:0"]; 20393 [labelType="html" label="MapPartitionsRDD [20393] run at <unknown>:0"]; } subgraph cluster45637 { label="Project"; 20394 [labelType="html" label="MapPartitionsRDD [20394] run at <unknown>:0"]; } subgraph cluster45633 { label="WholeStageCodegen (1)"; 20395 [labelType="html" label="MapPartitionsRDD [20395] run at <unknown>:0"]; } subgraph cluster45655 { label="WholeStageCodegen (1)"; 20403 [labelType="html" label="MapPartitionsRDD [20403] toJavaRDD at <unknown>:0"]; } subgraph cluster45654 { label="Filter"; 20404 [labelType="html" label="MapPartitionsRDD [20404] toJavaRDD at <unknown>:0"]; } subgraph cluster45653 { label="Project"; 20405 [labelType="html" label="MapPartitionsRDD [20405] toJavaRDD at <unknown>:0"]; } subgraph cluster45650 { label="WholeStageCodegen (2)"; 20406 [labelType="html" label="MapPartitionsRDD [20406] toJavaRDD at <unknown>:0"]; } subgraph cluster45649 { label="Project"; 20407 [labelType="html" label="MapPartitionsRDD [20407] toJavaRDD at <unknown>:0"]; } subgraph cluster45648 { label="DeserializeToObject"; 20408 [labelType="html" label="MapPartitionsRDD [20408] toJavaRDD at <unknown>:0"]; } subgraph cluster45647 { label="MapPartitions"; 20409 [labelType="html" label="MapPartitionsRDD [20409] toJavaRDD at <unknown>:0"]; } subgraph cluster45657 { label="mapPartitions"; 20411 [labelType="html" label="MapPartitionsRDD [20411] toJavaRDD at <unknown>:0"]; } } 20392->20393; 20393->20394; 20394->20395; 20395->20396; 20396->20403; 20403->20404; 20404->20405; 20405->20406; 20406->20407; 20407->20408; 20408->20409; 20409->20410; 20410->20411; 20411->20412; }

Event Timeline

Enable zooming