|
226481
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:42:42
|
40 ms
|
[330049]
|
|
226482
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:42:42
|
41 ms
|
[330050]
|
|
226483
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:42:42
|
45 ms
|
[330051]
|
|
226484
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:42:42
|
41 ms
|
[330052]
|
|
226488
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:43:04
|
34 ms
|
[330061]
|
|
226489
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:43:04
|
29 ms
|
[330062]
|
|
226498
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:43:30
|
29 ms
|
[330075]
|
|
226501
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:43:45
|
39 ms
|
[330080]
|
|
226502
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:43:45
|
40 ms
|
[330081]
|
|
226503
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:43:45
|
51 ms
|
[330083]
|
|
226504
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:43:45
|
46 ms
|
[330082]
|
|
226505
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:43:45
|
37 ms
|
[330084]
|
|
226506
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:43:45
|
39 ms
|
[330085]
|
|
226507
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:43:45
|
35 ms
|
[330086]
|
|
226514
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:44:25
|
54 ms
|
[330098]
|
|
226515
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:44:25
|
38 ms
|
[330099]
|
|
226516
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:44:25
|
42 ms
|
[330100]
|
|
226517
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:44:25
|
41 ms
|
[330101]
|
|
226521
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:44:46
|
34 ms
|
[330110]
|
|
226522
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:44:46
|
31 ms
|
[330111]
|
|
226531
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:45:12
|
30 ms
|
[330124]
|
|
226534
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:45:28
|
44 ms
|
[330129]
|
|
226535
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:45:28
|
43 ms
|
[330130]
|
|
226536
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:45:28
|
42 ms
|
[330132]
|
|
226537
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:45:28
|
37 ms
|
[330131]
|
|
226538
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:45:28
|
47 ms
|
[330133]
|
|
226539
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:45:28
|
44 ms
|
[330134]
|
|
226540
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:45:28
|
34 ms
|
[330135]
|
|
226547
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:46:07
|
51 ms
|
[330147]
|
|
226548
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:46:07
|
49 ms
|
[330148]
|
|
226549
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:46:07
|
44 ms
|
[330150]
|
|
226550
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:46:07
|
40 ms
|
[330149]
|
|
226554
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:46:29
|
36 ms
|
[330159]
|
|
226555
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:46:29
|
31 ms
|
[330160]
|
|
226564
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:46:55
|
31 ms
|
[330173]
|
|
226567
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:10
|
60 ms
|
[330178]
|
|
226568
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:10
|
51 ms
|
[330180]
|
|
226569
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:10
|
41 ms
|
[330179]
|
|
226570
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:11
|
39 ms
|
[330181]
|
|
226571
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:11
|
40 ms
|
[330182]
|
|
226572
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:11
|
34 ms
|
[330183]
|
|
226573
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:11
|
34 ms
|
[330184]
|
|
226580
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:50
|
44 ms
|
[330197]
|
|
226581
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:50
|
47 ms
|
[330196]
|
|
226582
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:50
|
35 ms
|
[330199]
|
|
226583
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:47:50
|
33 ms
|
[330198]
|
|
226587
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:48:12
|
39 ms
|
[330208]
|
|
226588
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:48:12
|
31 ms
|
[330209]
|
|
226597
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:48:38
|
30 ms
|
[330222]
|
|
226600
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:48:53
|
51 ms
|
[330228]
|
|
226601
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:48:53
|
50 ms
|
[330227]
|
|
226602
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:48:53
|
46 ms
|
[330229]
|
|
226603
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:48:53
|
40 ms
|
[330230]
|
|
226604
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:48:54
|
0.2 s
|
[330231]
|
|
226605
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:48:54
|
0.1 s
|
[330232]
|
|
226606
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:48:54
|
45 ms
|
[330233]
|
|
226613
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:49:34
|
40 ms
|
[330245]
|
|
226614
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:49:34
|
35 ms
|
[330246]
|
|
226615
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:49:34
|
55 ms
|
[330248]
|
|
226616
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:49:34
|
43 ms
|
[330247]
|
|
226620
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:49:56
|
66 ms
|
[330257]
|
|
226621
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:49:56
|
68 ms
|
[330258]
|
|
226630
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:50:22
|
36 ms
|
[330271]
|
|
226633
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:50:38
|
49 ms
|
[330277]
|
|
226634
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:50:38
|
56 ms
|
[330276]
|
|
226635
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:50:38
|
45 ms
|
[330278]
|
|
226636
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:50:38
|
47 ms
|
[330279]
|
|
226637
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:50:38
|
42 ms
|
[330280]
|
|
226638
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:50:38
|
35 ms
|
[330281]
|
|
226639
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:50:38
|
39 ms
|
[330282]
|
|
226646
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:51:17
|
51 ms
|
[330294]
|
|
226647
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:51:17
|
47 ms
|
[330295]
|
|
226648
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:51:17
|
54 ms
|
[330297]
|
|
226649
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:51:17
|
37 ms
|
[330296]
|
|
226653
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:51:40
|
60 ms
|
[330306]
|
|
226654
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:51:40
|
35 ms
|
[330307]
|
|
226663
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:52:06
|
35 ms
|
[330320]
|
|
226666
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:52:21
|
71 ms
|
[330325]
|
|
226667
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:52:21
|
40 ms
|
[330326]
|
|
226668
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:52:21
|
43 ms
|
[330327]
|
|
226669
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:52:21
|
48 ms
|
[330328]
|
|
226670
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:52:21
|
36 ms
|
[330329]
|
|
226671
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:52:21
|
47 ms
|
[330330]
|
|
226672
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:52:21
|
37 ms
|
[330331]
|
|
226679
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:53:01
|
82 ms
|
[330344]
|
|
226680
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:53:01
|
69 ms
|
[330343]
|
|
226681
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:53:01
|
69 ms
|
[330346]
|
|
226682
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:53:01
|
39 ms
|
[330345]
|
|
226686
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:53:23
|
65 ms
|
[330356]
|
|
226687
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:53:23
|
62 ms
|
[330355]
|
|
226696
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:53:49
|
35 ms
|
[330369]
|
|
226699
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:54:05
|
95 ms
|
[330375]
|
|
226700
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:54:05
|
86 ms
|
[330376]
|
|
226701
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:54:05
|
95 ms
|
[330377]
|
|
226702
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:54:05
|
86 ms
|
[330374]
|
|
226703
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:54:05
|
44 ms
|
[330379]
|
|
226704
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:54:05
|
44 ms
|
[330378]
|
|
226705
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:54:05
|
37 ms
|
[330380]
|
|
226712
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:54:44
|
60 ms
|
[330392]
|
|
226713
|
load at CsvStorage.scala:52
+details
load at CsvStorage.scala:52
org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:188)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$6(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$2(CsvStorage.scala:52)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.util.spark.storage.CsvStorage.$anonfun$read$1(CsvStorage.scala:36)
scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426)
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
|
2025/08/01 15:54:44
|
36 ms
|
[330393]
|