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

digraph G { subgraph clusterstage_1732 { label="Stage 1732"; 18190 [labelType="html" label="SQLExecutionRDD [18190] run at <unknown>:0"]; 18198 [labelType="html" label="SQLExecutionRDD [18198] toJavaRDD at <unknown>:0"]; 18200 [labelType="html" label="PythonRDD [18200] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40707 { label="MicroBatchScan"; 18186 [labelType="html" label="DataSourceRDD [18186] run at <unknown>:0"]; 18187 [labelType="html" label="MapPartitionsRDD [18187] run at <unknown>:0"]; } subgraph cluster40706 { label="Project"; 18188 [labelType="html" label="MapPartitionsRDD [18188] run at <unknown>:0"]; } subgraph cluster40702 { label="WholeStageCodegen (1)"; 18189 [labelType="html" label="MapPartitionsRDD [18189] run at <unknown>:0"]; } subgraph cluster40716 { label="WholeStageCodegen (1)"; 18191 [labelType="html" label="MapPartitionsRDD [18191] toJavaRDD at <unknown>:0"]; } subgraph cluster40715 { label="Filter"; 18192 [labelType="html" label="MapPartitionsRDD [18192] toJavaRDD at <unknown>:0"]; } subgraph cluster40714 { label="Project"; 18193 [labelType="html" label="MapPartitionsRDD [18193] toJavaRDD at <unknown>:0"]; } subgraph cluster40711 { label="WholeStageCodegen (2)"; 18194 [labelType="html" label="MapPartitionsRDD [18194] toJavaRDD at <unknown>:0"]; } subgraph cluster40710 { label="Project"; 18195 [labelType="html" label="MapPartitionsRDD [18195] toJavaRDD at <unknown>:0"]; } subgraph cluster40709 { label="DeserializeToObject"; 18196 [labelType="html" label="MapPartitionsRDD [18196] toJavaRDD at <unknown>:0"]; } subgraph cluster40708 { label="MapPartitions"; 18197 [labelType="html" label="MapPartitionsRDD [18197] toJavaRDD at <unknown>:0"]; } subgraph cluster40718 { label="mapPartitions"; 18199 [labelType="html" label="MapPartitionsRDD [18199] toJavaRDD at <unknown>:0"]; } } 18186->18187; 18187->18188; 18188->18189; 18189->18190; 18190->18191; 18191->18192; 18192->18193; 18193->18194; 18194->18195; 18195->18196; 18196->18197; 18197->18198; 18198->18199; 18199->18200; }

Event Timeline

Enable zooming