| 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 |
|---|---|---|---|---|---|---|---|---|---|
| 375721 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773422 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/06/24 07:13:11 | 40 ms |
4/4
| ||||
| 375720 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773421 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/06/24 07:13:10 | 36 ms |
4/4
| ||||
| 375719 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773420 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/06/24 07:13:09 | 36 ms |
4/4
| ||||
| 375718 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773419 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/06/24 07:13:08 | 41 ms |
4/4
| ||||
| 375717 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773418 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/06/24 07:13:07 | 42 ms |
4/4
| ||||
| 375716 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773417 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/06/24 07:13:06 | 35 ms |
4/4
| ||||
| 375715 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773416 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/06/24 07:13:05 | 33 ms |
4/4
| ||||
| 375714 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773415 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/06/24 07:13:04 | 36 ms |
4/4
| ||||
| 375713 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773414 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/06/24 07:13:03 | 36 ms |
4/4
| ||||
| 375712 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773413 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/06/24 07:13:02 | 35 ms |
4/4
| ||||
| 375711 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773412 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/06/24 07:13:01 | 36 ms |
4/4
| ||||
| 375710 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773411 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/06/24 07:13:00 | 42 ms |
4/4
| ||||
| 375709 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773410 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/06/24 07:12:59 | 41 ms |
4/4
| ||||
| 375708 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773409 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/06/24 07:12:58 | 40 ms |
4/4
| ||||
| 375707 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773408 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/06/24 07:12:57 | 41 ms |
4/4
| ||||
| 375706 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773407 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/06/24 07:12:56 | 38 ms |
4/4
| ||||
| 375705 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773406 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/06/24 07:12:55 | 36 ms |
4/4
| ||||
| 375704 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773405 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/06/24 07:12:54 | 29 ms |
4/4
| ||||
| 375703 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773404 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/06/24 07:12:53 | 34 ms |
4/4
| ||||
| 375702 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773403 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/06/24 07:12:52 | 39 ms |
4/4
| ||||
| 375701 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773402 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/06/24 07:12:51 | 36 ms |
4/4
| ||||
| 375700 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773401 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/06/24 07:12:50 | 41 ms |
4/4
| ||||
| 375699 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773400 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/06/24 07:12:49 | 33 ms |
4/4
| ||||
| 375698 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773399 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/06/24 07:12:48 | 36 ms |
4/4
| ||||
| 375697 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773398 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/06/24 07:12:47 | 34 ms |
4/4
| ||||
| 375696 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773397 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/06/24 07:12:46 | 44 ms |
4/4
| ||||
| 375695 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773396 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/06/24 07:12:45 | 30 ms |
4/4
| ||||
| 375694 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773395 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/06/24 07:12:44 | 38 ms |
4/4
| ||||
| 375693 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773394 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/06/24 07:12:43 | 57 ms |
4/4
| ||||
| 375692 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773393 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/06/24 07:12:42 | 26 ms |
4/4
| ||||
| 375691 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773392 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/06/24 07:12:41 | 34 ms |
4/4
| ||||
| 375690 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773391 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/06/24 07:12:40 | 38 ms |
4/4
| ||||
| 375689 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773390 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/06/24 07:12:39 | 35 ms |
4/4
| ||||
| 375688 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773389 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/06/24 07:12:38 | 42 ms |
4/4
| ||||
| 375687 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773388 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/06/24 07:12:37 | 39 ms |
4/4
| ||||
| 375686 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773387 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/06/24 07:12:36 | 38 ms |
4/4
| ||||
| 375685 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773386 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/06/24 07:12:35 | 33 ms |
4/4
| ||||
| 375684 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773385 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/06/24 07:12:34 | 31 ms |
4/4
| ||||
| 375683 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773384 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/06/24 07:12:33 | 35 ms |
4/4
| ||||
| 375682 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773383 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/06/24 07:12:32 | 34 ms |
4/4
| ||||
| 375681 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773382 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/06/24 07:12:31 | 57 ms |
4/4
| ||||
| 375680 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773381 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/06/24 07:12:30 | 36 ms |
4/4
| ||||
| 375679 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773380 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/06/24 07:12:29 | 42 ms |
4/4
| ||||
| 375678 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773379 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/06/24 07:12:28 | 40 ms |
4/4
| ||||
| 375677 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773378 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/06/24 07:12:27 | 49 ms |
4/4
| ||||
| 375676 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773377 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/06/24 07:12:26 | 50 ms |
4/4
| ||||
| 375675 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773376 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/06/24 07:12:25 | 39 ms |
4/4
| ||||
| 375674 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773375 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/06/24 07:12:24 | 36 ms |
4/4
| ||||
| 375673 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773374 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/06/24 07:12:23 | 33 ms |
4/4
| ||||
| 375672 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773373 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/06/24 07:12:22 | 37 ms |
4/4
| ||||
| 375671 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773372 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/06/24 07:12:21 | 37 ms |
4/4
| ||||
| 375670 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773371 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/06/24 07:12:20 | 35 ms |
4/4
| ||||
| 375669 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773370 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/06/24 07:12:19 | 32 ms |
4/4
| ||||
| 375668 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773369 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/06/24 07:12:18 | 36 ms |
4/4
| ||||
| 375667 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773368 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/06/24 07:12:17 | 40 ms |
4/4
| ||||
| 375666 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773367 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/06/24 07:12:16 | 32 ms |
4/4
| ||||
| 375665 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773366 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/06/24 07:12:15 | 34 ms |
4/4
| ||||
| 375664 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773365 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/06/24 07:12:14 | 34 ms |
4/4
| ||||
| 375663 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773364 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/06/24 07:12:13 | 33 ms |
4/4
| ||||
| 375662 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773363 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/06/24 07:12:12 | 31 ms |
4/4
| ||||
| 375661 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773362 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/06/24 07:12:11 | 41 ms |
4/4
| ||||
| 375660 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773361 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/06/24 07:12:10 | 35 ms |
4/4
| ||||
| 375659 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773360 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/06/24 07:12:09 | 34 ms |
4/4
| ||||
| 375658 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773359 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/06/24 07:12:08 | 34 ms |
4/4
| ||||
| 375657 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773358 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/06/24 07:12:07 | 42 ms |
4/4
| ||||
| 375656 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773357 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/06/24 07:12:06 | 32 ms |
4/4
| ||||
| 375655 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773356 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/06/24 07:12:05 | 35 ms |
4/4
| ||||
| 375654 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773355 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/06/24 07:12:04 | 40 ms |
4/4
| ||||
| 375653 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773354 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/06/24 07:12:03 | 36 ms |
4/4
| ||||
| 375652 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773353 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/06/24 07:12:02 | 33 ms |
4/4
| ||||
| 375651 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773352 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/06/24 07:12:01 | 35 ms |
4/4
| ||||
| 375650 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773351 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/06/24 07:12:00 | 34 ms |
4/4
| ||||
| 375649 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773350 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/06/24 07:11:59 | 38 ms |
4/4
| ||||
| 375648 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773349 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/06/24 07:11:58 | 49 ms |
4/4
| ||||
| 375647 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773348 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/06/24 07:11:57 | 44 ms |
4/4
| ||||
| 375646 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773347 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/06/24 07:11:56 | 39 ms |
4/4
| ||||
| 375645 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773346 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/06/24 07:11:55 | 37 ms |
4/4
| ||||
| 375644 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773345 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/06/24 07:11:54 | 33 ms |
4/4
| ||||
| 375643 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773344 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/06/24 07:11:53 | 33 ms |
4/4
| ||||
| 375642 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773343 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/06/24 07:11:52 | 32 ms |
4/4
| ||||
| 375641 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773342 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/06/24 07:11:51 | 40 ms |
4/4
| ||||
| 375640 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773341 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/06/24 07:11:50 | 34 ms |
4/4
| ||||
| 375639 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773340 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/06/24 07:11:49 | 35 ms |
4/4
| ||||
| 375638 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773339 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/06/24 07:11:48 | 35 ms |
4/4
| ||||
| 375637 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773338 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/06/24 07:11:47 | 33 ms |
4/4
| ||||
| 375636 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773337 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/06/24 07:11:46 | 34 ms |
4/4
| ||||
| 375635 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773336 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/06/24 07:11:45 | 30 ms |
4/4
| ||||
| 375634 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773335 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/06/24 07:11:44 | 32 ms |
4/4
| ||||
| 375633 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773334 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/06/24 07:11:43 | 32 ms |
4/4
| ||||
| 375632 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773333 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/06/24 07:11:42 | 33 ms |
4/4
| ||||
| 375631 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773332 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/06/24 07:11:41 | 28 ms |
4/4
| ||||
| 375630 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773331 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/06/24 07:11:40 | 60 ms |
4/4
| ||||
| 375629 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773330 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/06/24 07:11:39 | 35 ms |
4/4
| ||||
| 375628 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773329 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/06/24 07:11:38 | 35 ms |
4/4
| ||||
| 375627 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773328 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/06/24 07:11:37 | 41 ms |
4/4
| ||||
| 375626 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773327 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/06/24 07:11:36 | 36 ms |
4/4
| ||||
| 375625 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773326 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/06/24 07:11:35 | 34 ms |
4/4
| ||||
| 375624 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773325 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/06/24 07:11:34 | 39 ms |
4/4
| ||||
| 375623 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773324 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/06/24 07:11:33 | 35 ms |
4/4
| ||||
| 375622 | default | TrendJob___TrendJob
id = 22794db6-9919-4fc3-b9c7-f67a0e1efa44
runId = 09d1ac67-4ba7-4680-94bb-fd28c47e3a5e
batch = 5773323 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/06/24 07:11:32 | 45 ms |
4/4
|