Smartbi Mining - Details for Job 297

Status: SUCCEEDED
Submitted: 2025/04/12 08:00:36
Duration: 11 ms
Associated SQL Query: 297
Completed Stages: 1

Enable zooming

digraph G { subgraph clusterstage_419 { label="Stage 419"; 1590 [labelType="html" label="JDBCRDD [1590] cache at ValueReplaceNode.java:62"]; subgraph cluster3856 { label="WholeStageCodegen (1)"; 1591 [labelType="html" label="MapPartitionsRDD [1591] count at DatasetOutput.java:65"]; } subgraph cluster3855 { label="Generate"; 1592 [labelType="html" label="MapPartitionsRDD [1592] count at DatasetOutput.java:65"]; } subgraph cluster3850 { label="WholeStageCodegen (2)"; 1593 [labelType="html" label="MapPartitionsRDD [1593] count at DatasetOutput.java:65"]; } subgraph cluster3849 { label="InMemoryTableScan"; 1594 [labelType="html" label="MapPartitionsRDD [1594] count at DatasetOutput.java:65"]; 1595 [labelType="html" label="*(2) SerializeFromObject [if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 0, F0000080), StringType), true, false) AS F0000080#16278, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 1, ye), StringType), true, false) AS ye#16279, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 2, dataTime), StringType), true, false) AS dataTime#16280, if (assertnotnull(input[0, org.apache.spa... [1595] [Cached] count at DatasetOutput.java:65"]; } subgraph cluster4011 { label="InMemoryTableScan"; 1662 [labelType="html" label="MapPartitionsRDD [1662] collectAsList at DataStorageUtils.java:104"]; 1663 [labelType="html" label="MapPartitionsRDD [1663] collectAsList at DataStorageUtils.java:104"]; 1664 [labelType="html" label="MapPartitionsRDD [1664] collectAsList at DataStorageUtils.java:104"]; } subgraph cluster4008 { label="WholeStageCodegen (1)"; 1665 [labelType="html" label="MapPartitionsRDD [1665] collectAsList at DataStorageUtils.java:104"]; } subgraph cluster4012 { label="mapPartitionsInternal"; 1666 [labelType="html" label="MapPartitionsRDD [1666] collectAsList at DataStorageUtils.java:104"]; } } 1590->1591; 1591->1592; 1592->1593; 1593->1594; 1594->1595; 1595->1662; 1662->1663; 1663->1664; 1664->1665; 1665->1666; }

1595

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
419	smartbi-mining	collectAsList at DataStorageUtils.java:104 +details org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989) smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:262) smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204) smartbix.datamining.engine.execute.node.datatarget.JdbcDataTargetNode.execute(JdbcDataTargetNode.java:177) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49) java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/04/12 08:00:36	6 ms	1/1	53.5 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

419

smartbi-mining

collectAsList at DataStorageUtils.java:104 +details

org.apache.spark.sql.Dataset.collectAsList(Dataset.scala:2989)
smartbix.datamining.engine.util.DataStorageUtils.csv(DataStorageUtils.java:104)
smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:182)
smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:262)
smartbix.datamining.engine.execute.node.GenericNode.genOutputs(GenericNode.java:227)
smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:204)
smartbix.datamining.engine.execute.node.datatarget.JdbcDataTargetNode.execute(JdbcDataTargetNode.java:177)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)

2025/04/12 08:00:36

6 ms

1/1

53.5 KiB

Page: