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

digraph G { subgraph clusterstage_1585 { label="Stage 1585"; 16658 [labelType="html" label="SQLExecutionRDD [16658] run at <unknown>:0"]; 16666 [labelType="html" label="SQLExecutionRDD [16666] toJavaRDD at <unknown>:0"]; 16668 [labelType="html" label="PythonRDD [16668] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37272 { label="MicroBatchScan"; 16654 [labelType="html" label="DataSourceRDD [16654] run at <unknown>:0"]; 16655 [labelType="html" label="MapPartitionsRDD [16655] run at <unknown>:0"]; } subgraph cluster37271 { label="Project"; 16656 [labelType="html" label="MapPartitionsRDD [16656] run at <unknown>:0"]; } subgraph cluster37267 { label="WholeStageCodegen (1)"; 16657 [labelType="html" label="MapPartitionsRDD [16657] run at <unknown>:0"]; } subgraph cluster37281 { label="WholeStageCodegen (1)"; 16659 [labelType="html" label="MapPartitionsRDD [16659] toJavaRDD at <unknown>:0"]; } subgraph cluster37280 { label="Filter"; 16660 [labelType="html" label="MapPartitionsRDD [16660] toJavaRDD at <unknown>:0"]; } subgraph cluster37279 { label="Project"; 16661 [labelType="html" label="MapPartitionsRDD [16661] toJavaRDD at <unknown>:0"]; } subgraph cluster37276 { label="WholeStageCodegen (2)"; 16662 [labelType="html" label="MapPartitionsRDD [16662] toJavaRDD at <unknown>:0"]; } subgraph cluster37275 { label="Project"; 16663 [labelType="html" label="MapPartitionsRDD [16663] toJavaRDD at <unknown>:0"]; } subgraph cluster37274 { label="DeserializeToObject"; 16664 [labelType="html" label="MapPartitionsRDD [16664] toJavaRDD at <unknown>:0"]; } subgraph cluster37273 { label="MapPartitions"; 16665 [labelType="html" label="MapPartitionsRDD [16665] toJavaRDD at <unknown>:0"]; } subgraph cluster37283 { label="mapPartitions"; 16667 [labelType="html" label="MapPartitionsRDD [16667] toJavaRDD at <unknown>:0"]; } } 16654->16655; 16655->16656; 16656->16657; 16657->16658; 16658->16659; 16659->16660; 16660->16661; 16661->16662; 16662->16663; 16663->16664; 16664->16665; 16665->16666; 16666->16667; 16667->16668; }

Event Timeline

Enable zooming