| Pool Name | Minimum Share | Pool Weight | Active Stages | Running Tasks | SchedulingMode |
|---|---|---|---|---|---|
| smartbi-mining | 2 | 100 | 0 | 0 | FAIR |
| default | 0 | 1 | 0 | 0 | FIFO |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 609 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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/06/27 08:00:36 | 6 ms |
1/1
| 53.5 KiB | |||
| 608 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) 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/06/27 08:00:36 | 3 ms |
1/1
| 59.0 B | |||
| 607 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) 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/06/27 08:00:36 | 7 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 606 | smartbi-mining | foreachPartition at SparkFunctionUtil.java:146 org.apache.spark.sql.Dataset.foreachPartition(Dataset.scala:2930) smartbix.datamining.engine.util.SparkFunctionUtil.saveTable(SparkFunctionUtil.java:146) smartbix.datamining.engine.datasource.JdbcHandler.replaceDataToDatabase(JdbcHandler.java:305) smartbix.datamining.engine.execute.node.datasource.handler.MysqlHandler.executor(MysqlHandler.java:48) smartbix.datamining.engine.execute.node.datatarget.JdbcDataTargetNode.execute(JdbcDataTargetNode.java:165) 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/06/27 08:00:07 | 28 s |
1/1
| 53.5 KiB | |||
| 605 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.MetadataNode.execute(MetadataNode.java:54) 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/06/27 08:00:07 | 7 ms |
1/1
| 53.5 KiB | |||
| 604 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.MetadataNode.execute(MetadataNode.java:54) 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/06/27 08:00:07 | 3 ms |
1/1
| 59.0 B | |||
| 603 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.MetadataNode.execute(MetadataNode.java:54) 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/06/27 08:00:07 | 7 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 602 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) 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/06/27 08:00:07 | 6 ms |
1/1
| 53.5 KiB | |||
| 601 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) 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/06/27 08:00:07 | 3 ms |
1/1
| 59.0 B | |||
| 600 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) 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/06/27 08:00:07 | 6 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 599 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) 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/06/27 08:00:07 | 6 ms |
1/1
| 53.5 KiB | |||
| 598 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) 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/06/27 08:00:07 | 4 ms |
1/1
| 59.0 B | |||
| 597 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) 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/06/27 08:00:07 | 7 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 596 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) 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/06/27 08:00:07 | 6 ms |
1/1
| 53.5 KiB | |||
| 595 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) 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/06/27 08:00:07 | 4 ms |
1/1
| 59.0 B | |||
| 594 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) 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/06/27 08:00:06 | 0.8 s |
1/1
| 59.0 B | |||
| 593 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.Column2RowNode.execute(Column2RowNode.java:116) 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/06/27 08:00:05 | 0.8 s |
1/1
| ||||
| 592 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.Column2RowNode.execute(Column2RowNode.java:116) 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/06/27 08:00:05 | 3 ms |
1/1
| 59.0 B | |||
| 591 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.Column2RowNode.execute(Column2RowNode.java:116) 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/06/27 08:00:04 | 0.8 s |
1/1
| 59.0 B | |||
| 590 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.DivideNode.execute(DivideNode.java:88) 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/06/27 08:00:03 | 0.8 s |
1/1
| ||||
| 589 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DivideNode.execute(DivideNode.java:88) 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/06/27 08:00:03 | 4 ms |
1/1
| 59.0 B | |||
| 588 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DivideNode.execute(DivideNode.java:88) 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/06/27 08:00:02 | 0.8 s |
1/1
| 59.0 B | |||
| 587 | smartbi-mining | describe at DivideNode.java:229 org.apache.spark.sql.Dataset.describe(Dataset.scala:2660) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:229) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) 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/06/27 08:00:02 | 7 ms |
1/1
| 94.0 B | |||
| 586 | smartbi-mining | describe at DivideNode.java:229 org.apache.spark.sql.Dataset.describe(Dataset.scala:2660) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:229) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) 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/06/27 08:00:02 | 0.8 s |
1/1
| 94.0 B | |||
| 585 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.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.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/06/27 08:00:01 | 0.8 s |
1/1
| ||||
| 584 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.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.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/06/27 08:00:01 | 7 ms |
1/1
| 59.0 B | |||
| 583 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.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.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/06/27 08:00:00 | 0.8 s |
1/1
| 59.0 B | |||
| 582 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:77) 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/06/27 01:00:06 | 26 ms |
1/1
| 14.1 KiB | |||
| 581 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) 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.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:77) 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/06/27 01:00:06 | 9 ms |
1/1
| 59.0 B | |||
| 580 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) 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.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:77) 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/06/27 01:00:06 | 13 ms |
1/1
| 2.7 KiB | 59.0 B | ||
| 579 | smartbi-mining | foreachPartition at SparkFunctionUtil.java:146 org.apache.spark.sql.Dataset.foreachPartition(Dataset.scala:2930) smartbix.datamining.engine.util.SparkFunctionUtil.saveTable(SparkFunctionUtil.java:146) smartbix.datamining.engine.datasource.JdbcHandler.insertDataToDatabase(JdbcHandler.java:274) smartbix.datamining.engine.datasource.JdbcHandler.insertDataToDatabase(JdbcHandler.java:226) smartbix.datamining.engine.execute.node.datasource.handler.ClickHouseHandler.executorByTable(ClickHouseHandler.java:122) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.createTable(SmartbiMppOutputNode.java:98) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:69) 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/06/27 01:00:06 | 0.2 s |
1/1
| 14.1 KiB | |||
| 578 | 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/06/27 01:00:05 | 17 ms |
1/1
| ||||
| 577 | 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.checkConfig(SmartbiMppOutputNode.java:162) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:116) 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/06/27 01:00:05 | 19 ms |
1/1
| ||||
| 576 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.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/06/27 01:00:05 | 17 ms |
1/1
| 14.1 KiB | |||
| 575 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.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/06/27 01:00:05 | 6 ms |
1/1
| 59.0 B | |||
| 574 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.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/06/27 01:00:05 | 13 ms |
1/1
| 2.7 KiB | 59.0 B | ||
| 573 | 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/06/27 01:00:05 | 48 ms |
1/1
| ||||
| 572 | smartbi-mining | parquet at DatasetEvent.java:208 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:874) smartbix.datamining.engine.execute.event.DatasetEvent.serializeFields(DatasetEvent.java:208) 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/06/27 01:00:04 | 0.5 s |
1/1
| 11.4 KiB | |||
| 571 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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/06/26 08:00:39 | 6 ms |
1/1
| 53.5 KiB | |||
| 570 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) 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/06/26 08:00:39 | 3 ms |
1/1
| 59.0 B | |||
| 569 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) 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/06/26 08:00:39 | 6 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 568 | smartbi-mining | foreachPartition at SparkFunctionUtil.java:146 org.apache.spark.sql.Dataset.foreachPartition(Dataset.scala:2930) smartbix.datamining.engine.util.SparkFunctionUtil.saveTable(SparkFunctionUtil.java:146) smartbix.datamining.engine.datasource.JdbcHandler.replaceDataToDatabase(JdbcHandler.java:305) smartbix.datamining.engine.execute.node.datasource.handler.MysqlHandler.executor(MysqlHandler.java:48) smartbix.datamining.engine.execute.node.datatarget.JdbcDataTargetNode.execute(JdbcDataTargetNode.java:165) 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/06/26 08:00:08 | 32 s |
1/1
| 53.5 KiB | |||
| 567 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.MetadataNode.execute(MetadataNode.java:54) 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/06/26 08:00:07 | 6 ms |
1/1
| 53.5 KiB | |||
| 566 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.MetadataNode.execute(MetadataNode.java:54) 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/06/26 08:00:07 | 3 ms |
1/1
| 59.0 B | |||
| 565 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.MetadataNode.execute(MetadataNode.java:54) 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/06/26 08:00:07 | 7 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 564 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) 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/06/26 08:00:07 | 6 ms |
1/1
| 53.5 KiB | |||
| 563 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) 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/06/26 08:00:07 | 4 ms |
1/1
| 59.0 B | |||
| 562 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) 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/06/26 08:00:07 | 7 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 561 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) 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/06/26 08:00:07 | 6 ms |
1/1
| 53.5 KiB | |||
| 560 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) 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/06/26 08:00:07 | 4 ms |
1/1
| 59.0 B | |||
| 559 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) 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/06/26 08:00:07 | 7 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 558 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) 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/06/26 08:00:07 | 7 ms |
1/1
| 53.5 KiB | |||
| 557 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) 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/06/26 08:00:07 | 4 ms |
1/1
| 59.0 B | |||
| 556 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) 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/06/26 08:00:06 | 0.9 s |
1/1
| 59.0 B | |||
| 555 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.Column2RowNode.execute(Column2RowNode.java:116) 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/06/26 08:00:05 | 0.8 s |
1/1
| ||||
| 554 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.Column2RowNode.execute(Column2RowNode.java:116) 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/06/26 08:00:05 | 3 ms |
1/1
| 59.0 B | |||
| 553 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.Column2RowNode.execute(Column2RowNode.java:116) 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/06/26 08:00:04 | 0.8 s |
1/1
| 59.0 B | |||
| 552 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.DivideNode.execute(DivideNode.java:88) 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/06/26 08:00:03 | 0.8 s |
1/1
| ||||
| 551 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DivideNode.execute(DivideNode.java:88) 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/06/26 08:00:03 | 4 ms |
1/1
| 59.0 B | |||
| 550 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DivideNode.execute(DivideNode.java:88) 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/06/26 08:00:03 | 0.8 s |
1/1
| 59.0 B | |||
| 549 | smartbi-mining | describe at DivideNode.java:229 org.apache.spark.sql.Dataset.describe(Dataset.scala:2660) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:229) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) 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/06/26 08:00:03 | 5 ms |
1/1
| 94.0 B | |||
| 548 | smartbi-mining | describe at DivideNode.java:229 org.apache.spark.sql.Dataset.describe(Dataset.scala:2660) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:229) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) 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/06/26 08:00:02 | 0.8 s |
1/1
| 94.0 B | |||
| 547 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.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.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/06/26 08:00:01 | 0.8 s |
1/1
| ||||
| 546 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.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.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/06/26 08:00:01 | 8 ms |
1/1
| 59.0 B | |||
| 545 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.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.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/06/26 08:00:00 | 0.9 s |
1/1
| 59.0 B | |||
| 544 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:77) 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/06/26 01:00:08 | 10 ms |
1/1
| 14.1 KiB | |||
| 543 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) 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.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:77) 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/06/26 01:00:08 | 12 ms |
1/1
| 59.0 B | |||
| 542 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) 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.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:77) 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/06/26 01:00:08 | 9 ms |
1/1
| 2.7 KiB | 59.0 B | ||
| 541 | smartbi-mining | foreachPartition at SparkFunctionUtil.java:146 org.apache.spark.sql.Dataset.foreachPartition(Dataset.scala:2930) smartbix.datamining.engine.util.SparkFunctionUtil.saveTable(SparkFunctionUtil.java:146) smartbix.datamining.engine.datasource.JdbcHandler.insertDataToDatabase(JdbcHandler.java:274) smartbix.datamining.engine.datasource.JdbcHandler.insertDataToDatabase(JdbcHandler.java:226) smartbix.datamining.engine.execute.node.datasource.handler.ClickHouseHandler.executorByTable(ClickHouseHandler.java:122) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.createTable(SmartbiMppOutputNode.java:98) smartbix.datamining.engine.execute.node.datatarget.SmartbiMppOutputNode.execute(SmartbiMppOutputNode.java:69) 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/06/26 01:00:07 | 1 s |
1/1
| 14.1 KiB | |||
| 540 | 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/06/26 01:00:06 | 18 ms |
1/1
| ||||
| 539 | 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.checkConfig(SmartbiMppOutputNode.java:162) smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:116) 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/06/26 01:00:06 | 26 ms |
1/1
| ||||
| 538 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.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/06/26 01:00:06 | 10 ms |
1/1
| 14.1 KiB | |||
| 537 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.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/06/26 01:00:05 | 6 ms |
1/1
| 59.0 B | |||
| 536 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.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/06/26 01:00:05 | 22 ms |
1/1
| 2.7 KiB | 59.0 B | ||
| 535 | 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/06/26 01:00:05 | 39 ms |
1/1
| ||||
| 534 | smartbi-mining | parquet at DatasetEvent.java:208 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:874) smartbix.datamining.engine.execute.event.DatasetEvent.serializeFields(DatasetEvent.java:208) 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/06/26 01:00:03 | 2 s |
1/1
| 11.4 KiB | |||
| 533 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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/06/25 08:00:38 | 6 ms |
1/1
| 53.5 KiB | |||
| 532 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) 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/06/25 08:00:38 | 3 ms |
1/1
| 59.0 B | |||
| 531 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) 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/06/25 08:00:38 | 7 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 530 | smartbi-mining | foreachPartition at SparkFunctionUtil.java:146 org.apache.spark.sql.Dataset.foreachPartition(Dataset.scala:2930) smartbix.datamining.engine.util.SparkFunctionUtil.saveTable(SparkFunctionUtil.java:146) smartbix.datamining.engine.datasource.JdbcHandler.replaceDataToDatabase(JdbcHandler.java:305) smartbix.datamining.engine.execute.node.datasource.handler.MysqlHandler.executor(MysqlHandler.java:48) smartbix.datamining.engine.execute.node.datatarget.JdbcDataTargetNode.execute(JdbcDataTargetNode.java:165) 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/06/25 08:00:07 | 31 s |
1/1
| 53.5 KiB | |||
| 529 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.MetadataNode.execute(MetadataNode.java:54) 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/06/25 08:00:07 | 6 ms |
1/1
| 53.5 KiB | |||
| 528 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.MetadataNode.execute(MetadataNode.java:54) 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/06/25 08:00:07 | 3 ms |
1/1
| 59.0 B | |||
| 527 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.MetadataNode.execute(MetadataNode.java:54) 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/06/25 08:00:07 | 6 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 526 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) 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/06/25 08:00:07 | 6 ms |
1/1
| 53.5 KiB | |||
| 525 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) 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/06/25 08:00:07 | 3 ms |
1/1
| 59.0 B | |||
| 524 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ColumnSelectionNode.execute(ColumnSelectionNode.java:48) 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/06/25 08:00:07 | 7 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 523 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) 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/06/25 08:00:07 | 6 ms |
1/1
| 53.5 KiB | |||
| 522 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) 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/06/25 08:00:07 | 4 ms |
1/1
| 59.0 B | |||
| 521 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:110) 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/06/25 08:00:07 | 7 ms |
1/1
| 53.5 KiB | 59.0 B | ||
| 520 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) 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/06/25 08:00:07 | 7 ms |
1/1
| 53.5 KiB | |||
| 519 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) 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/06/25 08:00:07 | 4 ms |
1/1
| 59.0 B | |||
| 518 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.ValueReplaceNode.execute(ValueReplaceNode.java:64) 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/06/25 08:00:06 | 0.8 s |
1/1
| 59.0 B | |||
| 517 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.Column2RowNode.execute(Column2RowNode.java:116) 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/06/25 08:00:05 | 0.8 s |
1/1
| ||||
| 516 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.Column2RowNode.execute(Column2RowNode.java:116) 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/06/25 08:00:05 | 4 ms |
1/1
| 59.0 B | |||
| 515 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.Column2RowNode.execute(Column2RowNode.java:116) 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/06/25 08:00:04 | 0.8 s |
1/1
| 59.0 B | |||
| 514 | smartbi-mining | collectAsList at DataStorageUtils.java:104 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:273) 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.preprocess.DivideNode.execute(DivideNode.java:88) 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/06/25 08:00:03 | 0.8 s |
1/1
| ||||
| 513 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DivideNode.execute(DivideNode.java:88) 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/06/25 08:00:03 | 4 ms |
1/1
| 59.0 B | |||
| 512 | smartbi-mining | count at DatasetOutput.java:65 org.apache.spark.sql.Dataset.count(Dataset.scala:3018) smartbix.datamining.engine.execute.node.output.DatasetOutput.<init>(DatasetOutput.java:65) smartbix.datamining.engine.execute.event.DatasetEvent.toOutput(DatasetEvent.java:179) smartbix.datamining.engine.execute.node.GenericNode.saveResult(GenericNode.java:273) 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.preprocess.DivideNode.execute(DivideNode.java:88) 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/06/25 08:00:03 | 0.8 s |
1/1
| 59.0 B | |||
| 511 | smartbi-mining | describe at DivideNode.java:229 org.apache.spark.sql.Dataset.describe(Dataset.scala:2660) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:229) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) 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/06/25 08:00:02 | 9 ms |
1/1
| 94.0 B | |||
| 510 | smartbi-mining | describe at DivideNode.java:229 org.apache.spark.sql.Dataset.describe(Dataset.scala:2660) smartbix.datamining.engine.execute.node.preprocess.DivideNode.divideMapDataSetMax(DivideNode.java:229) smartbix.datamining.engine.execute.node.preprocess.DivideNode.execute(DivideNode.java:70) 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/06/25 08:00:02 | 0.8 s |
1/1
| 94.0 B |