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

digraph G { subgraph clusterstage_2046 { label="Stage 2046"; 21488 [labelType="html" label="SQLExecutionRDD [21488] run at <unknown>:0"]; 21502 [labelType="html" label="SQLExecutionRDD [21502] toJavaRDD at <unknown>:0"]; 21504 [labelType="html" label="PythonRDD [21504] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster48082 { label="MicroBatchScan"; 21484 [labelType="html" label="DataSourceRDD [21484] run at <unknown>:0"]; 21485 [labelType="html" label="MapPartitionsRDD [21485] run at <unknown>:0"]; } subgraph cluster48081 { label="Project"; 21486 [labelType="html" label="MapPartitionsRDD [21486] run at <unknown>:0"]; } subgraph cluster48077 { label="WholeStageCodegen (1)"; 21487 [labelType="html" label="MapPartitionsRDD [21487] run at <unknown>:0"]; } subgraph cluster48097 { label="WholeStageCodegen (1)"; 21495 [labelType="html" label="MapPartitionsRDD [21495] toJavaRDD at <unknown>:0"]; } subgraph cluster48096 { label="Filter"; 21496 [labelType="html" label="MapPartitionsRDD [21496] toJavaRDD at <unknown>:0"]; } subgraph cluster48095 { label="Project"; 21497 [labelType="html" label="MapPartitionsRDD [21497] toJavaRDD at <unknown>:0"]; } subgraph cluster48092 { label="WholeStageCodegen (2)"; 21498 [labelType="html" label="MapPartitionsRDD [21498] toJavaRDD at <unknown>:0"]; } subgraph cluster48091 { label="Project"; 21499 [labelType="html" label="MapPartitionsRDD [21499] toJavaRDD at <unknown>:0"]; } subgraph cluster48090 { label="DeserializeToObject"; 21500 [labelType="html" label="MapPartitionsRDD [21500] toJavaRDD at <unknown>:0"]; } subgraph cluster48089 { label="MapPartitions"; 21501 [labelType="html" label="MapPartitionsRDD [21501] toJavaRDD at <unknown>:0"]; } subgraph cluster48101 { label="mapPartitions"; 21503 [labelType="html" label="MapPartitionsRDD [21503] toJavaRDD at <unknown>:0"]; } } 21484->21485; 21485->21486; 21486->21487; 21487->21488; 21488->21495; 21495->21496; 21496->21497; 21497->21498; 21498->21499; 21499->21500; 21500->21501; 21501->21502; 21502->21503; 21503->21504; }

Event Timeline

Enable zooming