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

digraph G { subgraph clusterstage_1665 { label="Stage 1665"; 17498 [labelType="html" label="SQLExecutionRDD [17498] run at <unknown>:0"]; 17506 [labelType="html" label="SQLExecutionRDD [17506] toJavaRDD at <unknown>:0"]; 17508 [labelType="html" label="PythonRDD [17508] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39152 { label="MicroBatchScan"; 17494 [labelType="html" label="DataSourceRDD [17494] run at <unknown>:0"]; 17495 [labelType="html" label="MapPartitionsRDD [17495] run at <unknown>:0"]; } subgraph cluster39151 { label="Project"; 17496 [labelType="html" label="MapPartitionsRDD [17496] run at <unknown>:0"]; } subgraph cluster39147 { label="WholeStageCodegen (1)"; 17497 [labelType="html" label="MapPartitionsRDD [17497] run at <unknown>:0"]; } subgraph cluster39161 { label="WholeStageCodegen (1)"; 17499 [labelType="html" label="MapPartitionsRDD [17499] toJavaRDD at <unknown>:0"]; } subgraph cluster39160 { label="Filter"; 17500 [labelType="html" label="MapPartitionsRDD [17500] toJavaRDD at <unknown>:0"]; } subgraph cluster39159 { label="Project"; 17501 [labelType="html" label="MapPartitionsRDD [17501] toJavaRDD at <unknown>:0"]; } subgraph cluster39156 { label="WholeStageCodegen (2)"; 17502 [labelType="html" label="MapPartitionsRDD [17502] toJavaRDD at <unknown>:0"]; } subgraph cluster39155 { label="Project"; 17503 [labelType="html" label="MapPartitionsRDD [17503] toJavaRDD at <unknown>:0"]; } subgraph cluster39154 { label="DeserializeToObject"; 17504 [labelType="html" label="MapPartitionsRDD [17504] toJavaRDD at <unknown>:0"]; } subgraph cluster39153 { label="MapPartitions"; 17505 [labelType="html" label="MapPartitionsRDD [17505] toJavaRDD at <unknown>:0"]; } subgraph cluster39163 { label="mapPartitions"; 17507 [labelType="html" label="MapPartitionsRDD [17507] toJavaRDD at <unknown>:0"]; } } 17494->17495; 17495->17496; 17496->17497; 17497->17498; 17498->17499; 17499->17500; 17500->17501; 17501->17502; 17502->17503; 17503->17504; 17504->17505; 17505->17506; 17506->17507; 17507->17508; }

Event Timeline

Enable zooming