SparkEngine - SQL / DataFrame

Completed Queries: 377

Completed Queries (377)

Page:

ID	Description ▴	Submitted	Duration	Job IDs
1	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:28	0.3 s	[3][4]
9	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:00	0.1 s	[17][18]
13	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:01	0.3 s	[24][25]
14	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:01	0.1 s	[27][29]
28	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:05:38	0.1 s	[52][53]
36	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 14:45:32	71 ms	[67][68]
44	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:00:00	76 ms	[81][82]
47	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:00:01	85 ms	[87][89]
50	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:00:01	0.1 s	[92][94]
63	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:05:38	77 ms	[116][117]
71	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 14:45:32	69 ms	[131][132]
79	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:00:00	73 ms	[145][146]
82	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:00:00	86 ms	[151][152]
88	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:00:01	0.1 s	[157][158]
98	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:05:38	0.1 s	[183][184]
106	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 14:45:32	70 ms	[198][199]
114	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:00:00	0.1 s	[212][213]
117	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:00:00	91 ms	[218][219]
123	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:00:01	68 ms	[224][225]
133	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:05:38	71 ms	[250][251]
141	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 14:45:32	60 ms	[265][266]
149	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:00:00	89 ms	[279][280]
152	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:00:00	73 ms	[285][286]
157	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:00:01	91 ms	[291][292]
168	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:05:38	62 ms	[317][318]
176	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 14:45:32	51 ms	[332][333]
184	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:00:00	87 ms	[346][347]
187	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:00:00	65 ms	[352][353]
193	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:00:01	58 ms	[358][359]
203	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:05:38	83 ms	[384][385]
211	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 14:45:32	94 ms	[399][400]
219	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:00:00	76 ms	[413][414]
222	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:00:00	57 ms	[419][420]
229	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:00:01	83 ms	[427][429]
238	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:05:38	65 ms	[451][452]
246	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 14:45:32	75 ms	[466][467]
254	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:00:00	88 ms	[480][481]
257	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:00:00	58 ms	[486][487]
263	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:00:01	69 ms	[492][493]
273	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:05:38	74 ms	[518][519]
281	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 14:45:32	65 ms	[533][534]
289	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:00:00	95 ms	[547][548]
292	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:00:01	79 ms	[553][554]
296	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:00:01	98 ms	[559][560]
308	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:05:38	74 ms	[585][586]
316	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 14:45:32	77 ms	[600][601]
324	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:00:00	68 ms	[614][615]
327	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:00:00	61 ms	[620][621]
333	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:00:01	92 ms	[626][627]
343	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:05:38	84 ms	[652][653]
351	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 14:45:32	57 ms	[667][668]
359	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/14 00:00:00	83 ms	[681][682]
362	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/14 00:00:00	57 ms	[687][688]
368	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/14 00:00:01	56 ms	[693][694]
6	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:33	0.2 s	[11][12]
23	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:04	0.2 s	[36][37]
25	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:05	0.4 s	[41][42][43][44]
33	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:05:39	0.2 s	[60][61]
41	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 14:45:33	73 ms	[75][76]
58	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:00:02	0.1 s	[101][102]
59	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:00:02	0.2 s	[103][104][106][108]
68	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:05:39	83 ms	[124][125]
76	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 14:45:33	0.1 s	[139][140]
93	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:00:03	0.2 s	[168][170]
94	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:00:03	0.4 s	[166][167][169][172][174]
103	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:05:39	0.1 s	[191][192]
111	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 14:45:33	0.1 s	[206][207]
128	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:00:02	0.2 s	[233][234][236][238][240]
129	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:00:02	86 ms	[235][237]
138	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:05:39	77 ms	[258][259]
146	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 14:45:33	79 ms	[273][274]
163	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:00:02	0.2 s	[301][302][304][306][307]
164	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:00:02	0.1 s	[300][303]
173	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:05:38	0.1 s	[325][326]
181	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 14:45:32	56 ms	[340][341]
198	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:00:02	72 ms	[367][368]
200	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:00:02	0.2 s	[370][371][373][374][375]
208	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:05:39	69 ms	[392][393]
216	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 14:45:33	95 ms	[407][408]
233	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:00:01	0.2 s	[433][434][435][437][438]
235	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:00:02	60 ms	[443][445]
243	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:05:38	89 ms	[459][460]
251	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 14:45:33	0.1 s	[474][475]
268	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:00:02	0.2 s	[501][502][504][505][507]
269	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:00:02	78 ms	[503][506]
278	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:05:38	82 ms	[526][527]
286	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 14:45:32	73 ms	[541][542]
303	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:00:02	53 ms	[568][569]
304	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:00:02	0.2 s	[570][571][573][575][576]
313	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:05:39	0.1 s	[593][594]
321	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 14:45:33	60 ms	[608][609]
338	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:00:02	0.1 s	[637][638]
339	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:00:02	0.2 s	[635][636][639][640][642]
348	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:05:39	63 ms	[660][661]
356	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 14:45:33	65 ms	[675][676]
373	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/14 00:00:02	0.3 s	[701][702][704][705][706]
374	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/14 00:00:02	88 ms	[707][710]
2	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:28	0.3 s	[5][6]
7	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:33	0.2 s	[13][14]
10	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:00	0.1 s	[19][20]

Page: