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

digraph G { subgraph clusterstage_244 { label="Stage 244"; 2566 [labelType="html" label="SQLExecutionRDD [2566] run at <unknown>:0"]; 2574 [labelType="html" label="SQLExecutionRDD [2574] toJavaRDD at <unknown>:0"]; 2576 [labelType="html" label="PythonRDD [2576] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster5739 { label="MicroBatchScan"; 2562 [labelType="html" label="DataSourceRDD [2562] run at <unknown>:0"]; 2563 [labelType="html" label="MapPartitionsRDD [2563] run at <unknown>:0"]; } subgraph cluster5738 { label="Project"; 2564 [labelType="html" label="MapPartitionsRDD [2564] run at <unknown>:0"]; } subgraph cluster5734 { label="WholeStageCodegen (1)"; 2565 [labelType="html" label="MapPartitionsRDD [2565] run at <unknown>:0"]; } subgraph cluster5748 { label="WholeStageCodegen (1)"; 2567 [labelType="html" label="MapPartitionsRDD [2567] toJavaRDD at <unknown>:0"]; } subgraph cluster5747 { label="Filter"; 2568 [labelType="html" label="MapPartitionsRDD [2568] toJavaRDD at <unknown>:0"]; } subgraph cluster5746 { label="Project"; 2569 [labelType="html" label="MapPartitionsRDD [2569] toJavaRDD at <unknown>:0"]; } subgraph cluster5743 { label="WholeStageCodegen (2)"; 2570 [labelType="html" label="MapPartitionsRDD [2570] toJavaRDD at <unknown>:0"]; } subgraph cluster5742 { label="Project"; 2571 [labelType="html" label="MapPartitionsRDD [2571] toJavaRDD at <unknown>:0"]; } subgraph cluster5741 { label="DeserializeToObject"; 2572 [labelType="html" label="MapPartitionsRDD [2572] toJavaRDD at <unknown>:0"]; } subgraph cluster5740 { label="MapPartitions"; 2573 [labelType="html" label="MapPartitionsRDD [2573] toJavaRDD at <unknown>:0"]; } subgraph cluster5750 { label="mapPartitions"; 2575 [labelType="html" label="MapPartitionsRDD [2575] toJavaRDD at <unknown>:0"]; } } 2562->2563; 2563->2564; 2564->2565; 2565->2566; 2566->2567; 2567->2568; 2568->2569; 2569->2570; 2570->2571; 2571->2572; 2572->2573; 2573->2574; 2574->2575; 2575->2576; }

Event Timeline

Enable zooming