DataHubScheduler - Details for Job 25029

Status: SUCCEEDED
Submitted: 2026/10/18 14:08:20
Duration: 9 ms
Associated SQL Query: 6020
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { subgraph clusterstage_34961 { label="Stage 34961 (skipped)"; 152985 [labelType="html" label="JDBCRDD [152985] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; subgraph cluster369296 { label="Scan JDBCRelation((SELECT * FROM dbo.fact_trans_chain_po_detail WHERE bigid BETWEEN 50001 AND 60000) AS page) [numPartitions=1] "; 152986 [labelType="html" label="MapPartitionsRDD [152986] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster369297 { label="mapPartitionsInternal"; 152987 [labelType="html" label="MapPartitionsRDD [152987] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster369298 { label="mapPartitionsInternal"; 152988 [labelType="html" label="Scan JDBCRelation((SELECT * FROM dbo.fact_trans_chain_po_detail WHERE bigid BETWEEN 50001 AND 60000) AS page) [numPartitions=1] [po_item_product_code#14570583,po_item_product_name#14570584,transaction_id#14570585,buyer_gln#14570586,seller_gln#14570587,pod_division#14570588,pod_delivery_date#14570589,pod_product_item_id#14570590,pod_product_entity#14570591,po_number#14570592,product_item_id#14570593,product_entity#14570594,brand_context_id#14570595,po_division#14570596,po_delivery_date#14570597,row_id#14570598L,parent_row_id#14570599,chain_seq#14570600,tier#14570601,production_input_type#14570602,trans_create_ts#14570603,trans_update_ts#14570604,outbound_create_ts#14570605,outbound_supplier_code#14570606,... 111 more fields] PushedFilters: [], ReadSchema: struct<po_item_product_code:string,po_item_product_name:string,transaction_id:string,buyer_gln:st...\n [152988] [Cached] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster369304 { label="InMemoryTableScan"; 152989 [labelType="html" label="MapPartitionsRDD [152989] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; 152990 [labelType="html" label="MapPartitionsRDD [152990] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; 152991 [labelType="html" label="MapPartitionsRDD [152991] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster369300 { label="WholeStageCodegen (1)"; 152992 [labelType="html" label="MapPartitionsRDD [152992] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster369299 { label="Exchange"; 152993 [labelType="html" label="MapPartitionsRDD [152993] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } } 152985->152986; 152986->152987; 152987->152988; 152988->152989; 152989->152990; 152990->152991; 152991->152992; 152992->152993; }

152988

digraph G { subgraph clusterstage_34962 { label="Stage 34962"; subgraph cluster369309 { label="Exchange"; 152994 [labelType="html" label="ShuffledRowRDD [152994] [Unordered] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster369305 { label="WholeStageCodegen (2)"; 152995 [labelType="html" label="MapPartitionsRDD [152995] [Unordered] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } subgraph cluster369310 { label="mapPartitionsInternal"; 152996 [labelType="html" label="MapPartitionsRDD [152996] [Unordered] first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169"]; } } 152994->152995; 152995->152996; }

152993,152994

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
34962	default	first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 +details org.apache.spark.sql.Dataset.count(Dataset.scala:3613) jdk.internal.reflect.GeneratedMethodAccessor202.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374) py4j.Gateway.invoke(Gateway.java:282) py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) py4j.commands.CallCommand.execute(CallCommand.java:79) py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182) py4j.ClientServerConnection.run(ClientServerConnection.java:106) java.base/java.lang.Thread.run(Unknown Source)	2026/10/18 14:08:20	7 ms	1/1			59.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

34962

default

first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 +details

org.apache.spark.sql.Dataset.count(Dataset.scala:3613)
jdk.internal.reflect.GeneratedMethodAccessor202.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)

2026/10/18 14:08:20

7 ms

1/1

59.0 B

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
34961	default	first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 +details org.apache.spark.sql.Dataset.count(Dataset.scala:3613) jdk.internal.reflect.GeneratedMethodAccessor202.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374) py4j.Gateway.invoke(Gateway.java:282) py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) py4j.commands.CallCommand.execute(CallCommand.java:79) py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182) py4j.ClientServerConnection.run(ClientServerConnection.java:106) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

34961

default

first at /opt/app/scheduler/jobs/batch_table_copy_job.py:169 +details

org.apache.spark.sql.Dataset.count(Dataset.scala:3613)
jdk.internal.reflect.GeneratedMethodAccessor202.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)

Unknown

0/1

Page: