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

digraph G { subgraph clusterstage_1901 { label="Stage 1901"; 19954 [labelType="html" label="SQLExecutionRDD [19954] run at <unknown>:0"]; 19968 [labelType="html" label="SQLExecutionRDD [19968] toJavaRDD at <unknown>:0"]; 19970 [labelType="html" label="PythonRDD [19970] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44655 { label="MicroBatchScan"; 19950 [labelType="html" label="DataSourceRDD [19950] run at <unknown>:0"]; 19951 [labelType="html" label="MapPartitionsRDD [19951] run at <unknown>:0"]; } subgraph cluster44654 { label="Project"; 19952 [labelType="html" label="MapPartitionsRDD [19952] run at <unknown>:0"]; } subgraph cluster44650 { label="WholeStageCodegen (1)"; 19953 [labelType="html" label="MapPartitionsRDD [19953] run at <unknown>:0"]; } subgraph cluster44672 { label="WholeStageCodegen (1)"; 19961 [labelType="html" label="MapPartitionsRDD [19961] toJavaRDD at <unknown>:0"]; } subgraph cluster44671 { label="Filter"; 19962 [labelType="html" label="MapPartitionsRDD [19962] toJavaRDD at <unknown>:0"]; } subgraph cluster44670 { label="Project"; 19963 [labelType="html" label="MapPartitionsRDD [19963] toJavaRDD at <unknown>:0"]; } subgraph cluster44667 { label="WholeStageCodegen (2)"; 19964 [labelType="html" label="MapPartitionsRDD [19964] toJavaRDD at <unknown>:0"]; } subgraph cluster44666 { label="Project"; 19965 [labelType="html" label="MapPartitionsRDD [19965] toJavaRDD at <unknown>:0"]; } subgraph cluster44665 { label="DeserializeToObject"; 19966 [labelType="html" label="MapPartitionsRDD [19966] toJavaRDD at <unknown>:0"]; } subgraph cluster44664 { label="MapPartitions"; 19967 [labelType="html" label="MapPartitionsRDD [19967] toJavaRDD at <unknown>:0"]; } subgraph cluster44674 { label="mapPartitions"; 19969 [labelType="html" label="MapPartitionsRDD [19969] toJavaRDD at <unknown>:0"]; } } 19950->19951; 19951->19952; 19952->19953; 19953->19954; 19954->19961; 19961->19962; 19962->19963; 19963->19964; 19964->19965; 19965->19966; 19966->19967; 19967->19968; 19968->19969; 19969->19970; }

Event Timeline

Enable zooming