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

digraph G { subgraph clusterstage_1891 { label="Stage 1891"; 19855 [labelType="html" label="SQLExecutionRDD [19855] run at <unknown>:0"]; 19863 [labelType="html" label="SQLExecutionRDD [19863] toJavaRDD at <unknown>:0"]; 19865 [labelType="html" label="PythonRDD [19865] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44428 { label="MicroBatchScan"; 19851 [labelType="html" label="DataSourceRDD [19851] run at <unknown>:0"]; 19852 [labelType="html" label="MapPartitionsRDD [19852] run at <unknown>:0"]; } subgraph cluster44427 { label="Project"; 19853 [labelType="html" label="MapPartitionsRDD [19853] run at <unknown>:0"]; } subgraph cluster44423 { label="WholeStageCodegen (1)"; 19854 [labelType="html" label="MapPartitionsRDD [19854] run at <unknown>:0"]; } subgraph cluster44437 { label="WholeStageCodegen (1)"; 19856 [labelType="html" label="MapPartitionsRDD [19856] toJavaRDD at <unknown>:0"]; } subgraph cluster44436 { label="Filter"; 19857 [labelType="html" label="MapPartitionsRDD [19857] toJavaRDD at <unknown>:0"]; } subgraph cluster44435 { label="Project"; 19858 [labelType="html" label="MapPartitionsRDD [19858] toJavaRDD at <unknown>:0"]; } subgraph cluster44432 { label="WholeStageCodegen (2)"; 19859 [labelType="html" label="MapPartitionsRDD [19859] toJavaRDD at <unknown>:0"]; } subgraph cluster44431 { label="Project"; 19860 [labelType="html" label="MapPartitionsRDD [19860] toJavaRDD at <unknown>:0"]; } subgraph cluster44430 { label="DeserializeToObject"; 19861 [labelType="html" label="MapPartitionsRDD [19861] toJavaRDD at <unknown>:0"]; } subgraph cluster44429 { label="MapPartitions"; 19862 [labelType="html" label="MapPartitionsRDD [19862] toJavaRDD at <unknown>:0"]; } subgraph cluster44439 { label="mapPartitions"; 19864 [labelType="html" label="MapPartitionsRDD [19864] toJavaRDD at <unknown>:0"]; } } 19851->19852; 19852->19853; 19853->19854; 19854->19855; 19855->19856; 19856->19857; 19857->19858; 19858->19859; 19859->19860; 19860->19861; 19861->19862; 19862->19863; 19863->19864; 19864->19865; }

Event Timeline

Enable zooming