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

digraph G { subgraph clusterstage_1571 { label="Stage 1571"; 16511 [labelType="html" label="SQLExecutionRDD [16511] run at <unknown>:0"]; 16519 [labelType="html" label="SQLExecutionRDD [16519] toJavaRDD at <unknown>:0"]; 16521 [labelType="html" label="PythonRDD [16521] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster36943 { label="MicroBatchScan"; 16507 [labelType="html" label="DataSourceRDD [16507] run at <unknown>:0"]; 16508 [labelType="html" label="MapPartitionsRDD [16508] run at <unknown>:0"]; } subgraph cluster36942 { label="Project"; 16509 [labelType="html" label="MapPartitionsRDD [16509] run at <unknown>:0"]; } subgraph cluster36938 { label="WholeStageCodegen (1)"; 16510 [labelType="html" label="MapPartitionsRDD [16510] run at <unknown>:0"]; } subgraph cluster36952 { label="WholeStageCodegen (1)"; 16512 [labelType="html" label="MapPartitionsRDD [16512] toJavaRDD at <unknown>:0"]; } subgraph cluster36951 { label="Filter"; 16513 [labelType="html" label="MapPartitionsRDD [16513] toJavaRDD at <unknown>:0"]; } subgraph cluster36950 { label="Project"; 16514 [labelType="html" label="MapPartitionsRDD [16514] toJavaRDD at <unknown>:0"]; } subgraph cluster36947 { label="WholeStageCodegen (2)"; 16515 [labelType="html" label="MapPartitionsRDD [16515] toJavaRDD at <unknown>:0"]; } subgraph cluster36946 { label="Project"; 16516 [labelType="html" label="MapPartitionsRDD [16516] toJavaRDD at <unknown>:0"]; } subgraph cluster36945 { label="DeserializeToObject"; 16517 [labelType="html" label="MapPartitionsRDD [16517] toJavaRDD at <unknown>:0"]; } subgraph cluster36944 { label="MapPartitions"; 16518 [labelType="html" label="MapPartitionsRDD [16518] toJavaRDD at <unknown>:0"]; } subgraph cluster36954 { label="mapPartitions"; 16520 [labelType="html" label="MapPartitionsRDD [16520] toJavaRDD at <unknown>:0"]; } } 16507->16508; 16508->16509; 16509->16510; 16510->16511; 16511->16512; 16512->16513; 16513->16514; 16514->16515; 16515->16516; 16516->16517; 16517->16518; 16518->16519; 16519->16520; 16520->16521; }

Event Timeline

Enable zooming