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

digraph G { subgraph clusterstage_707 { label="Stage 707"; 7439 [labelType="html" label="SQLExecutionRDD [7439] run at <unknown>:0"]; 7447 [labelType="html" label="SQLExecutionRDD [7447] toJavaRDD at <unknown>:0"]; 7449 [labelType="html" label="PythonRDD [7449] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster16639 { label="MicroBatchScan"; 7435 [labelType="html" label="DataSourceRDD [7435] run at <unknown>:0"]; 7436 [labelType="html" label="MapPartitionsRDD [7436] run at <unknown>:0"]; } subgraph cluster16638 { label="Project"; 7437 [labelType="html" label="MapPartitionsRDD [7437] run at <unknown>:0"]; } subgraph cluster16634 { label="WholeStageCodegen (1)"; 7438 [labelType="html" label="MapPartitionsRDD [7438] run at <unknown>:0"]; } subgraph cluster16648 { label="WholeStageCodegen (1)"; 7440 [labelType="html" label="MapPartitionsRDD [7440] toJavaRDD at <unknown>:0"]; } subgraph cluster16647 { label="Filter"; 7441 [labelType="html" label="MapPartitionsRDD [7441] toJavaRDD at <unknown>:0"]; } subgraph cluster16646 { label="Project"; 7442 [labelType="html" label="MapPartitionsRDD [7442] toJavaRDD at <unknown>:0"]; } subgraph cluster16643 { label="WholeStageCodegen (2)"; 7443 [labelType="html" label="MapPartitionsRDD [7443] toJavaRDD at <unknown>:0"]; } subgraph cluster16642 { label="Project"; 7444 [labelType="html" label="MapPartitionsRDD [7444] toJavaRDD at <unknown>:0"]; } subgraph cluster16641 { label="DeserializeToObject"; 7445 [labelType="html" label="MapPartitionsRDD [7445] toJavaRDD at <unknown>:0"]; } subgraph cluster16640 { label="MapPartitions"; 7446 [labelType="html" label="MapPartitionsRDD [7446] toJavaRDD at <unknown>:0"]; } subgraph cluster16650 { label="mapPartitions"; 7448 [labelType="html" label="MapPartitionsRDD [7448] toJavaRDD at <unknown>:0"]; } } 7435->7436; 7436->7437; 7437->7438; 7438->7439; 7439->7440; 7440->7441; 7441->7442; 7442->7443; 7443->7444; 7444->7445; 7445->7446; 7446->7447; 7447->7448; 7448->7449; }

Event Timeline

Enable zooming