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

digraph G { subgraph clusterstage_1474 { label="Stage 1474"; 15481 [labelType="html" label="SQLExecutionRDD [15481] run at <unknown>:0"]; 15489 [labelType="html" label="SQLExecutionRDD [15489] toJavaRDD at <unknown>:0"]; 15491 [labelType="html" label="PythonRDD [15491] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34644 { label="MicroBatchScan"; 15477 [labelType="html" label="DataSourceRDD [15477] run at <unknown>:0"]; 15478 [labelType="html" label="MapPartitionsRDD [15478] run at <unknown>:0"]; } subgraph cluster34643 { label="Project"; 15479 [labelType="html" label="MapPartitionsRDD [15479] run at <unknown>:0"]; } subgraph cluster34639 { label="WholeStageCodegen (1)"; 15480 [labelType="html" label="MapPartitionsRDD [15480] run at <unknown>:0"]; } subgraph cluster34653 { label="WholeStageCodegen (1)"; 15482 [labelType="html" label="MapPartitionsRDD [15482] toJavaRDD at <unknown>:0"]; } subgraph cluster34652 { label="Filter"; 15483 [labelType="html" label="MapPartitionsRDD [15483] toJavaRDD at <unknown>:0"]; } subgraph cluster34651 { label="Project"; 15484 [labelType="html" label="MapPartitionsRDD [15484] toJavaRDD at <unknown>:0"]; } subgraph cluster34648 { label="WholeStageCodegen (2)"; 15485 [labelType="html" label="MapPartitionsRDD [15485] toJavaRDD at <unknown>:0"]; } subgraph cluster34647 { label="Project"; 15486 [labelType="html" label="MapPartitionsRDD [15486] toJavaRDD at <unknown>:0"]; } subgraph cluster34646 { label="DeserializeToObject"; 15487 [labelType="html" label="MapPartitionsRDD [15487] toJavaRDD at <unknown>:0"]; } subgraph cluster34645 { label="MapPartitions"; 15488 [labelType="html" label="MapPartitionsRDD [15488] toJavaRDD at <unknown>:0"]; } subgraph cluster34655 { label="mapPartitions"; 15490 [labelType="html" label="MapPartitionsRDD [15490] toJavaRDD at <unknown>:0"]; } } 15477->15478; 15478->15479; 15479->15480; 15480->15481; 15481->15482; 15482->15483; 15483->15484; 15484->15485; 15485->15486; 15486->15487; 15487->15488; 15488->15489; 15489->15490; 15490->15491; }

Event Timeline

Enable zooming