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

digraph G { subgraph clusterstage_127 { label="Stage 127"; 1333 [labelType="html" label="SQLExecutionRDD [1333] run at <unknown>:0"]; 1341 [labelType="html" label="SQLExecutionRDD [1341] toJavaRDD at <unknown>:0"]; 1343 [labelType="html" label="PythonRDD [1343] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2974 { label="MicroBatchScan"; 1329 [labelType="html" label="DataSourceRDD [1329] run at <unknown>:0"]; 1330 [labelType="html" label="MapPartitionsRDD [1330] run at <unknown>:0"]; } subgraph cluster2973 { label="Project"; 1331 [labelType="html" label="MapPartitionsRDD [1331] run at <unknown>:0"]; } subgraph cluster2969 { label="WholeStageCodegen (1)"; 1332 [labelType="html" label="MapPartitionsRDD [1332] run at <unknown>:0"]; } subgraph cluster2983 { label="WholeStageCodegen (1)"; 1334 [labelType="html" label="MapPartitionsRDD [1334] toJavaRDD at <unknown>:0"]; } subgraph cluster2982 { label="Filter"; 1335 [labelType="html" label="MapPartitionsRDD [1335] toJavaRDD at <unknown>:0"]; } subgraph cluster2981 { label="Project"; 1336 [labelType="html" label="MapPartitionsRDD [1336] toJavaRDD at <unknown>:0"]; } subgraph cluster2978 { label="WholeStageCodegen (2)"; 1337 [labelType="html" label="MapPartitionsRDD [1337] toJavaRDD at <unknown>:0"]; } subgraph cluster2977 { label="Project"; 1338 [labelType="html" label="MapPartitionsRDD [1338] toJavaRDD at <unknown>:0"]; } subgraph cluster2976 { label="DeserializeToObject"; 1339 [labelType="html" label="MapPartitionsRDD [1339] toJavaRDD at <unknown>:0"]; } subgraph cluster2975 { label="MapPartitions"; 1340 [labelType="html" label="MapPartitionsRDD [1340] toJavaRDD at <unknown>:0"]; } subgraph cluster2985 { label="mapPartitions"; 1342 [labelType="html" label="MapPartitionsRDD [1342] toJavaRDD at <unknown>:0"]; } } 1329->1330; 1330->1331; 1331->1332; 1332->1333; 1333->1334; 1334->1335; 1335->1336; 1336->1337; 1337->1338; 1338->1339; 1339->1340; 1340->1341; 1341->1342; 1342->1343; }

Event Timeline

Enable zooming