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

digraph G { subgraph clusterstage_1872 { label="Stage 1872"; 19660 [labelType="html" label="SQLExecutionRDD [19660] run at <unknown>:0"]; 19668 [labelType="html" label="SQLExecutionRDD [19668] toJavaRDD at <unknown>:0"]; 19670 [labelType="html" label="PythonRDD [19670] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43997 { label="MicroBatchScan"; 19656 [labelType="html" label="DataSourceRDD [19656] run at <unknown>:0"]; 19657 [labelType="html" label="MapPartitionsRDD [19657] run at <unknown>:0"]; } subgraph cluster43996 { label="Project"; 19658 [labelType="html" label="MapPartitionsRDD [19658] run at <unknown>:0"]; } subgraph cluster43992 { label="WholeStageCodegen (1)"; 19659 [labelType="html" label="MapPartitionsRDD [19659] run at <unknown>:0"]; } subgraph cluster44006 { label="WholeStageCodegen (1)"; 19661 [labelType="html" label="MapPartitionsRDD [19661] toJavaRDD at <unknown>:0"]; } subgraph cluster44005 { label="Filter"; 19662 [labelType="html" label="MapPartitionsRDD [19662] toJavaRDD at <unknown>:0"]; } subgraph cluster44004 { label="Project"; 19663 [labelType="html" label="MapPartitionsRDD [19663] toJavaRDD at <unknown>:0"]; } subgraph cluster44001 { label="WholeStageCodegen (2)"; 19664 [labelType="html" label="MapPartitionsRDD [19664] toJavaRDD at <unknown>:0"]; } subgraph cluster44000 { label="Project"; 19665 [labelType="html" label="MapPartitionsRDD [19665] toJavaRDD at <unknown>:0"]; } subgraph cluster43999 { label="DeserializeToObject"; 19666 [labelType="html" label="MapPartitionsRDD [19666] toJavaRDD at <unknown>:0"]; } subgraph cluster43998 { label="MapPartitions"; 19667 [labelType="html" label="MapPartitionsRDD [19667] toJavaRDD at <unknown>:0"]; } subgraph cluster44008 { label="mapPartitions"; 19669 [labelType="html" label="MapPartitionsRDD [19669] toJavaRDD at <unknown>:0"]; } } 19656->19657; 19657->19658; 19658->19659; 19659->19660; 19660->19661; 19661->19662; 19662->19663; 19663->19664; 19664->19665; 19665->19666; 19666->19667; 19667->19668; 19668->19669; 19669->19670; }

Event Timeline

Enable zooming