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

digraph G { subgraph clusterstage_590 { label="Stage 590"; 6199 [labelType="html" label="SQLExecutionRDD [6199] run at <unknown>:0"]; 6207 [labelType="html" label="SQLExecutionRDD [6207] toJavaRDD at <unknown>:0"]; 6209 [labelType="html" label="PythonRDD [6209] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster13870 { label="MicroBatchScan"; 6195 [labelType="html" label="DataSourceRDD [6195] run at <unknown>:0"]; 6196 [labelType="html" label="MapPartitionsRDD [6196] run at <unknown>:0"]; } subgraph cluster13869 { label="Project"; 6197 [labelType="html" label="MapPartitionsRDD [6197] run at <unknown>:0"]; } subgraph cluster13865 { label="WholeStageCodegen (1)"; 6198 [labelType="html" label="MapPartitionsRDD [6198] run at <unknown>:0"]; } subgraph cluster13879 { label="WholeStageCodegen (1)"; 6200 [labelType="html" label="MapPartitionsRDD [6200] toJavaRDD at <unknown>:0"]; } subgraph cluster13878 { label="Filter"; 6201 [labelType="html" label="MapPartitionsRDD [6201] toJavaRDD at <unknown>:0"]; } subgraph cluster13877 { label="Project"; 6202 [labelType="html" label="MapPartitionsRDD [6202] toJavaRDD at <unknown>:0"]; } subgraph cluster13874 { label="WholeStageCodegen (2)"; 6203 [labelType="html" label="MapPartitionsRDD [6203] toJavaRDD at <unknown>:0"]; } subgraph cluster13873 { label="Project"; 6204 [labelType="html" label="MapPartitionsRDD [6204] toJavaRDD at <unknown>:0"]; } subgraph cluster13872 { label="DeserializeToObject"; 6205 [labelType="html" label="MapPartitionsRDD [6205] toJavaRDD at <unknown>:0"]; } subgraph cluster13871 { label="MapPartitions"; 6206 [labelType="html" label="MapPartitionsRDD [6206] toJavaRDD at <unknown>:0"]; } subgraph cluster13881 { label="mapPartitions"; 6208 [labelType="html" label="MapPartitionsRDD [6208] toJavaRDD at <unknown>:0"]; } } 6195->6196; 6196->6197; 6197->6198; 6198->6199; 6199->6200; 6200->6201; 6201->6202; 6202->6203; 6203->6204; 6204->6205; 6205->6206; 6206->6207; 6207->6208; 6208->6209; }

Event Timeline

Enable zooming