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

digraph G { subgraph clusterstage_1185 { label="Stage 1185"; 12458 [labelType="html" label="SQLExecutionRDD [12458] run at <unknown>:0"]; 12466 [labelType="html" label="SQLExecutionRDD [12466] toJavaRDD at <unknown>:0"]; 12468 [labelType="html" label="PythonRDD [12468] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster27872 { label="MicroBatchScan"; 12454 [labelType="html" label="DataSourceRDD [12454] run at <unknown>:0"]; 12455 [labelType="html" label="MapPartitionsRDD [12455] run at <unknown>:0"]; } subgraph cluster27871 { label="Project"; 12456 [labelType="html" label="MapPartitionsRDD [12456] run at <unknown>:0"]; } subgraph cluster27867 { label="WholeStageCodegen (1)"; 12457 [labelType="html" label="MapPartitionsRDD [12457] run at <unknown>:0"]; } subgraph cluster27881 { label="WholeStageCodegen (1)"; 12459 [labelType="html" label="MapPartitionsRDD [12459] toJavaRDD at <unknown>:0"]; } subgraph cluster27880 { label="Filter"; 12460 [labelType="html" label="MapPartitionsRDD [12460] toJavaRDD at <unknown>:0"]; } subgraph cluster27879 { label="Project"; 12461 [labelType="html" label="MapPartitionsRDD [12461] toJavaRDD at <unknown>:0"]; } subgraph cluster27876 { label="WholeStageCodegen (2)"; 12462 [labelType="html" label="MapPartitionsRDD [12462] toJavaRDD at <unknown>:0"]; } subgraph cluster27875 { label="Project"; 12463 [labelType="html" label="MapPartitionsRDD [12463] toJavaRDD at <unknown>:0"]; } subgraph cluster27874 { label="DeserializeToObject"; 12464 [labelType="html" label="MapPartitionsRDD [12464] toJavaRDD at <unknown>:0"]; } subgraph cluster27873 { label="MapPartitions"; 12465 [labelType="html" label="MapPartitionsRDD [12465] toJavaRDD at <unknown>:0"]; } subgraph cluster27883 { label="mapPartitions"; 12467 [labelType="html" label="MapPartitionsRDD [12467] toJavaRDD at <unknown>:0"]; } } 12454->12455; 12455->12456; 12456->12457; 12457->12458; 12458->12459; 12459->12460; 12460->12461; 12461->12462; 12462->12463; 12463->12464; 12464->12465; 12465->12466; 12466->12467; 12467->12468; }

Event Timeline

Enable zooming