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

digraph G { subgraph clusterstage_1839 { label="Stage 1839"; 19303 [labelType="html" label="SQLExecutionRDD [19303] run at <unknown>:0"]; 19317 [labelType="html" label="SQLExecutionRDD [19317] toJavaRDD at <unknown>:0"]; 19319 [labelType="html" label="PythonRDD [19319] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43198 { label="MicroBatchScan"; 19299 [labelType="html" label="DataSourceRDD [19299] run at <unknown>:0"]; 19300 [labelType="html" label="MapPartitionsRDD [19300] run at <unknown>:0"]; } subgraph cluster43197 { label="Project"; 19301 [labelType="html" label="MapPartitionsRDD [19301] run at <unknown>:0"]; } subgraph cluster43193 { label="WholeStageCodegen (1)"; 19302 [labelType="html" label="MapPartitionsRDD [19302] run at <unknown>:0"]; } subgraph cluster43215 { label="WholeStageCodegen (1)"; 19310 [labelType="html" label="MapPartitionsRDD [19310] toJavaRDD at <unknown>:0"]; } subgraph cluster43214 { label="Filter"; 19311 [labelType="html" label="MapPartitionsRDD [19311] toJavaRDD at <unknown>:0"]; } subgraph cluster43213 { label="Project"; 19312 [labelType="html" label="MapPartitionsRDD [19312] toJavaRDD at <unknown>:0"]; } subgraph cluster43210 { label="WholeStageCodegen (2)"; 19313 [labelType="html" label="MapPartitionsRDD [19313] toJavaRDD at <unknown>:0"]; } subgraph cluster43209 { label="Project"; 19314 [labelType="html" label="MapPartitionsRDD [19314] toJavaRDD at <unknown>:0"]; } subgraph cluster43208 { label="DeserializeToObject"; 19315 [labelType="html" label="MapPartitionsRDD [19315] toJavaRDD at <unknown>:0"]; } subgraph cluster43207 { label="MapPartitions"; 19316 [labelType="html" label="MapPartitionsRDD [19316] toJavaRDD at <unknown>:0"]; } subgraph cluster43217 { label="mapPartitions"; 19318 [labelType="html" label="MapPartitionsRDD [19318] toJavaRDD at <unknown>:0"]; } } 19299->19300; 19300->19301; 19301->19302; 19302->19303; 19303->19310; 19310->19311; 19311->19312; 19312->19313; 19313->19314; 19314->19315; 19315->19316; 19316->19317; 19317->19318; 19318->19319; }

Event Timeline

Enable zooming