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

digraph G { subgraph clusterstage_2057 { label="Stage 2057"; 21614 [labelType="html" label="SQLExecutionRDD [21614] run at <unknown>:0"]; 21622 [labelType="html" label="SQLExecutionRDD [21622] toJavaRDD at <unknown>:0"]; 21624 [labelType="html" label="PythonRDD [21624] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster48364 { label="MicroBatchScan"; 21610 [labelType="html" label="DataSourceRDD [21610] run at <unknown>:0"]; 21611 [labelType="html" label="MapPartitionsRDD [21611] run at <unknown>:0"]; } subgraph cluster48363 { label="Project"; 21612 [labelType="html" label="MapPartitionsRDD [21612] run at <unknown>:0"]; } subgraph cluster48359 { label="WholeStageCodegen (1)"; 21613 [labelType="html" label="MapPartitionsRDD [21613] run at <unknown>:0"]; } subgraph cluster48373 { label="WholeStageCodegen (1)"; 21615 [labelType="html" label="MapPartitionsRDD [21615] toJavaRDD at <unknown>:0"]; } subgraph cluster48372 { label="Filter"; 21616 [labelType="html" label="MapPartitionsRDD [21616] toJavaRDD at <unknown>:0"]; } subgraph cluster48371 { label="Project"; 21617 [labelType="html" label="MapPartitionsRDD [21617] toJavaRDD at <unknown>:0"]; } subgraph cluster48368 { label="WholeStageCodegen (2)"; 21618 [labelType="html" label="MapPartitionsRDD [21618] toJavaRDD at <unknown>:0"]; } subgraph cluster48367 { label="Project"; 21619 [labelType="html" label="MapPartitionsRDD [21619] toJavaRDD at <unknown>:0"]; } subgraph cluster48366 { label="DeserializeToObject"; 21620 [labelType="html" label="MapPartitionsRDD [21620] toJavaRDD at <unknown>:0"]; } subgraph cluster48365 { label="MapPartitions"; 21621 [labelType="html" label="MapPartitionsRDD [21621] toJavaRDD at <unknown>:0"]; } subgraph cluster48375 { label="mapPartitions"; 21623 [labelType="html" label="MapPartitionsRDD [21623] toJavaRDD at <unknown>:0"]; } } 21610->21611; 21611->21612; 21612->21613; 21613->21614; 21614->21615; 21615->21616; 21616->21617; 21617->21618; 21618->21619; 21619->21620; 21620->21621; 21621->21622; 21622->21623; 21623->21624; }

Event Timeline

Enable zooming