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

digraph G { subgraph clusterstage_1303 { label="Stage 1303"; 13681 [labelType="html" label="SQLExecutionRDD [13681] run at <unknown>:0"]; 13689 [labelType="html" label="SQLExecutionRDD [13689] toJavaRDD at <unknown>:0"]; 13691 [labelType="html" label="PythonRDD [13691] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster30610 { label="MicroBatchScan"; 13677 [labelType="html" label="DataSourceRDD [13677] run at <unknown>:0"]; 13678 [labelType="html" label="MapPartitionsRDD [13678] run at <unknown>:0"]; } subgraph cluster30609 { label="Project"; 13679 [labelType="html" label="MapPartitionsRDD [13679] run at <unknown>:0"]; } subgraph cluster30605 { label="WholeStageCodegen (1)"; 13680 [labelType="html" label="MapPartitionsRDD [13680] run at <unknown>:0"]; } subgraph cluster30619 { label="WholeStageCodegen (1)"; 13682 [labelType="html" label="MapPartitionsRDD [13682] toJavaRDD at <unknown>:0"]; } subgraph cluster30618 { label="Filter"; 13683 [labelType="html" label="MapPartitionsRDD [13683] toJavaRDD at <unknown>:0"]; } subgraph cluster30617 { label="Project"; 13684 [labelType="html" label="MapPartitionsRDD [13684] toJavaRDD at <unknown>:0"]; } subgraph cluster30614 { label="WholeStageCodegen (2)"; 13685 [labelType="html" label="MapPartitionsRDD [13685] toJavaRDD at <unknown>:0"]; } subgraph cluster30613 { label="Project"; 13686 [labelType="html" label="MapPartitionsRDD [13686] toJavaRDD at <unknown>:0"]; } subgraph cluster30612 { label="DeserializeToObject"; 13687 [labelType="html" label="MapPartitionsRDD [13687] toJavaRDD at <unknown>:0"]; } subgraph cluster30611 { label="MapPartitions"; 13688 [labelType="html" label="MapPartitionsRDD [13688] toJavaRDD at <unknown>:0"]; } subgraph cluster30621 { label="mapPartitions"; 13690 [labelType="html" label="MapPartitionsRDD [13690] toJavaRDD at <unknown>:0"]; } } 13677->13678; 13678->13679; 13679->13680; 13680->13681; 13681->13682; 13682->13683; 13683->13684; 13684->13685; 13685->13686; 13686->13687; 13687->13688; 13688->13689; 13689->13690; 13690->13691; }

Event Timeline

Enable zooming