|
227782
|
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/03 15:08:18
|
36 ms
|
[331968]
|
|
227783
|
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/03 15:08:18
|
30 ms
|
[331969]
|
|
227792
|
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/03 15:08:43
|
29 ms
|
[331982]
|
|
227795
|
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/03 15:08:59
|
47 ms
|
[331987]
|
|
227796
|
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/03 15:08:59
|
59 ms
|
[331988]
|
|
227797
|
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/03 15:08:59
|
46 ms
|
[331990]
|
|
227798
|
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/03 15:08:59
|
41 ms
|
[331989]
|
|
227799
|
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/03 15:08:59
|
45 ms
|
[331991]
|
|
227800
|
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/03 15:08:59
|
50 ms
|
[331992]
|
|
227801
|
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/03 15:08:59
|
38 ms
|
[331993]
|
|
227808
|
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/03 15:09:38
|
64 ms
|
[332005]
|
|
227809
|
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/03 15:09:38
|
51 ms
|
[332006]
|
|
227810
|
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/03 15:09:38
|
42 ms
|
[332007]
|
|
227811
|
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/03 15:09:39
|
37 ms
|
[332008]
|
|
227815
|
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/03 15:10:00
|
38 ms
|
[332017]
|
|
227816
|
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/03 15:10:00
|
31 ms
|
[332018]
|
|
227825
|
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/03 15:10:26
|
30 ms
|
[332031]
|
|
227828
|
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/03 15:10:42
|
0.1 s
|
[332037]
|
|
227829
|
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/03 15:10:42
|
96 ms
|
[332036]
|
|
227830
|
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/03 15:10:42
|
48 ms
|
[332038]
|
|
227831
|
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/03 15:10:42
|
43 ms
|
[332039]
|
|
227832
|
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/03 15:10:42
|
44 ms
|
[332040]
|
|
227833
|
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/03 15:10:42
|
49 ms
|
[332041]
|
|
227834
|
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/03 15:10:42
|
32 ms
|
[332042]
|
|
227841
|
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/03 15:11:21
|
49 ms
|
[332055]
|
|
227842
|
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/03 15:11:21
|
41 ms
|
[332054]
|
|
227843
|
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/03 15:11:21
|
42 ms
|
[332056]
|
|
227844
|
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/03 15:11:21
|
30 ms
|
[332057]
|
|
227848
|
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/03 15:11:43
|
34 ms
|
[332066]
|
|
227849
|
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/03 15:11:43
|
29 ms
|
[332067]
|
|
227858
|
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/03 15:12:09
|
32 ms
|
[332080]
|
|
227861
|
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/03 15:12:24
|
45 ms
|
[332085]
|
|
227862
|
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/03 15:12:24
|
57 ms
|
[332086]
|
|
227863
|
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/03 15:12:25
|
40 ms
|
[332087]
|
|
227864
|
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/03 15:12:25
|
36 ms
|
[332088]
|
|
227865
|
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/03 15:12:25
|
45 ms
|
[332089]
|
|
227866
|
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/03 15:12:25
|
47 ms
|
[332090]
|
|
227867
|
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/03 15:12:25
|
35 ms
|
[332091]
|
|
227874
|
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/03 15:13:04
|
46 ms
|
[332104]
|
|
227875
|
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/03 15:13:04
|
38 ms
|
[332103]
|
|
227876
|
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/03 15:13:04
|
44 ms
|
[332105]
|
|
227877
|
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/03 15:13:04
|
33 ms
|
[332106]
|
|
227881
|
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/03 15:13:26
|
30 ms
|
[332115]
|
|
227882
|
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/03 15:13:26
|
29 ms
|
[332116]
|
|
227891
|
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/03 15:13:52
|
30 ms
|
[332129]
|
|
227894
|
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/03 15:14:07
|
42 ms
|
[332134]
|
|
227895
|
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/03 15:14:07
|
47 ms
|
[332135]
|
|
227896
|
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/03 15:14:07
|
51 ms
|
[332137]
|
|
227897
|
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/03 15:14:07
|
40 ms
|
[332136]
|
|
227898
|
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/03 15:14:07
|
36 ms
|
[332138]
|
|
227899
|
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/03 15:14:07
|
39 ms
|
[332139]
|
|
227900
|
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/03 15:14:07
|
49 ms
|
[332140]
|
|
227907
|
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/03 15:14:47
|
45 ms
|
[332152]
|
|
227908
|
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/03 15:14:47
|
43 ms
|
[332153]
|
|
227909
|
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/03 15:14:47
|
49 ms
|
[332155]
|
|
227910
|
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/03 15:14:47
|
45 ms
|
[332154]
|
|
227914
|
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/03 15:15:09
|
53 ms
|
[332164]
|
|
227915
|
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/03 15:15:09
|
35 ms
|
[332165]
|
|
227924
|
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/03 15:15:35
|
29 ms
|
[332178]
|
|
227927
|
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/03 15:15:50
|
61 ms
|
[332183]
|
|
227928
|
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/03 15:15:50
|
45 ms
|
[332184]
|
|
227929
|
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/03 15:15:50
|
72 ms
|
[332185]
|
|
227930
|
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/03 15:15:50
|
68 ms
|
[332186]
|
|
227931
|
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/03 15:15:50
|
34 ms
|
[332187]
|
|
227932
|
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/03 15:15:50
|
34 ms
|
[332188]
|
|
227933
|
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/03 15:15:50
|
90 ms
|
[332189]
|
|
227940
|
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/03 15:16:30
|
39 ms
|
[332201]
|
|
227941
|
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/03 15:16:30
|
49 ms
|
[332202]
|
|
227942
|
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/03 15:16:30
|
39 ms
|
[332203]
|
|
227943
|
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/03 15:16:30
|
42 ms
|
[332204]
|
|
227947
|
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/03 15:16:52
|
33 ms
|
[332213]
|
|
227948
|
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/03 15:16:52
|
33 ms
|
[332214]
|
|
227957
|
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/03 15:17:18
|
87 ms
|
[332227]
|
|
227960
|
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/03 15:17:33
|
67 ms
|
[332233]
|
|
227961
|
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/03 15:17:33
|
62 ms
|
[332232]
|
|
227962
|
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/03 15:17:33
|
41 ms
|
[332235]
|
|
227963
|
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/03 15:17:33
|
30 ms
|
[332234]
|
|
227964
|
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/03 15:17:33
|
56 ms
|
[332236]
|
|
227965
|
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/03 15:17:33
|
51 ms
|
[332237]
|
|
227966
|
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/03 15:17:33
|
33 ms
|
[332238]
|
|
227973
|
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/03 15:18:13
|
86 ms
|
[332250]
|
|
227974
|
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/03 15:18:13
|
78 ms
|
[332251]
|
|
227975
|
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/03 15:18:13
|
51 ms
|
[332252]
|
|
227976
|
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/03 15:18:13
|
51 ms
|
[332253]
|
|
227980
|
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/03 15:18:35
|
70 ms
|
[332262]
|
|
227981
|
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/03 15:18:35
|
37 ms
|
[332263]
|
|
227990
|
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/03 15:19:01
|
71 ms
|
[332276]
|
|
227993
|
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/03 15:19:16
|
56 ms
|
[332281]
|
|
227994
|
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/03 15:19:16
|
41 ms
|
[332282]
|
|
227995
|
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/03 15:19:16
|
82 ms
|
[332283]
|
|
227996
|
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/03 15:19:16
|
79 ms
|
[332284]
|
|
227997
|
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/03 15:19:16
|
59 ms
|
[332286]
|
|
227998
|
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/03 15:19:16
|
49 ms
|
[332285]
|
|
227999
|
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/03 15:19:16
|
35 ms
|
[332287]
|
|
228006
|
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/03 15:19:56
|
57 ms
|
[332299]
|
|
228007
|
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/03 15:19:56
|
66 ms
|
[332300]
|
|
228008
|
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/03 15:19:56
|
56 ms
|
[332301]
|
|
228009
|
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/03 15:19:56
|
42 ms
|
[332302]
|
|
228013
|
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/03 15:20:18
|
36 ms
|
[332311]
|
|
228014
|
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/03 15:20:18
|
33 ms
|
[332312]
|