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

digraph G { subgraph clusterstage_159 { label="Stage 159"; 1663 [labelType="html" label="SQLExecutionRDD [1663] run at <unknown>:0"]; 1677 [labelType="html" label="SQLExecutionRDD [1677] toJavaRDD at <unknown>:0"]; 1679 [labelType="html" label="PythonRDD [1679] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3718 { label="MicroBatchScan"; 1659 [labelType="html" label="DataSourceRDD [1659] run at <unknown>:0"]; 1660 [labelType="html" label="MapPartitionsRDD [1660] run at <unknown>:0"]; } subgraph cluster3717 { label="Project"; 1661 [labelType="html" label="MapPartitionsRDD [1661] run at <unknown>:0"]; } subgraph cluster3713 { label="WholeStageCodegen (1)"; 1662 [labelType="html" label="MapPartitionsRDD [1662] run at <unknown>:0"]; } subgraph cluster3735 { label="WholeStageCodegen (1)"; 1670 [labelType="html" label="MapPartitionsRDD [1670] toJavaRDD at <unknown>:0"]; } subgraph cluster3734 { label="Filter"; 1671 [labelType="html" label="MapPartitionsRDD [1671] toJavaRDD at <unknown>:0"]; } subgraph cluster3733 { label="Project"; 1672 [labelType="html" label="MapPartitionsRDD [1672] toJavaRDD at <unknown>:0"]; } subgraph cluster3730 { label="WholeStageCodegen (2)"; 1673 [labelType="html" label="MapPartitionsRDD [1673] toJavaRDD at <unknown>:0"]; } subgraph cluster3729 { label="Project"; 1674 [labelType="html" label="MapPartitionsRDD [1674] toJavaRDD at <unknown>:0"]; } subgraph cluster3728 { label="DeserializeToObject"; 1675 [labelType="html" label="MapPartitionsRDD [1675] toJavaRDD at <unknown>:0"]; } subgraph cluster3727 { label="MapPartitions"; 1676 [labelType="html" label="MapPartitionsRDD [1676] toJavaRDD at <unknown>:0"]; } subgraph cluster3737 { label="mapPartitions"; 1678 [labelType="html" label="MapPartitionsRDD [1678] toJavaRDD at <unknown>:0"]; } } 1659->1660; 1660->1661; 1661->1662; 1662->1663; 1663->1670; 1670->1671; 1671->1672; 1672->1673; 1673->1674; 1674->1675; 1675->1676; 1676->1677; 1677->1678; 1678->1679; }

Event Timeline

Enable zooming