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

digraph G { subgraph clusterstage_1415 { label="Stage 1415"; 14873 [labelType="html" label="SQLExecutionRDD [14873] run at <unknown>:0"]; 14881 [labelType="html" label="SQLExecutionRDD [14881] toJavaRDD at <unknown>:0"]; 14883 [labelType="html" label="PythonRDD [14883] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33277 { label="MicroBatchScan"; 14869 [labelType="html" label="DataSourceRDD [14869] run at <unknown>:0"]; 14870 [labelType="html" label="MapPartitionsRDD [14870] run at <unknown>:0"]; } subgraph cluster33276 { label="Project"; 14871 [labelType="html" label="MapPartitionsRDD [14871] run at <unknown>:0"]; } subgraph cluster33272 { label="WholeStageCodegen (1)"; 14872 [labelType="html" label="MapPartitionsRDD [14872] run at <unknown>:0"]; } subgraph cluster33286 { label="WholeStageCodegen (1)"; 14874 [labelType="html" label="MapPartitionsRDD [14874] toJavaRDD at <unknown>:0"]; } subgraph cluster33285 { label="Filter"; 14875 [labelType="html" label="MapPartitionsRDD [14875] toJavaRDD at <unknown>:0"]; } subgraph cluster33284 { label="Project"; 14876 [labelType="html" label="MapPartitionsRDD [14876] toJavaRDD at <unknown>:0"]; } subgraph cluster33281 { label="WholeStageCodegen (2)"; 14877 [labelType="html" label="MapPartitionsRDD [14877] toJavaRDD at <unknown>:0"]; } subgraph cluster33280 { label="Project"; 14878 [labelType="html" label="MapPartitionsRDD [14878] toJavaRDD at <unknown>:0"]; } subgraph cluster33279 { label="DeserializeToObject"; 14879 [labelType="html" label="MapPartitionsRDD [14879] toJavaRDD at <unknown>:0"]; } subgraph cluster33278 { label="MapPartitions"; 14880 [labelType="html" label="MapPartitionsRDD [14880] toJavaRDD at <unknown>:0"]; } subgraph cluster33288 { label="mapPartitions"; 14882 [labelType="html" label="MapPartitionsRDD [14882] toJavaRDD at <unknown>:0"]; } } 14869->14870; 14870->14871; 14871->14872; 14872->14873; 14873->14874; 14874->14875; 14875->14876; 14876->14877; 14877->14878; 14878->14879; 14879->14880; 14880->14881; 14881->14882; 14882->14883; }

Event Timeline

Enable zooming