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

digraph G { subgraph clusterstage_553 { label="Stage 553"; 5800 [labelType="html" label="SQLExecutionRDD [5800] run at <unknown>:0"]; 5814 [labelType="html" label="SQLExecutionRDD [5814] toJavaRDD at <unknown>:0"]; 5816 [labelType="html" label="PythonRDD [5816] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12977 { label="MicroBatchScan"; 5796 [labelType="html" label="DataSourceRDD [5796] run at <unknown>:0"]; 5797 [labelType="html" label="MapPartitionsRDD [5797] run at <unknown>:0"]; } subgraph cluster12976 { label="Project"; 5798 [labelType="html" label="MapPartitionsRDD [5798] run at <unknown>:0"]; } subgraph cluster12972 { label="WholeStageCodegen (1)"; 5799 [labelType="html" label="MapPartitionsRDD [5799] run at <unknown>:0"]; } subgraph cluster12994 { label="WholeStageCodegen (1)"; 5807 [labelType="html" label="MapPartitionsRDD [5807] toJavaRDD at <unknown>:0"]; } subgraph cluster12993 { label="Filter"; 5808 [labelType="html" label="MapPartitionsRDD [5808] toJavaRDD at <unknown>:0"]; } subgraph cluster12992 { label="Project"; 5809 [labelType="html" label="MapPartitionsRDD [5809] toJavaRDD at <unknown>:0"]; } subgraph cluster12989 { label="WholeStageCodegen (2)"; 5810 [labelType="html" label="MapPartitionsRDD [5810] toJavaRDD at <unknown>:0"]; } subgraph cluster12988 { label="Project"; 5811 [labelType="html" label="MapPartitionsRDD [5811] toJavaRDD at <unknown>:0"]; } subgraph cluster12987 { label="DeserializeToObject"; 5812 [labelType="html" label="MapPartitionsRDD [5812] toJavaRDD at <unknown>:0"]; } subgraph cluster12986 { label="MapPartitions"; 5813 [labelType="html" label="MapPartitionsRDD [5813] toJavaRDD at <unknown>:0"]; } subgraph cluster12996 { label="mapPartitions"; 5815 [labelType="html" label="MapPartitionsRDD [5815] toJavaRDD at <unknown>:0"]; } } 5796->5797; 5797->5798; 5798->5799; 5799->5800; 5800->5807; 5807->5808; 5808->5809; 5809->5810; 5810->5811; 5811->5812; 5812->5813; 5813->5814; 5814->5815; 5815->5816; }

Event Timeline

Enable zooming