|
4509
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:52
|
64 ms
|
[7020]
|
|
4510
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:52
|
0 ms
|
|
|
4511
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:52
|
1 ms
|
|
|
4512
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:52
|
0 ms
|
|
|
4513
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:538)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:326)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:53
|
32 ms
|
[7021]
|
|
4514
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:53
|
0 ms
|
|
|
4515
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:53
|
0 ms
|
|
|
4516
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:53
|
0 ms
|
|
|
4517
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:538)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:326)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:54
|
37 ms
|
[7025]
|
|
4518
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:54
|
0 ms
|
|
|
4519
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:54
|
37 ms
|
[7026]
|
|
4520
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:54
|
1 ms
|
|
|
4521
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:54
|
0 ms
|
|
|
4522
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:54
|
0 ms
|
|
|
4523
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:55
|
74 ms
|
[7032]
|
|
4524
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:55
|
0 ms
|
|
|
4525
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:55
|
0 ms
|
|
|
4526
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:56
|
31 ms
|
[7035]
|
|
4527
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:56
|
32 ms
|
[7036]
|
|
4528
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:56
|
0 ms
|
|
|
4529
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:56
|
0 ms
|
|
|
4530
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:56
|
71 ms
|
[7040]
|
|
4531
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:57
|
0 ms
|
|
|
4532
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:57
|
0 ms
|
|
|
4533
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:538)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:326)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:57
|
38 ms
|
[7043]
|
|
4534
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:57
|
0 ms
|
|
|
4535
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:57
|
1.0 s
|
[7044][7045][7046][7047][7048][7050]
|
|
4536
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:58
|
0 ms
|
|
|
4537
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:58
|
4 s
|
[7049][7052][7056]
|
|
4538
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:58
|
0 ms
|
|
|
4539
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:30:59
|
5 s
|
[7053][7054][7055][7057][7058]
|
|
4540
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:31:04
|
0 ms
|
|
|
4541
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:31:05
|
0 ms
|
|
|
4542
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:31:06
|
1 ms
|
|
|
4543
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:31:07
|
0 ms
|
|
|
4544
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:31:08
|
0 ms
|
|
|
4545
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:31:09
|
50 ms
|
[7062]
|
|
4546
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:31:09
|
0 ms
|
|
|
4547
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:31:31
|
10 s
|
[7083][7084][7085][7086][7087][7088][7089][7090][7091][7092][7093][7094][7095][7096][7097][7098][7099][7100][7101][7102][7103]
|
|
4548
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:33:22
|
0 ms
|
|
|
4549
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:33:22
|
0 ms
|
|
|
4550
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:33:35
|
11 s
|
[7117][7118][7119][7120][7121][7122][7123][7124][7125][7126][7127][7128]
|
|
4551
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:34:58
|
0 ms
|
|
|
4552
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:34:58
|
0.3 s
|
[7130]
|
|
4553
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
0 ms
|
|
|
4554
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
0 ms
|
|
|
4555
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
1 ms
|
|
|
4556
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
0 ms
|
|
|
4557
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
0 ms
|
|
|
4558
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
0 ms
|
|
|
4559
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
0 ms
|
|
|
4560
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
0 ms
|
|
|
4561
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
0 ms
|
|
|
4562
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
0 ms
|
|
|
4563
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:23
|
0 ms
|
|
|
4564
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:24
|
76 ms
|
[7141]
|
|
4565
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:24
|
0 ms
|
|
|
4566
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:24
|
39 ms
|
[7142]
|
|
4567
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:24
|
0 ms
|
|
|
4568
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:24
|
0 ms
|
|
|
4569
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:24
|
0.2 s
|
[7143]
|
|
4570
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:24
|
30 ms
|
[7144]
|
|
4571
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:25
|
0 ms
|
|
|
4572
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:25
|
1 ms
|
|
|
4573
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:25
|
0 ms
|
|
|
4574
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:25
|
33 ms
|
[7151]
|
|
4575
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:25
|
0 ms
|
|
|
4576
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:26
|
0 ms
|
|
|
4577
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:26
|
0 ms
|
|
|
4578
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:26
|
0.8 s
|
[7154][7155][7156][7158][7159]
|
|
4579
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:26
|
37 ms
|
[7157]
|
|
4580
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:26
|
0 ms
|
|
|
4581
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:26
|
0 ms
|
|
|
4582
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:26
|
43 ms
|
[7160]
|
|
4583
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:27
|
0 ms
|
|
|
4584
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:27
|
0 ms
|
|
|
4585
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:27
|
0 ms
|
|
|
4586
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:27
|
35 ms
|
[7169]
|
|
4587
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:28
|
0 ms
|
|
|
4588
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:28
|
0 ms
|
|
|
4589
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:28
|
1 s
|
[7172][7173][7176]
|
|
4590
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:28
|
60 ms
|
[7171]
|
|
4591
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:28
|
1.0 s
|
[7174][7175][7177][7180][7183]
|
|
4592
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:28
|
0 ms
|
|
|
4593
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:29
|
34 ms
|
[7181]
|
|
4594
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:29
|
1 ms
|
|
|
4595
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:29
|
0.9 s
|
[7182][7184][7185]
|
|
4596
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:29
|
1 ms
|
|
|
4597
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:30
|
0.3 s
|
[7189]
|
|
4598
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:29
|
32 ms
|
[7187]
|
|
4599
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:30
|
0 ms
|
|
|
4600
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:30
|
0 ms
|
|
|
4601
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:30
|
0 ms
|
|
|
4602
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:30
|
1 ms
|
|
|
4603
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:31
|
34 ms
|
[7193]
|
|
4604
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:31
|
0.8 s
|
[7194][7195][7196]
|
|
4605
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:31
|
0 ms
|
|
|
4606
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameReader.csv(DataFrameReader.scala:444)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvFile(DataFrameCommonJob.java:314)
com.adb.hdh.spark.job.impl.DataFrameCommonJob.readCsvAndGetDataSet(DataFrameCommonJob.java:195)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadCsv(DataFrameStructuredLoaderJob.java:272)
com.adb.hdh.spark.job.impl.DataFrameStructuredLoaderJob.loadUet(DataFrameStructuredLoaderJob.java:73)
com.adb.hdh.spark.job.impl.CommonJob.getDataFrame(CommonJob.java:27)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:19)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:32
|
0.1 s
|
[7201]
|
|
4607
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.Dataset.createOrReplaceTempView(Dataset.scala:3910)
com.adb.hdh.spark.job.impl.LoadJob.exec(LoadJob.java:21)
com.adb.hdh.spark.jobs.SparkJobRunnerService.createFrames(SparkJobRunnerService.java:338)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:76)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:32
|
0 ms
|
|
|
4608
|
PersistFrame
+details
PersistFrame
org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:802)
com.adb.hdh.spark.job.impl.PersistJob.exec(PersistJob.java:35)
com.adb.hdh.spark.jobs.SparkJobRunnerService.runJob(SparkJobRunnerService.java:77)
com.adb.hdh.spark.jobs.AbstractJobThread.run(AbstractJobThread.java:47)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)
|
2026/05/20 14:35:33
|
0.9 s
|
[7207][7208][7209][7210][7211][7213]
|