| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 122 | smartbi-mining | parquet at DatasetEvent.java:219 org.apache.spark.sql.DataFrameReader.parquet(DataFrameReader.scala:805) smartbix.datamining.engine.execute.event.DatasetEvent.deserializeFields(DatasetEvent.java:219) smartbix.datamining.engine.util.EventSerializeUtil.deserialize(EventSerializeUtil.java:104) smartbix.datamining.engine.util.EventSerializeUtil.deserialize(EventSerializeUtil.java:77) smartbix.datamining.engine.agent.execute.flow.DefaultSparkFlowContext.getNodeInputData(DefaultSparkFlowContext.java:56) smartbix.datamining.engine.execute.node.GenericNode.getInputData(GenericNode.java:308) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:51) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117) smartbix.datamining.engine.agent.execute.executor.DefaultNodeExecutor.execute(DefaultNodeExecutor.java:43) smartbix.datamining.engine.agent.execute.launcher.DefaultLauncher.run(DefaultLauncher.java:67) 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/05 01:00:06 | 47 ms |
1/1
|