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

digraph G { subgraph clusterstage_1810 { label="Stage 1810"; 19009 [labelType="html" label="SQLExecutionRDD [19009] run at <unknown>:0"]; 19017 [labelType="html" label="SQLExecutionRDD [19017] toJavaRDD at <unknown>:0"]; 19019 [labelType="html" label="PythonRDD [19019] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42540 { label="MicroBatchScan"; 19005 [labelType="html" label="DataSourceRDD [19005] run at <unknown>:0"]; 19006 [labelType="html" label="MapPartitionsRDD [19006] run at <unknown>:0"]; } subgraph cluster42539 { label="Project"; 19007 [labelType="html" label="MapPartitionsRDD [19007] run at <unknown>:0"]; } subgraph cluster42535 { label="WholeStageCodegen (1)"; 19008 [labelType="html" label="MapPartitionsRDD [19008] run at <unknown>:0"]; } subgraph cluster42549 { label="WholeStageCodegen (1)"; 19010 [labelType="html" label="MapPartitionsRDD [19010] toJavaRDD at <unknown>:0"]; } subgraph cluster42548 { label="Filter"; 19011 [labelType="html" label="MapPartitionsRDD [19011] toJavaRDD at <unknown>:0"]; } subgraph cluster42547 { label="Project"; 19012 [labelType="html" label="MapPartitionsRDD [19012] toJavaRDD at <unknown>:0"]; } subgraph cluster42544 { label="WholeStageCodegen (2)"; 19013 [labelType="html" label="MapPartitionsRDD [19013] toJavaRDD at <unknown>:0"]; } subgraph cluster42543 { label="Project"; 19014 [labelType="html" label="MapPartitionsRDD [19014] toJavaRDD at <unknown>:0"]; } subgraph cluster42542 { label="DeserializeToObject"; 19015 [labelType="html" label="MapPartitionsRDD [19015] toJavaRDD at <unknown>:0"]; } subgraph cluster42541 { label="MapPartitions"; 19016 [labelType="html" label="MapPartitionsRDD [19016] toJavaRDD at <unknown>:0"]; } subgraph cluster42551 { label="mapPartitions"; 19018 [labelType="html" label="MapPartitionsRDD [19018] toJavaRDD at <unknown>:0"]; } } 19005->19006; 19006->19007; 19007->19008; 19008->19009; 19009->19010; 19010->19011; 19011->19012; 19012->19013; 19013->19014; 19014->19015; 19015->19016; 19016->19017; 19017->19018; 19018->19019; }

Event Timeline

Enable zooming