processing-stream-kafka-raw-to-minio - Details for Stage 240 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 553
Associated Job Ids: 240

digraph G { subgraph clusterstage_240 { label="Stage 240"; 2524 [labelType="html" label="SQLExecutionRDD [2524] run at <unknown>:0"]; 2532 [labelType="html" label="SQLExecutionRDD [2532] toJavaRDD at <unknown>:0"]; 2540 [labelType="html" label="PythonRDD [2540] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster5645 { label="MicroBatchScan"; 2520 [labelType="html" label="DataSourceRDD [2520] run at <unknown>:0"]; 2521 [labelType="html" label="MapPartitionsRDD [2521] run at <unknown>:0"]; } subgraph cluster5644 { label="Project"; 2522 [labelType="html" label="MapPartitionsRDD [2522] run at <unknown>:0"]; } subgraph cluster5640 { label="WholeStageCodegen (1)"; 2523 [labelType="html" label="MapPartitionsRDD [2523] run at <unknown>:0"]; } subgraph cluster5660 { label="WholeStageCodegen (1)"; 2525 [labelType="html" label="MapPartitionsRDD [2525] toJavaRDD at <unknown>:0"]; } subgraph cluster5659 { label="Filter"; 2526 [labelType="html" label="MapPartitionsRDD [2526] toJavaRDD at <unknown>:0"]; } subgraph cluster5658 { label="Project"; 2527 [labelType="html" label="MapPartitionsRDD [2527] toJavaRDD at <unknown>:0"]; } subgraph cluster5655 { label="WholeStageCodegen (2)"; 2528 [labelType="html" label="MapPartitionsRDD [2528] toJavaRDD at <unknown>:0"]; } subgraph cluster5654 { label="Project"; 2529 [labelType="html" label="MapPartitionsRDD [2529] toJavaRDD at <unknown>:0"]; } subgraph cluster5653 { label="DeserializeToObject"; 2530 [labelType="html" label="MapPartitionsRDD [2530] toJavaRDD at <unknown>:0"]; } subgraph cluster5652 { label="MapPartitions"; 2531 [labelType="html" label="MapPartitionsRDD [2531] toJavaRDD at <unknown>:0"]; } subgraph cluster5662 { label="mapPartitions"; 2536 [labelType="html" label="MapPartitionsRDD [2536] toJavaRDD at <unknown>:0"]; } } 2520->2521; 2521->2522; 2522->2523; 2523->2524; 2524->2525; 2525->2526; 2526->2527; 2527->2528; 2528->2529; 2529->2530; 2530->2531; 2531->2532; 2532->2536; 2536->2540; }

Event Timeline

Enable zooming