| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 117 | smartbi-mining | parquet at DatasetEvent.java:211 org.apache.spark.sql.DataFrameReader.parquet(DataFrameReader.scala:805) smartbix.datamining.engine.execute.event.DatasetEvent.serializeFields(DatasetEvent.java:211) smartbix.datamining.engine.util.EventSerializeUtil.serialize(EventSerializeUtil.java:45) smartbix.datamining.engine.agent.execute.flow.DefaultSparkFlowContext.persistNodeExecuteResult(DefaultSparkFlowContext.java:97) smartbix.datamining.engine.execute.node.GenericNode.finish(GenericNode.java:201) smartbix.datamining.engine.execute.node.datasource.QueryNode.executeSqlQuery(QueryNode.java:223) smartbix.datamining.engine.execute.node.datasource.QueryNode.execute(QueryNode.java:130) 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:05 | 49 ms |
1/1
|