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

digraph G { subgraph clusterstage_1181 { label="Stage 1181"; 12416 [labelType="html" label="SQLExecutionRDD [12416] run at <unknown>:0"]; 12424 [labelType="html" label="SQLExecutionRDD [12424] toJavaRDD at <unknown>:0"]; 12426 [labelType="html" label="PythonRDD [12426] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster27778 { label="MicroBatchScan"; 12412 [labelType="html" label="DataSourceRDD [12412] run at <unknown>:0"]; 12413 [labelType="html" label="MapPartitionsRDD [12413] run at <unknown>:0"]; } subgraph cluster27777 { label="Project"; 12414 [labelType="html" label="MapPartitionsRDD [12414] run at <unknown>:0"]; } subgraph cluster27773 { label="WholeStageCodegen (1)"; 12415 [labelType="html" label="MapPartitionsRDD [12415] run at <unknown>:0"]; } subgraph cluster27787 { label="WholeStageCodegen (1)"; 12417 [labelType="html" label="MapPartitionsRDD [12417] toJavaRDD at <unknown>:0"]; } subgraph cluster27786 { label="Filter"; 12418 [labelType="html" label="MapPartitionsRDD [12418] toJavaRDD at <unknown>:0"]; } subgraph cluster27785 { label="Project"; 12419 [labelType="html" label="MapPartitionsRDD [12419] toJavaRDD at <unknown>:0"]; } subgraph cluster27782 { label="WholeStageCodegen (2)"; 12420 [labelType="html" label="MapPartitionsRDD [12420] toJavaRDD at <unknown>:0"]; } subgraph cluster27781 { label="Project"; 12421 [labelType="html" label="MapPartitionsRDD [12421] toJavaRDD at <unknown>:0"]; } subgraph cluster27780 { label="DeserializeToObject"; 12422 [labelType="html" label="MapPartitionsRDD [12422] toJavaRDD at <unknown>:0"]; } subgraph cluster27779 { label="MapPartitions"; 12423 [labelType="html" label="MapPartitionsRDD [12423] toJavaRDD at <unknown>:0"]; } subgraph cluster27789 { label="mapPartitions"; 12425 [labelType="html" label="MapPartitionsRDD [12425] toJavaRDD at <unknown>:0"]; } } 12412->12413; 12413->12414; 12414->12415; 12415->12416; 12416->12417; 12417->12418; 12418->12419; 12419->12420; 12420->12421; 12421->12422; 12422->12423; 12423->12424; 12424->12425; 12425->12426; }

Event Timeline

Enable zooming