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

digraph G { subgraph clusterstage_1896 { label="Stage 1896"; 19912 [labelType="html" label="SQLExecutionRDD [19912] run at <unknown>:0"]; 19920 [labelType="html" label="SQLExecutionRDD [19920] toJavaRDD at <unknown>:0"]; 19922 [labelType="html" label="PythonRDD [19922] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44561 { label="MicroBatchScan"; 19908 [labelType="html" label="DataSourceRDD [19908] run at <unknown>:0"]; 19909 [labelType="html" label="MapPartitionsRDD [19909] run at <unknown>:0"]; } subgraph cluster44560 { label="Project"; 19910 [labelType="html" label="MapPartitionsRDD [19910] run at <unknown>:0"]; } subgraph cluster44556 { label="WholeStageCodegen (1)"; 19911 [labelType="html" label="MapPartitionsRDD [19911] run at <unknown>:0"]; } subgraph cluster44570 { label="WholeStageCodegen (1)"; 19913 [labelType="html" label="MapPartitionsRDD [19913] toJavaRDD at <unknown>:0"]; } subgraph cluster44569 { label="Filter"; 19914 [labelType="html" label="MapPartitionsRDD [19914] toJavaRDD at <unknown>:0"]; } subgraph cluster44568 { label="Project"; 19915 [labelType="html" label="MapPartitionsRDD [19915] toJavaRDD at <unknown>:0"]; } subgraph cluster44565 { label="WholeStageCodegen (2)"; 19916 [labelType="html" label="MapPartitionsRDD [19916] toJavaRDD at <unknown>:0"]; } subgraph cluster44564 { label="Project"; 19917 [labelType="html" label="MapPartitionsRDD [19917] toJavaRDD at <unknown>:0"]; } subgraph cluster44563 { label="DeserializeToObject"; 19918 [labelType="html" label="MapPartitionsRDD [19918] toJavaRDD at <unknown>:0"]; } subgraph cluster44562 { label="MapPartitions"; 19919 [labelType="html" label="MapPartitionsRDD [19919] toJavaRDD at <unknown>:0"]; } subgraph cluster44572 { label="mapPartitions"; 19921 [labelType="html" label="MapPartitionsRDD [19921] toJavaRDD at <unknown>:0"]; } } 19908->19909; 19909->19910; 19910->19911; 19911->19912; 19912->19913; 19913->19914; 19914->19915; 19915->19916; 19916->19917; 19917->19918; 19918->19919; 19919->19920; 19920->19921; 19921->19922; }

Event Timeline

Enable zooming