| 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 |
|---|---|---|---|---|---|---|---|---|---|
| 303651 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225552 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/05/09 13:17:17 | 33 ms |
4/4
| ||||
| 303650 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225551 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/05/09 13:17:16 | 40 ms |
4/4
| ||||
| 303649 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225550 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/05/09 13:17:15 | 36 ms |
4/4
| ||||
| 303648 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225549 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/05/09 13:17:14 | 42 ms |
4/4
| ||||
| 303647 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225548 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/05/09 13:17:13 | 35 ms |
4/4
| ||||
| 303646 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225547 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/05/09 13:17:12 | 0.1 s |
4/4
| ||||
| 303645 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225546 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/05/09 13:17:11 | 38 ms |
4/4
| ||||
| 303644 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225545 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/05/09 13:17:10 | 38 ms |
4/4
| ||||
| 303643 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225544 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/05/09 13:17:09 | 42 ms |
4/4
| ||||
| 303642 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225543 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/05/09 13:17:08 | 60 ms |
4/4
| ||||
| 303641 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225542 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/05/09 13:17:07 | 50 ms |
4/4
| ||||
| 303640 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225541 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/05/09 13:17:06 | 41 ms |
4/4
| ||||
| 303639 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225540 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/05/09 13:17:05 | 80 ms |
4/4
| ||||
| 303638 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225539 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/05/09 13:17:04 | 51 ms |
4/4
| ||||
| 303637 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225538 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/05/09 13:17:03 | 40 ms |
4/4
| ||||
| 303636 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225537 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/05/09 13:17:02 | 38 ms |
4/4
| ||||
| 303635 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225536 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/05/09 13:17:01 | 58 ms |
4/4
| ||||
| 303634 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225535 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/05/09 13:17:00 | 27 ms |
4/4
| ||||
| 303633 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225534 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/05/09 13:16:59 | 0.1 s |
4/4
| ||||
| 303632 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225533 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/05/09 13:16:58 | 99 ms |
4/4
| ||||
| 303631 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225532 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/05/09 13:16:57 | 95 ms |
4/4
| ||||
| 303630 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225531 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/05/09 13:16:56 | 43 ms |
4/4
| ||||
| 303629 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225530 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/05/09 13:16:55 | 46 ms |
4/4
| ||||
| 303628 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225529 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/05/09 13:16:54 | 46 ms |
4/4
| ||||
| 303627 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225528 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/05/09 13:16:53 | 41 ms |
4/4
| ||||
| 303626 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225527 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/05/09 13:16:52 | 44 ms |
4/4
| ||||
| 303625 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225526 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/05/09 13:16:51 | 65 ms |
4/4
| ||||
| 303624 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225525 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/05/09 13:16:50 | 35 ms |
4/4
| ||||
| 303623 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225524 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/05/09 13:16:49 | 39 ms |
4/4
| ||||
| 303622 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225523 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/05/09 13:16:47 | 51 ms |
4/4
| ||||
| 303621 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225522 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/05/09 13:16:46 | 47 ms |
4/4
| ||||
| 303620 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225521 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/05/09 13:16:45 | 36 ms |
4/4
| ||||
| 303619 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225520 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/05/09 13:16:44 | 42 ms |
4/4
| ||||
| 303618 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225519 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/05/09 13:16:43 | 40 ms |
4/4
| ||||
| 303617 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225518 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/05/09 13:16:42 | 43 ms |
4/4
| ||||
| 303616 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225517 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/05/09 13:16:41 | 41 ms |
4/4
| ||||
| 303615 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225516 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/05/09 13:16:40 | 41 ms |
4/4
| ||||
| 303614 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225515 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/05/09 13:16:39 | 64 ms |
4/4
| ||||
| 303613 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225514 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/05/09 13:16:38 | 59 ms |
4/4
| ||||
| 303612 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225513 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/05/09 13:16:37 | 46 ms |
4/4
| ||||
| 303611 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225512 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/05/09 13:16:36 | 56 ms |
4/4
| ||||
| 303610 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225511 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/05/09 13:16:35 | 39 ms |
4/4
| ||||
| 303609 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225510 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/05/09 13:16:34 | 40 ms |
4/4
| ||||
| 303608 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225509 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/05/09 13:16:33 | 30 ms |
4/4
| ||||
| 303607 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225508 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/05/09 13:16:32 | 34 ms |
4/4
| ||||
| 303606 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225507 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/05/09 13:16:30 | 52 ms |
4/4
| ||||
| 303605 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225506 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/05/09 13:16:29 | 35 ms |
4/4
| ||||
| 303604 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225505 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/05/09 13:16:28 | 41 ms |
4/4
| ||||
| 303603 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225504 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/05/09 13:16:27 | 0.2 s |
4/4
| ||||
| 303602 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225503 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/05/09 13:16:26 | 75 ms |
4/4
| ||||
| 303601 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225502 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/05/09 13:16:25 | 63 ms |
4/4
| ||||
| 303600 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225501 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/05/09 13:16:24 | 0.1 s |
4/4
| ||||
| 303599 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225500 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/05/09 13:16:23 | 64 ms |
4/4
| ||||
| 303598 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225499 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/05/09 13:16:22 | 31 ms |
4/4
| ||||
| 303597 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225498 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/05/09 13:16:21 | 45 ms |
4/4
| ||||
| 303596 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225497 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/05/09 13:16:20 | 35 ms |
4/4
| ||||
| 303595 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225496 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/05/09 13:16:19 | 33 ms |
4/4
| ||||
| 303594 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225495 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/05/09 13:16:18 | 33 ms |
4/4
| ||||
| 303593 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225494 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/05/09 13:16:17 | 51 ms |
4/4
| ||||
| 303592 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225493 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/05/09 13:16:15 | 34 ms |
4/4
| ||||
| 303591 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225492 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/05/09 13:16:14 | 40 ms |
4/4
| ||||
| 303590 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225491 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/05/09 13:16:13 | 0.1 s |
4/4
| ||||
| 303589 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225490 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/05/09 13:16:12 | 26 ms |
4/4
| ||||
| 303588 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225489 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/05/09 13:16:11 | 34 ms |
4/4
| ||||
| 303587 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225488 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/05/09 13:16:10 | 36 ms |
4/4
| ||||
| 303586 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225487 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/05/09 13:16:09 | 39 ms |
4/4
| ||||
| 303585 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225486 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/05/09 13:16:08 | 38 ms |
4/4
| ||||
| 303584 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225485 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/05/09 13:16:07 | 51 ms |
4/4
| ||||
| 303583 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225484 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/05/09 13:16:06 | 44 ms |
4/4
| ||||
| 303582 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225483 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/05/09 13:16:05 | 35 ms |
4/4
| ||||
| 303581 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225482 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/05/09 13:16:04 | 49 ms |
4/4
| ||||
| 303580 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225481 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/05/09 13:16:03 | 32 ms |
4/4
| ||||
| 303579 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225480 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/05/09 13:16:02 | 37 ms |
4/4
| ||||
| 303578 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225479 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/05/09 13:16:01 | 62 ms |
4/4
| ||||
| 303577 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225478 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/05/09 13:16:00 | 33 ms |
4/4
| ||||
| 303576 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225477 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/05/09 13:15:59 | 58 ms |
4/4
| ||||
| 303575 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225476 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/05/09 13:15:58 | 0.1 s |
4/4
| ||||
| 303574 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225475 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/05/09 13:15:57 | 56 ms |
4/4
| ||||
| 303573 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225474 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/05/09 13:15:56 | 86 ms |
4/4
| ||||
| 303572 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225473 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/05/09 13:15:55 | 64 ms |
4/4
| ||||
| 303571 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225472 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/05/09 13:15:54 | 36 ms |
4/4
| ||||
| 303570 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225471 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/05/09 13:15:52 | 28 ms |
4/4
| ||||
| 303569 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225470 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/05/09 13:15:51 | 41 ms |
4/4
| ||||
| 303568 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225469 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/05/09 13:15:50 | 29 ms |
4/4
| ||||
| 303567 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225468 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/05/09 13:15:49 | 42 ms |
4/4
| ||||
| 303566 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225467 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/05/09 13:15:48 | 36 ms |
4/4
| ||||
| 303565 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225466 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/05/09 13:15:47 | 46 ms |
4/4
| ||||
| 303564 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225465 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/05/09 13:15:46 | 27 ms |
4/4
| ||||
| 303563 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225464 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/05/09 13:15:45 | 39 ms |
4/4
| ||||
| 303562 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225463 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/05/09 13:15:44 | 24 ms |
4/4
| ||||
| 303561 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225462 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/05/09 13:15:43 | 0.1 s |
4/4
| ||||
| 303560 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225461 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/05/09 13:15:42 | 0.1 s |
4/4
| ||||
| 303559 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225460 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/05/09 13:15:41 | 0.1 s |
4/4
| ||||
| 303558 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225459 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/05/09 13:15:40 | 35 ms |
4/4
| ||||
| 303557 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225458 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/05/09 13:15:39 | 43 ms |
4/4
| ||||
| 303556 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225457 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/05/09 13:15:38 | 41 ms |
4/4
| ||||
| 303555 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225456 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/05/09 13:15:37 | 58 ms |
4/4
| ||||
| 303554 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225455 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/05/09 13:15:36 | 58 ms |
4/4
| ||||
| 303553 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225454 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/05/09 13:15:35 | 45 ms |
4/4
| ||||
| 303552 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = fc20c589-97cd-4b3f-83d0-7fdad9df9e88
batch = 4225453 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/05/09 13:15:34 | 33 ms |
4/4
|