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

digraph G { subgraph clusterstage_1040 { label="Stage 1040"; 10924 [labelType="html" label="SQLExecutionRDD [10924] run at <unknown>:0"]; 10932 [labelType="html" label="SQLExecutionRDD [10932] toJavaRDD at <unknown>:0"]; 10934 [labelType="html" label="PythonRDD [10934] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24445 { label="MicroBatchScan"; 10920 [labelType="html" label="DataSourceRDD [10920] run at <unknown>:0"]; 10921 [labelType="html" label="MapPartitionsRDD [10921] run at <unknown>:0"]; } subgraph cluster24444 { label="Project"; 10922 [labelType="html" label="MapPartitionsRDD [10922] run at <unknown>:0"]; } subgraph cluster24440 { label="WholeStageCodegen (1)"; 10923 [labelType="html" label="MapPartitionsRDD [10923] run at <unknown>:0"]; } subgraph cluster24454 { label="WholeStageCodegen (1)"; 10925 [labelType="html" label="MapPartitionsRDD [10925] toJavaRDD at <unknown>:0"]; } subgraph cluster24453 { label="Filter"; 10926 [labelType="html" label="MapPartitionsRDD [10926] toJavaRDD at <unknown>:0"]; } subgraph cluster24452 { label="Project"; 10927 [labelType="html" label="MapPartitionsRDD [10927] toJavaRDD at <unknown>:0"]; } subgraph cluster24449 { label="WholeStageCodegen (2)"; 10928 [labelType="html" label="MapPartitionsRDD [10928] toJavaRDD at <unknown>:0"]; } subgraph cluster24448 { label="Project"; 10929 [labelType="html" label="MapPartitionsRDD [10929] toJavaRDD at <unknown>:0"]; } subgraph cluster24447 { label="DeserializeToObject"; 10930 [labelType="html" label="MapPartitionsRDD [10930] toJavaRDD at <unknown>:0"]; } subgraph cluster24446 { label="MapPartitions"; 10931 [labelType="html" label="MapPartitionsRDD [10931] toJavaRDD at <unknown>:0"]; } subgraph cluster24456 { label="mapPartitions"; 10933 [labelType="html" label="MapPartitionsRDD [10933] toJavaRDD at <unknown>:0"]; } } 10920->10921; 10921->10922; 10922->10923; 10923->10924; 10924->10925; 10925->10926; 10926->10927; 10927->10928; 10928->10929; 10929->10930; 10930->10931; 10931->10932; 10932->10933; 10933->10934; }

Event Timeline

Enable zooming