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

digraph G { subgraph clusterstage_1123 { label="Stage 1123"; 11807 [labelType="html" label="SQLExecutionRDD [11807] run at <unknown>:0"]; 11815 [labelType="html" label="SQLExecutionRDD [11815] toJavaRDD at <unknown>:0"]; 11817 [labelType="html" label="PythonRDD [11817] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster26415 { label="MicroBatchScan"; 11803 [labelType="html" label="DataSourceRDD [11803] run at <unknown>:0"]; 11804 [labelType="html" label="MapPartitionsRDD [11804] run at <unknown>:0"]; } subgraph cluster26414 { label="Project"; 11805 [labelType="html" label="MapPartitionsRDD [11805] run at <unknown>:0"]; } subgraph cluster26410 { label="WholeStageCodegen (1)"; 11806 [labelType="html" label="MapPartitionsRDD [11806] run at <unknown>:0"]; } subgraph cluster26424 { label="WholeStageCodegen (1)"; 11808 [labelType="html" label="MapPartitionsRDD [11808] toJavaRDD at <unknown>:0"]; } subgraph cluster26423 { label="Filter"; 11809 [labelType="html" label="MapPartitionsRDD [11809] toJavaRDD at <unknown>:0"]; } subgraph cluster26422 { label="Project"; 11810 [labelType="html" label="MapPartitionsRDD [11810] toJavaRDD at <unknown>:0"]; } subgraph cluster26419 { label="WholeStageCodegen (2)"; 11811 [labelType="html" label="MapPartitionsRDD [11811] toJavaRDD at <unknown>:0"]; } subgraph cluster26418 { label="Project"; 11812 [labelType="html" label="MapPartitionsRDD [11812] toJavaRDD at <unknown>:0"]; } subgraph cluster26417 { label="DeserializeToObject"; 11813 [labelType="html" label="MapPartitionsRDD [11813] toJavaRDD at <unknown>:0"]; } subgraph cluster26416 { label="MapPartitions"; 11814 [labelType="html" label="MapPartitionsRDD [11814] toJavaRDD at <unknown>:0"]; } subgraph cluster26426 { label="mapPartitions"; 11816 [labelType="html" label="MapPartitionsRDD [11816] toJavaRDD at <unknown>:0"]; } } 11803->11804; 11804->11805; 11805->11806; 11806->11807; 11807->11808; 11808->11809; 11809->11810; 11810->11811; 11811->11812; 11812->11813; 11813->11814; 11814->11815; 11815->11816; 11816->11817; }

Event Timeline

Enable zooming