Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
---|---|---|---|---|---|---|---|---|---|
513029 | default | 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/02 15:23:53 | 14 ms |
1/1
| 64.0 KiB |