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

digraph G { subgraph clusterstage_1757 { label="Stage 1757"; 18448 [labelType="html" label="SQLExecutionRDD [18448] run at <unknown>:0"]; 18456 [labelType="html" label="SQLExecutionRDD [18456] toJavaRDD at <unknown>:0"]; 18458 [labelType="html" label="PythonRDD [18458] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41279 { label="MicroBatchScan"; 18444 [labelType="html" label="DataSourceRDD [18444] run at <unknown>:0"]; 18445 [labelType="html" label="MapPartitionsRDD [18445] run at <unknown>:0"]; } subgraph cluster41278 { label="Project"; 18446 [labelType="html" label="MapPartitionsRDD [18446] run at <unknown>:0"]; } subgraph cluster41274 { label="WholeStageCodegen (1)"; 18447 [labelType="html" label="MapPartitionsRDD [18447] run at <unknown>:0"]; } subgraph cluster41288 { label="WholeStageCodegen (1)"; 18449 [labelType="html" label="MapPartitionsRDD [18449] toJavaRDD at <unknown>:0"]; } subgraph cluster41287 { label="Filter"; 18450 [labelType="html" label="MapPartitionsRDD [18450] toJavaRDD at <unknown>:0"]; } subgraph cluster41286 { label="Project"; 18451 [labelType="html" label="MapPartitionsRDD [18451] toJavaRDD at <unknown>:0"]; } subgraph cluster41283 { label="WholeStageCodegen (2)"; 18452 [labelType="html" label="MapPartitionsRDD [18452] toJavaRDD at <unknown>:0"]; } subgraph cluster41282 { label="Project"; 18453 [labelType="html" label="MapPartitionsRDD [18453] toJavaRDD at <unknown>:0"]; } subgraph cluster41281 { label="DeserializeToObject"; 18454 [labelType="html" label="MapPartitionsRDD [18454] toJavaRDD at <unknown>:0"]; } subgraph cluster41280 { label="MapPartitions"; 18455 [labelType="html" label="MapPartitionsRDD [18455] toJavaRDD at <unknown>:0"]; } subgraph cluster41290 { label="mapPartitions"; 18457 [labelType="html" label="MapPartitionsRDD [18457] toJavaRDD at <unknown>:0"]; } } 18444->18445; 18445->18446; 18446->18447; 18447->18448; 18448->18449; 18449->18450; 18450->18451; 18451->18452; 18452->18453; 18453->18454; 18454->18455; 18455->18456; 18456->18457; 18457->18458; }

Event Timeline

Enable zooming