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

digraph G { subgraph clusterstage_1680 { label="Stage 1680"; 17651 [labelType="html" label="SQLExecutionRDD [17651] run at <unknown>:0"]; 17659 [labelType="html" label="SQLExecutionRDD [17659] toJavaRDD at <unknown>:0"]; 17661 [labelType="html" label="PythonRDD [17661] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39489 { label="MicroBatchScan"; 17647 [labelType="html" label="DataSourceRDD [17647] run at <unknown>:0"]; 17648 [labelType="html" label="MapPartitionsRDD [17648] run at <unknown>:0"]; } subgraph cluster39488 { label="Project"; 17649 [labelType="html" label="MapPartitionsRDD [17649] run at <unknown>:0"]; } subgraph cluster39484 { label="WholeStageCodegen (1)"; 17650 [labelType="html" label="MapPartitionsRDD [17650] run at <unknown>:0"]; } subgraph cluster39498 { label="WholeStageCodegen (1)"; 17652 [labelType="html" label="MapPartitionsRDD [17652] toJavaRDD at <unknown>:0"]; } subgraph cluster39497 { label="Filter"; 17653 [labelType="html" label="MapPartitionsRDD [17653] toJavaRDD at <unknown>:0"]; } subgraph cluster39496 { label="Project"; 17654 [labelType="html" label="MapPartitionsRDD [17654] toJavaRDD at <unknown>:0"]; } subgraph cluster39493 { label="WholeStageCodegen (2)"; 17655 [labelType="html" label="MapPartitionsRDD [17655] toJavaRDD at <unknown>:0"]; } subgraph cluster39492 { label="Project"; 17656 [labelType="html" label="MapPartitionsRDD [17656] toJavaRDD at <unknown>:0"]; } subgraph cluster39491 { label="DeserializeToObject"; 17657 [labelType="html" label="MapPartitionsRDD [17657] toJavaRDD at <unknown>:0"]; } subgraph cluster39490 { label="MapPartitions"; 17658 [labelType="html" label="MapPartitionsRDD [17658] toJavaRDD at <unknown>:0"]; } subgraph cluster39500 { label="mapPartitions"; 17660 [labelType="html" label="MapPartitionsRDD [17660] toJavaRDD at <unknown>:0"]; } } 17647->17648; 17648->17649; 17649->17650; 17650->17651; 17651->17652; 17652->17653; 17653->17654; 17654->17655; 17655->17656; 17656->17657; 17657->17658; 17658->17659; 17659->17660; 17660->17661; }

Event Timeline

Enable zooming