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

digraph G { subgraph clusterstage_636 { label="Stage 636"; 6682 [labelType="html" label="SQLExecutionRDD [6682] run at <unknown>:0"]; 6690 [labelType="html" label="SQLExecutionRDD [6690] toJavaRDD at <unknown>:0"]; 6692 [labelType="html" label="PythonRDD [6692] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14951 { label="MicroBatchScan"; 6678 [labelType="html" label="DataSourceRDD [6678] run at <unknown>:0"]; 6679 [labelType="html" label="MapPartitionsRDD [6679] run at <unknown>:0"]; } subgraph cluster14950 { label="Project"; 6680 [labelType="html" label="MapPartitionsRDD [6680] run at <unknown>:0"]; } subgraph cluster14946 { label="WholeStageCodegen (1)"; 6681 [labelType="html" label="MapPartitionsRDD [6681] run at <unknown>:0"]; } subgraph cluster14960 { label="WholeStageCodegen (1)"; 6683 [labelType="html" label="MapPartitionsRDD [6683] toJavaRDD at <unknown>:0"]; } subgraph cluster14959 { label="Filter"; 6684 [labelType="html" label="MapPartitionsRDD [6684] toJavaRDD at <unknown>:0"]; } subgraph cluster14958 { label="Project"; 6685 [labelType="html" label="MapPartitionsRDD [6685] toJavaRDD at <unknown>:0"]; } subgraph cluster14955 { label="WholeStageCodegen (2)"; 6686 [labelType="html" label="MapPartitionsRDD [6686] toJavaRDD at <unknown>:0"]; } subgraph cluster14954 { label="Project"; 6687 [labelType="html" label="MapPartitionsRDD [6687] toJavaRDD at <unknown>:0"]; } subgraph cluster14953 { label="DeserializeToObject"; 6688 [labelType="html" label="MapPartitionsRDD [6688] toJavaRDD at <unknown>:0"]; } subgraph cluster14952 { label="MapPartitions"; 6689 [labelType="html" label="MapPartitionsRDD [6689] toJavaRDD at <unknown>:0"]; } subgraph cluster14962 { label="mapPartitions"; 6691 [labelType="html" label="MapPartitionsRDD [6691] toJavaRDD at <unknown>:0"]; } } 6678->6679; 6679->6680; 6680->6681; 6681->6682; 6682->6683; 6683->6684; 6684->6685; 6685->6686; 6686->6687; 6687->6688; 6688->6689; 6689->6690; 6690->6691; 6691->6692; }

Event Timeline

Enable zooming