| Pool Name | Minimum Share | Pool Weight | Active Stages | Running Tasks | SchedulingMode |
|---|---|---|---|---|---|
| default | 0 | 1 | 0 | 0 | FAIR |
| Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|---|
| 209794 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167101 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:39 | 49 ms |
4/4
| ||||
| 209793 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167100 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:38 | 50 ms |
4/4
| ||||
| 209792 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167099 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:37 | 46 ms |
4/4
| ||||
| 209791 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167098 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:36 | 54 ms |
4/4
| ||||
| 209790 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167097 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:35 | 57 ms |
4/4
| ||||
| 209789 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167096 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:34 | 38 ms |
4/4
| ||||
| 209788 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167095 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:33 | 39 ms |
4/4
| ||||
| 209787 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167094 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:32 | 40 ms |
4/4
| ||||
| 209786 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167093 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:31 | 54 ms |
4/4
| ||||
| 209785 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167092 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:30 | 49 ms |
4/4
| ||||
| 209784 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167091 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:29 | 34 ms |
4/4
| ||||
| 209783 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167090 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:28 | 55 ms |
4/4
| ||||
| 209782 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167089 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:27 | 28 ms |
4/4
| ||||
| 209781 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167088 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:26 | 59 ms |
4/4
| ||||
| 209780 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167087 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:25 | 43 ms |
4/4
| ||||
| 209779 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167086 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:24 | 38 ms |
4/4
| ||||
| 209778 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167085 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:23 | 45 ms |
4/4
| ||||
| 209777 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167084 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:22 | 33 ms |
4/4
| ||||
| 209776 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167083 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:21 | 79 ms |
4/4
| ||||
| 209775 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167082 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:20 | 56 ms |
4/4
| ||||
| 209774 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167081 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:19 | 56 ms |
4/4
| ||||
| 209773 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167080 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:18 | 65 ms |
4/4
| ||||
| 209772 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167079 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:17 | 48 ms |
4/4
| ||||
| 209771 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167078 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:16 | 33 ms |
4/4
| ||||
| 209770 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167077 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:15 | 45 ms |
4/4
| ||||
| 209769 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167076 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:14 | 44 ms |
4/4
| ||||
| 209768 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167075 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:13 | 25 ms |
4/4
| ||||
| 209767 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167074 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:12 | 60 ms |
4/4
| ||||
| 209766 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167073 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:11 | 51 ms |
4/4
| ||||
| 209765 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167072 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:10 | 61 ms |
4/4
| ||||
| 209764 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167071 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:08 | 73 ms |
4/4
| ||||
| 209763 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167070 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:07 | 41 ms |
4/4
| ||||
| 209762 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167069 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:05 | 43 ms |
4/4
| ||||
| 209761 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167068 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:04 | 70 ms |
4/4
| ||||
| 209760 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167067 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:03 | 48 ms |
4/4
| ||||
| 209759 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167066 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:02 | 45 ms |
4/4
| ||||
| 209758 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167065 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:01 | 44 ms |
4/4
| ||||
| 209757 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167064 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:07:00 | 68 ms |
4/4
| ||||
| 209756 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167063 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:59 | 53 ms |
4/4
| ||||
| 209755 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167062 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:58 | 40 ms |
4/4
| ||||
| 209754 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167061 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:57 | 49 ms |
4/4
| ||||
| 209753 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167060 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:56 | 0.1 s |
4/4
| ||||
| 209752 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167059 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:55 | 53 ms |
4/4
| ||||
| 209751 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167058 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:54 | 55 ms |
4/4
| ||||
| 209750 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167057 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:53 | 49 ms |
4/4
| ||||
| 209749 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167056 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:52 | 32 ms |
4/4
| ||||
| 209748 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167055 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:51 | 45 ms |
4/4
| ||||
| 209747 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167054 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:50 | 39 ms |
4/4
| ||||
| 209746 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167053 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:49 | 28 ms |
4/4
| ||||
| 209745 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167052 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:48 | 45 ms |
4/4
| ||||
| 209744 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167051 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:47 | 67 ms |
4/4
| ||||
| 209743 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167050 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:46 | 42 ms |
4/4
| ||||
| 209742 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167049 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:45 | 42 ms |
4/4
| ||||
| 209741 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167048 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:44 | 39 ms |
4/4
| ||||
| 209740 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167047 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:43 | 62 ms |
4/4
| ||||
| 209739 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167046 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:42 | 45 ms |
4/4
| ||||
| 209738 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167045 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:41 | 50 ms |
4/4
| ||||
| 209737 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167044 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:40 | 45 ms |
4/4
| ||||
| 209736 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167043 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:39 | 59 ms |
4/4
| ||||
| 209735 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167042 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:38 | 58 ms |
4/4
| ||||
| 209734 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167041 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:37 | 32 ms |
4/4
| ||||
| 209733 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167040 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:36 | 52 ms |
4/4
| ||||
| 209732 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167039 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:35 | 47 ms |
4/4
| ||||
| 209731 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167038 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:34 | 86 ms |
4/4
| ||||
| 209730 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167037 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:32 | 46 ms |
4/4
| ||||
| 209729 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167036 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:31 | 33 ms |
4/4
| ||||
| 209728 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167035 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:29 | 61 ms |
4/4
| ||||
| 209727 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167034 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:28 | 67 ms |
4/4
| ||||
| 209726 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167033 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:27 | 41 ms |
4/4
| ||||
| 209725 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167032 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:26 | 38 ms |
4/4
| ||||
| 209724 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167031 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:25 | 62 ms |
4/4
| ||||
| 209723 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167030 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:23 | 43 ms |
4/4
| ||||
| 209722 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167029 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:22 | 56 ms |
4/4
| ||||
| 209721 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167028 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:21 | 43 ms |
4/4
| ||||
| 209720 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167027 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:20 | 43 ms |
4/4
| ||||
| 209719 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167026 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:18 | 0.1 s |
4/4
| ||||
| 209718 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167025 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:17 | 39 ms |
4/4
| ||||
| 209717 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167024 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:16 | 42 ms |
4/4
| ||||
| 209716 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167023 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:15 | 59 ms |
4/4
| ||||
| 209715 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167022 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:14 | 24 ms |
4/4
| ||||
| 209714 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167021 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:13 | 56 ms |
4/4
| ||||
| 209713 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167020 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:12 | 60 ms |
4/4
| ||||
| 209712 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167019 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:11 | 0.1 s |
4/4
| ||||
| 209711 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167018 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:10 | 36 ms |
4/4
| ||||
| 209710 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167017 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:09 | 37 ms |
4/4
| ||||
| 209709 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167016 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:08 | 75 ms |
4/4
| ||||
| 209708 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167015 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:07 | 64 ms |
4/4
| ||||
| 209707 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167014 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:06 | 36 ms |
4/4
| ||||
| 209706 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167013 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:05 | 50 ms |
4/4
| ||||
| 209705 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167012 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:04 | 60 ms |
4/4
| ||||
| 209704 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167011 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:03 | 36 ms |
4/4
| ||||
| 209703 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167010 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:02 | 31 ms |
4/4
| ||||
| 209702 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167009 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:01 | 45 ms |
4/4
| ||||
| 209701 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167008 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:06:00 | 50 ms |
4/4
| ||||
| 209700 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167007 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:05:59 | 64 ms |
4/4
| ||||
| 209699 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167006 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:05:58 | 75 ms |
4/4
| ||||
| 209698 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167005 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:05:57 | 51 ms |
4/4
| ||||
| 209697 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167004 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:05:56 | 34 ms |
4/4
| ||||
| 209696 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167003 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:05:55 | 28 ms |
4/4
| ||||
| 209695 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = c4cb2a4c-9634-40d4-8604-13eedc951f27
batch = 13167002 start at JobTemplate.java:220 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) com.flex83.jobrunner.template.JobTemplate.write(JobTemplate.java:220) com.flex83.jobrunner.template.JobTemplate.run(JobTemplate.java:154) com.flex83.jobrunner.JobRunner.submitToExecutor(JobRunner.java:130) com.flex83.jobrunner.JobRunner.lambda$submit$1(JobRunner.java:120) java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source) | 2025/09/25 04:05:54 | 43 ms |
4/4
|