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

digraph G { subgraph clusterstage_1006 { label="Stage 1006"; 10567 [labelType="html" label="SQLExecutionRDD [10567] run at <unknown>:0"]; 10575 [labelType="html" label="SQLExecutionRDD [10575] toJavaRDD at <unknown>:0"]; 10577 [labelType="html" label="PythonRDD [10577] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23646 { label="MicroBatchScan"; 10563 [labelType="html" label="DataSourceRDD [10563] run at <unknown>:0"]; 10564 [labelType="html" label="MapPartitionsRDD [10564] run at <unknown>:0"]; } subgraph cluster23645 { label="Project"; 10565 [labelType="html" label="MapPartitionsRDD [10565] run at <unknown>:0"]; } subgraph cluster23641 { label="WholeStageCodegen (1)"; 10566 [labelType="html" label="MapPartitionsRDD [10566] run at <unknown>:0"]; } subgraph cluster23655 { label="WholeStageCodegen (1)"; 10568 [labelType="html" label="MapPartitionsRDD [10568] toJavaRDD at <unknown>:0"]; } subgraph cluster23654 { label="Filter"; 10569 [labelType="html" label="MapPartitionsRDD [10569] toJavaRDD at <unknown>:0"]; } subgraph cluster23653 { label="Project"; 10570 [labelType="html" label="MapPartitionsRDD [10570] toJavaRDD at <unknown>:0"]; } subgraph cluster23650 { label="WholeStageCodegen (2)"; 10571 [labelType="html" label="MapPartitionsRDD [10571] toJavaRDD at <unknown>:0"]; } subgraph cluster23649 { label="Project"; 10572 [labelType="html" label="MapPartitionsRDD [10572] toJavaRDD at <unknown>:0"]; } subgraph cluster23648 { label="DeserializeToObject"; 10573 [labelType="html" label="MapPartitionsRDD [10573] toJavaRDD at <unknown>:0"]; } subgraph cluster23647 { label="MapPartitions"; 10574 [labelType="html" label="MapPartitionsRDD [10574] toJavaRDD at <unknown>:0"]; } subgraph cluster23657 { label="mapPartitions"; 10576 [labelType="html" label="MapPartitionsRDD [10576] toJavaRDD at <unknown>:0"]; } } 10563->10564; 10564->10565; 10565->10566; 10566->10567; 10567->10568; 10568->10569; 10569->10570; 10570->10571; 10571->10572; 10572->10573; 10573->10574; 10574->10575; 10575->10576; 10576->10577; }

Event Timeline

Enable zooming