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

digraph G { subgraph clusterstage_1943 { label="Stage 1943"; 20417 [labelType="html" label="SQLExecutionRDD [20417] run at <unknown>:0"]; 20425 [labelType="html" label="SQLExecutionRDD [20425] toJavaRDD at <unknown>:0"]; 20427 [labelType="html" label="PythonRDD [20427] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45685 { label="MicroBatchScan"; 20413 [labelType="html" label="DataSourceRDD [20413] run at <unknown>:0"]; 20414 [labelType="html" label="MapPartitionsRDD [20414] run at <unknown>:0"]; } subgraph cluster45684 { label="Project"; 20415 [labelType="html" label="MapPartitionsRDD [20415] run at <unknown>:0"]; } subgraph cluster45680 { label="WholeStageCodegen (1)"; 20416 [labelType="html" label="MapPartitionsRDD [20416] run at <unknown>:0"]; } subgraph cluster45694 { label="WholeStageCodegen (1)"; 20418 [labelType="html" label="MapPartitionsRDD [20418] toJavaRDD at <unknown>:0"]; } subgraph cluster45693 { label="Filter"; 20419 [labelType="html" label="MapPartitionsRDD [20419] toJavaRDD at <unknown>:0"]; } subgraph cluster45692 { label="Project"; 20420 [labelType="html" label="MapPartitionsRDD [20420] toJavaRDD at <unknown>:0"]; } subgraph cluster45689 { label="WholeStageCodegen (2)"; 20421 [labelType="html" label="MapPartitionsRDD [20421] toJavaRDD at <unknown>:0"]; } subgraph cluster45688 { label="Project"; 20422 [labelType="html" label="MapPartitionsRDD [20422] toJavaRDD at <unknown>:0"]; } subgraph cluster45687 { label="DeserializeToObject"; 20423 [labelType="html" label="MapPartitionsRDD [20423] toJavaRDD at <unknown>:0"]; } subgraph cluster45686 { label="MapPartitions"; 20424 [labelType="html" label="MapPartitionsRDD [20424] toJavaRDD at <unknown>:0"]; } subgraph cluster45696 { label="mapPartitions"; 20426 [labelType="html" label="MapPartitionsRDD [20426] toJavaRDD at <unknown>:0"]; } } 20413->20414; 20414->20415; 20415->20416; 20416->20417; 20417->20418; 20418->20419; 20419->20420; 20420->20421; 20421->20422; 20422->20423; 20423->20424; 20424->20425; 20425->20426; 20426->20427; }

Event Timeline

Enable zooming