|
1
|
parquet at DatasetEvent.java:208
+details
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/04/02 01:00:07
|
5 s
|
[1]
|
|
28
|
parquet at DatasetEvent.java:208
+details
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/04/03 01:00:04
|
1 s
|
[28]
|
|
55
|
parquet at DatasetEvent.java:208
+details
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/04/04 01:00:03
|
1 s
|
[55]
|
|
82
|
parquet at DatasetEvent.java:208
+details
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/04/05 01:00:03
|
3 s
|
[82]
|
|
109
|
parquet at DatasetEvent.java:208
+details
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/04/06 01:00:03
|
2 s
|
[109]
|
|
136
|
parquet at DatasetEvent.java:208
+details
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/04/07 01:00:04
|
2 s
|
[136]
|
|
163
|
parquet at DatasetEvent.java:208
+details
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/04/08 01:00:03
|
2 s
|
[163]
|
|
190
|
parquet at DatasetEvent.java:208
+details
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/04/09 01:00:02
|
2 s
|
[190]
|
|
217
|
parquet at DatasetEvent.java:208
+details
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/04/10 01:00:03
|
3 s
|
[217]
|
|
244
|
parquet at DatasetEvent.java:208
+details
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/04/11 01:00:04
|
0.6 s
|
[244]
|
|
271
|
parquet at DatasetEvent.java:208
+details
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/04/12 01:00:03
|
3 s
|
[271]
|
|
298
|
parquet at DatasetEvent.java:208
+details
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/04/13 01:00:04
|
2 s
|
[298]
|
|
325
|
parquet at DatasetEvent.java:208
+details
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/04/14 01:00:02
|
3 s
|
[325]
|
|
352
|
parquet at DatasetEvent.java:208
+details
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/04/15 01:00:02
|
3 s
|
[352]
|
|
379
|
parquet at DatasetEvent.java:208
+details
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/04/16 01:00:03
|
2 s
|
[379]
|
|
406
|
parquet at DatasetEvent.java:208
+details
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/04/17 01:00:03
|
2 s
|
[406]
|
|
433
|
parquet at DatasetEvent.java:208
+details
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/04/18 01:00:02
|
2 s
|
[433]
|
|
460
|
parquet at DatasetEvent.java:208
+details
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/04/19 01:00:04
|
0.5 s
|
[460]
|
|
487
|
parquet at DatasetEvent.java:208
+details
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/04/20 01:00:02
|
4 s
|
[487]
|
|
514
|
parquet at DatasetEvent.java:208
+details
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/04/21 01:00:03
|
1 s
|
[514]
|
|
541
|
parquet at DatasetEvent.java:208
+details
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/04/22 01:00:02
|
3 s
|
[541]
|
|
568
|
parquet at DatasetEvent.java:208
+details
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/04/23 01:00:02
|
1 s
|
[568]
|
|
595
|
parquet at DatasetEvent.java:208
+details
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/04/24 01:00:02
|
2 s
|
[595]
|
|
622
|
parquet at DatasetEvent.java:208
+details
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/04/25 01:00:04
|
3 s
|
[622]
|
|
649
|
parquet at DatasetEvent.java:208
+details
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/04/26 01:00:04
|
2 s
|
[649]
|
|
676
|
parquet at DatasetEvent.java:208
+details
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/04/27 01:00:04
|
3 s
|
[676]
|
|
703
|
parquet at DatasetEvent.java:208
+details
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/04/28 01:00:02
|
3 s
|
[703]
|
|
730
|
parquet at DatasetEvent.java:208
+details
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/04/29 01:00:02
|
2 s
|
[730]
|
|
757
|
parquet at DatasetEvent.java:208
+details
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/04/30 01:00:03
|
2 s
|
[757]
|
|
4
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/02 01:00:15
|
0.5 s
|
[7]
|
|
25
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/02 08:00:10
|
33 s
|
[25]
|
|
31
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/03 01:00:06
|
4 s
|
[34]
|
|
52
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/03 08:00:08
|
30 s
|
[52]
|
|
58
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/04 01:00:05
|
2 s
|
[61]
|
|
79
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/04 08:00:08
|
36 s
|
[79]
|
|
85
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/05 01:00:06
|
0.2 s
|
[88]
|
|
106
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/05 08:00:08
|
34 s
|
[106]
|
|
112
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/06 01:00:06
|
2 s
|
[115]
|
|
133
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/06 08:00:07
|
33 s
|
[133]
|
|
139
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/07 01:00:06
|
2 s
|
[142]
|
|
160
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/07 08:00:07
|
28 s
|
[160]
|
|
166
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/08 01:00:06
|
3 s
|
[169]
|
|
187
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/08 08:00:08
|
36 s
|
[187]
|
|
193
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/09 01:00:05
|
2 s
|
[196]
|
|
214
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/09 08:00:07
|
34 s
|
[214]
|
|
220
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/10 01:00:07
|
0.5 s
|
[223]
|
|
241
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/10 08:00:07
|
30 s
|
[241]
|
|
247
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/11 01:00:05
|
2 s
|
[250]
|
|
268
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/11 08:00:07
|
33 s
|
[268]
|
|
274
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/12 01:00:07
|
1 s
|
[277]
|
|
295
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/12 08:00:07
|
29 s
|
[295]
|
|
301
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/13 01:00:07
|
0.2 s
|
[304]
|
|
322
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/13 08:00:07
|
28 s
|
[322]
|
|
328
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/14 01:00:06
|
0.7 s
|
[331]
|
|
349
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/14 08:00:07
|
30 s
|
[349]
|
|
355
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/15 01:00:06
|
2 s
|
[358]
|
|
376
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/15 08:00:07
|
33 s
|
[376]
|
|
382
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/16 01:00:05
|
0.2 s
|
[385]
|
|
403
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/16 08:00:07
|
31 s
|
[403]
|
|
409
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/17 01:00:06
|
0.5 s
|
[412]
|
|
430
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/17 08:00:07
|
29 s
|
[430]
|
|
436
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/18 01:00:05
|
2 s
|
[439]
|
|
457
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/18 08:00:07
|
24 s
|
[457]
|
|
463
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/19 01:00:05
|
2 s
|
[466]
|
|
484
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/19 08:00:07
|
34 s
|
[484]
|
|
490
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/20 01:00:06
|
1 s
|
[493]
|
|
511
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/20 08:00:07
|
33 s
|
[511]
|
|
517
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/21 01:00:06
|
1 s
|
[520]
|
|
538
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/21 08:00:07
|
31 s
|
[538]
|
|
544
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/22 01:00:06
|
2 s
|
[547]
|
|
565
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/22 08:00:07
|
37 s
|
[565]
|
|
571
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/23 01:00:05
|
2 s
|
[574]
|
|
592
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/23 08:00:07
|
31 s
|
[592]
|
|
598
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/24 01:00:05
|
3 s
|
[601]
|
|
619
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/24 08:00:07
|
30 s
|
[619]
|
|
625
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/25 01:00:07
|
2 s
|
[628]
|
|
646
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/25 08:00:07
|
30 s
|
[646]
|
|
652
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/26 01:00:07
|
2 s
|
[655]
|
|
673
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/26 08:00:07
|
34 s
|
[673]
|
|
679
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/27 01:00:08
|
0.9 s
|
[682]
|
|
700
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/27 08:00:07
|
35 s
|
[700]
|
|
706
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/28 01:00:06
|
1 s
|
[709]
|
|
727
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/28 08:00:07
|
34 s
|
[727]
|
|
733
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/29 01:00:05
|
0.5 s
|
[736]
|
|
754
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/29 08:00:07
|
32 s
|
[754]
|
|
760
|
foreachPartition at SparkFunctionUtil.java:146
+details
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/04/30 01:00:06
|
2 s
|
[763]
|
|
17
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/02 08:00:09
|
1 ms
|
|
|
44
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/03 08:00:07
|
0 ms
|
|
|
71
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/04 08:00:07
|
0 ms
|
|
|
98
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/05 08:00:07
|
0 ms
|
|
|
125
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/06 08:00:07
|
0 ms
|
|
|
152
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/07 08:00:07
|
0 ms
|
|
|
179
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/08 08:00:07
|
1 ms
|
|
|
206
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/09 08:00:07
|
0 ms
|
|
|
233
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/10 08:00:07
|
0 ms
|
|
|
260
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/11 08:00:07
|
0 ms
|
|
|
287
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/12 08:00:07
|
0 ms
|
|
|
314
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/13 08:00:07
|
0 ms
|
|
|
341
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/14 08:00:07
|
0 ms
|
|
|
368
|
createOrReplaceTempView at DeriveColumnNode.java:81
+details
createOrReplaceTempView at DeriveColumnNode.java:81
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3313)
smartbix.datamining.engine.execute.node.preprocess.DeriveColumnNode.execute(DeriveColumnNode.java:81)
smartbix.datamining.engine.execute.node.GenericNode.start(GenericNode.java:117)
smartbix.datamining.engine.experiment.execute.node.LocalNodeExecutor.run(LocalNodeExecutor.java:49)
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
java.util.concurrent.FutureTask.run(FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)
|
2025/04/15 08:00:07
|
1 ms
|
|