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

digraph G { subgraph clusterstage_107 { label="Stage 107"; 1117 [labelType="html" label="SQLExecutionRDD [1117] run at <unknown>:0"]; 1131 [labelType="html" label="SQLExecutionRDD [1131] toJavaRDD at <unknown>:0"]; 1133 [labelType="html" label="PythonRDD [1133] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2496 { label="MicroBatchScan"; 1113 [labelType="html" label="DataSourceRDD [1113] run at <unknown>:0"]; 1114 [labelType="html" label="MapPartitionsRDD [1114] run at <unknown>:0"]; } subgraph cluster2495 { label="Project"; 1115 [labelType="html" label="MapPartitionsRDD [1115] run at <unknown>:0"]; } subgraph cluster2491 { label="WholeStageCodegen (1)"; 1116 [labelType="html" label="MapPartitionsRDD [1116] run at <unknown>:0"]; } subgraph cluster2513 { label="WholeStageCodegen (1)"; 1124 [labelType="html" label="MapPartitionsRDD [1124] toJavaRDD at <unknown>:0"]; } subgraph cluster2512 { label="Filter"; 1125 [labelType="html" label="MapPartitionsRDD [1125] toJavaRDD at <unknown>:0"]; } subgraph cluster2511 { label="Project"; 1126 [labelType="html" label="MapPartitionsRDD [1126] toJavaRDD at <unknown>:0"]; } subgraph cluster2508 { label="WholeStageCodegen (2)"; 1127 [labelType="html" label="MapPartitionsRDD [1127] toJavaRDD at <unknown>:0"]; } subgraph cluster2507 { label="Project"; 1128 [labelType="html" label="MapPartitionsRDD [1128] toJavaRDD at <unknown>:0"]; } subgraph cluster2506 { label="DeserializeToObject"; 1129 [labelType="html" label="MapPartitionsRDD [1129] toJavaRDD at <unknown>:0"]; } subgraph cluster2505 { label="MapPartitions"; 1130 [labelType="html" label="MapPartitionsRDD [1130] toJavaRDD at <unknown>:0"]; } subgraph cluster2515 { label="mapPartitions"; 1132 [labelType="html" label="MapPartitionsRDD [1132] toJavaRDD at <unknown>:0"]; } } 1113->1114; 1114->1115; 1115->1116; 1116->1117; 1117->1124; 1124->1125; 1125->1126; 1126->1127; 1127->1128; 1128->1129; 1129->1130; 1130->1131; 1131->1132; 1132->1133; }

Event Timeline

Enable zooming