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

digraph G { subgraph clusterstage_1528 { label="Stage 1528"; 16048 [labelType="html" label="SQLExecutionRDD [16048] run at <unknown>:0"]; 16056 [labelType="html" label="SQLExecutionRDD [16056] toJavaRDD at <unknown>:0"]; 16058 [labelType="html" label="PythonRDD [16058] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35913 { label="MicroBatchScan"; 16044 [labelType="html" label="DataSourceRDD [16044] run at <unknown>:0"]; 16045 [labelType="html" label="MapPartitionsRDD [16045] run at <unknown>:0"]; } subgraph cluster35912 { label="Project"; 16046 [labelType="html" label="MapPartitionsRDD [16046] run at <unknown>:0"]; } subgraph cluster35908 { label="WholeStageCodegen (1)"; 16047 [labelType="html" label="MapPartitionsRDD [16047] run at <unknown>:0"]; } subgraph cluster35922 { label="WholeStageCodegen (1)"; 16049 [labelType="html" label="MapPartitionsRDD [16049] toJavaRDD at <unknown>:0"]; } subgraph cluster35921 { label="Filter"; 16050 [labelType="html" label="MapPartitionsRDD [16050] toJavaRDD at <unknown>:0"]; } subgraph cluster35920 { label="Project"; 16051 [labelType="html" label="MapPartitionsRDD [16051] toJavaRDD at <unknown>:0"]; } subgraph cluster35917 { label="WholeStageCodegen (2)"; 16052 [labelType="html" label="MapPartitionsRDD [16052] toJavaRDD at <unknown>:0"]; } subgraph cluster35916 { label="Project"; 16053 [labelType="html" label="MapPartitionsRDD [16053] toJavaRDD at <unknown>:0"]; } subgraph cluster35915 { label="DeserializeToObject"; 16054 [labelType="html" label="MapPartitionsRDD [16054] toJavaRDD at <unknown>:0"]; } subgraph cluster35914 { label="MapPartitions"; 16055 [labelType="html" label="MapPartitionsRDD [16055] toJavaRDD at <unknown>:0"]; } subgraph cluster35924 { label="mapPartitions"; 16057 [labelType="html" label="MapPartitionsRDD [16057] toJavaRDD at <unknown>:0"]; } } 16044->16045; 16045->16046; 16046->16047; 16047->16048; 16048->16049; 16049->16050; 16050->16051; 16051->16052; 16052->16053; 16053->16054; 16054->16055; 16055->16056; 16056->16057; 16057->16058; }

Event Timeline

Enable zooming