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

digraph G { subgraph clusterstage_336 { label="Stage 336"; 3532 [labelType="html" label="SQLExecutionRDD [3532] run at <unknown>:0"]; 3540 [labelType="html" label="SQLExecutionRDD [3540] toJavaRDD at <unknown>:0"]; 3542 [labelType="html" label="PythonRDD [3542] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7901 { label="MicroBatchScan"; 3528 [labelType="html" label="DataSourceRDD [3528] run at <unknown>:0"]; 3529 [labelType="html" label="MapPartitionsRDD [3529] run at <unknown>:0"]; } subgraph cluster7900 { label="Project"; 3530 [labelType="html" label="MapPartitionsRDD [3530] run at <unknown>:0"]; } subgraph cluster7896 { label="WholeStageCodegen (1)"; 3531 [labelType="html" label="MapPartitionsRDD [3531] run at <unknown>:0"]; } subgraph cluster7910 { label="WholeStageCodegen (1)"; 3533 [labelType="html" label="MapPartitionsRDD [3533] toJavaRDD at <unknown>:0"]; } subgraph cluster7909 { label="Filter"; 3534 [labelType="html" label="MapPartitionsRDD [3534] toJavaRDD at <unknown>:0"]; } subgraph cluster7908 { label="Project"; 3535 [labelType="html" label="MapPartitionsRDD [3535] toJavaRDD at <unknown>:0"]; } subgraph cluster7905 { label="WholeStageCodegen (2)"; 3536 [labelType="html" label="MapPartitionsRDD [3536] toJavaRDD at <unknown>:0"]; } subgraph cluster7904 { label="Project"; 3537 [labelType="html" label="MapPartitionsRDD [3537] toJavaRDD at <unknown>:0"]; } subgraph cluster7903 { label="DeserializeToObject"; 3538 [labelType="html" label="MapPartitionsRDD [3538] toJavaRDD at <unknown>:0"]; } subgraph cluster7902 { label="MapPartitions"; 3539 [labelType="html" label="MapPartitionsRDD [3539] toJavaRDD at <unknown>:0"]; } subgraph cluster7912 { label="mapPartitions"; 3541 [labelType="html" label="MapPartitionsRDD [3541] toJavaRDD at <unknown>:0"]; } } 3528->3529; 3529->3530; 3530->3531; 3531->3532; 3532->3533; 3533->3534; 3534->3535; 3535->3536; 3536->3537; 3537->3538; 3538->3539; 3539->3540; 3540->3541; 3541->3542; }

Event Timeline

Enable zooming