| Stage Id ▾ | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
|---|---|---|---|---|---|---|---|---|
| 635 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18866 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 13:44:35 | 0.5 s |
1/1
| ||||
| 634 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18866 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 13:44:35 | 0.5 s |
1/1
| ||||
| 633 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18865 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 12:15:14 | 0.5 s |
1/1
| ||||
| 632 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18865 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 12:15:14 | 0.5 s |
1/1
| ||||
| 631 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18864 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 12:08:54 | 0.5 s |
1/1
| ||||
| 630 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18864 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 12:08:54 | 0.5 s |
1/1
| ||||
| 629 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18863 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:57:31 | 0.5 s |
1/1
| ||||
| 628 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18863 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:57:31 | 0.5 s |
1/1
| ||||
| 627 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18862 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:57:02 | 0.5 s |
1/1
| ||||
| 626 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18862 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:57:02 | 0.5 s |
1/1
| ||||
| 625 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18861 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:56:51 | 0.5 s |
2/2
| ||||
| 624 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18861 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:56:51 | 0.5 s |
1/1
| ||||
| 623 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18860 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:56:42 | 0.5 s |
1/1
| ||||
| 622 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18860 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:56:42 | 0.5 s |
1/1
| ||||
| 621 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18859 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:56:39 | 0.5 s |
3/3
| ||||
| 620 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18859 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:56:39 | 0.5 s |
1/1
| ||||
| 619 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18858 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:56:38 | 0.5 s |
2/2
| ||||
| 618 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18858 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:56:38 | 0.2 s |
1/1
| ||||
| 617 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18857 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:55:43 | 0.5 s |
2/2
| ||||
| 616 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18857 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:55:43 | 0.5 s |
1/1
| ||||
| 615 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18856 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:55:27 | 0.5 s |
3/3
| ||||
| 614 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18856 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:55:27 | 0.5 s |
1/1
| ||||
| 613 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18855 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:55:00 | 0.5 s |
1/1
| ||||
| 612 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18855 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:55:00 | 0.5 s |
1/1
| ||||
| 611 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18854 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:54:31 | 0.5 s |
1/1
| ||||
| 610 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18854 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:54:31 | 0.5 s |
1/1
| ||||
| 609 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18853 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:54:14 | 0.5 s |
2/2
| ||||
| 608 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18853 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:54:14 | 0.5 s |
1/1
| ||||
| 607 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18852 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:52:05 | 0.5 s |
3/3
| ||||
| 606 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18852 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:52:05 | 0.5 s |
1/1
| ||||
| 605 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18851 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:51:42 | 0.5 s |
1/1
| ||||
| 604 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18851 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:51:42 | 0.5 s |
1/1
| ||||
| 603 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18850 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:51:41 | 0.5 s |
1/1
| ||||
| 602 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18850 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:51:41 | 65 ms |
1/1
| ||||
| 601 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18849 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:51:24 | 0.5 s |
1/1
| ||||
| 600 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18849 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:51:24 | 0.5 s |
1/1
| ||||
| 599 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18848 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:51:17 | 0.5 s |
1/1
| ||||
| 598 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18848 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:51:17 | 0.5 s |
1/1
| ||||
| 597 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18847 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:47:38 | 0.5 s |
1/1
| ||||
| 596 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18847 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:47:38 | 0.5 s |
1/1
| ||||
| 595 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18846 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:47:09 | 0.5 s |
1/1
| ||||
| 594 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18846 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:47:09 | 0.5 s |
1/1
| ||||
| 593 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18845 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:44:30 | 0.5 s |
1/1
| ||||
| 592 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18845 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:44:30 | 0.5 s |
1/1
| ||||
| 591 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18844 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:30:04 | 0.5 s |
1/1
| ||||
| 590 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18844 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/06 11:30:04 | 0.5 s |
1/1
| ||||
| 589 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18843 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/05 12:03:01 | 0.5 s |
1/1
| ||||
| 588 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18843 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/05 12:03:01 | 0.5 s |
1/1
| ||||
| 587 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18842 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/05 11:54:20 | 0.5 s |
1/1
| ||||
| 586 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18842 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/05 11:54:20 | 0.5 s |
1/1
| ||||
| 585 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18841 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/05 11:53:51 | 0.5 s |
1/1
| ||||
| 584 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18841 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/05 11:53:51 | 0.5 s |
1/1
| ||||
| 583 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18840 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:01:26 | 0.5 s |
1/1
| ||||
| 582 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18840 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:01:26 | 0.5 s |
1/1
| ||||
| 581 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18839 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:01:19 | 0.5 s |
1/1
| ||||
| 580 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18839 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:01:19 | 0.5 s |
1/1
| ||||
| 579 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18838 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:01:16 | 0.5 s |
1/1
| ||||
| 578 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18838 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:01:16 | 0.5 s |
1/1
| ||||
| 577 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18837 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:47 | 0.5 s |
1/1
| ||||
| 576 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18837 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:47 | 0.5 s |
1/1
| ||||
| 575 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18836 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:39 | 0.5 s |
1/1
| ||||
| 574 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18836 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:39 | 0.5 s |
1/1
| ||||
| 573 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18835 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:23 | 0.5 s |
1/1
| ||||
| 572 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18835 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:23 | 0.5 s |
1/1
| ||||
| 571 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18834 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:18 | 0.5 s |
1/1
| ||||
| 570 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18834 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:18 | 0.5 s |
1/1
| ||||
| 569 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18833 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:14 | 0.5 s |
1/1
| ||||
| 568 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18833 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:14 | 0.5 s |
1/1
| ||||
| 567 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18832 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:04 | 0.5 s |
1/1
| ||||
| 566 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18832 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 15:00:04 | 0.5 s |
1/1
| ||||
| 565 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18831 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 14:59:57 | 0.5 s |
1/1
| ||||
| 564 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18831 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 14:59:57 | 0.5 s |
1/1
| ||||
| 563 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18830 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 14:59:32 | 0.5 s |
1/1
| ||||
| 562 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18830 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 14:59:32 | 0.5 s |
1/1
| ||||
| 561 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18829 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 14:58:30 | 0.5 s |
1/1
| ||||
| 560 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18829 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 14:58:30 | 0.5 s |
1/1
| ||||
| 559 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18828 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 14:57:55 | 0.5 s |
1/1
| ||||
| 558 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18828 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 14:57:55 | 0.5 s |
1/1
| ||||
| 557 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18827 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 12:21:16 | 0.5 s |
1/1
| ||||
| 556 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18827 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 12:21:16 | 8 ms |
1/1
| ||||
| 555 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18826 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 12:21:15 | 0.5 s |
4/4
| ||||
| 554 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18826 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 12:21:15 | 0.5 s |
1/1
| ||||
| 553 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18825 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 12:21:09 | 0.5 s |
4/4
| ||||
| 552 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18825 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 12:21:09 | 0.5 s |
1/1
| ||||
| 551 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18824 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 12:20:27 | 0.5 s |
1/1
| ||||
| 550 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18824 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 12:20:27 | 0.5 s |
1/1
| ||||
| 549 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18823 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 12:19:45 | 0.5 s |
1/1
| ||||
| 548 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18823 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 12:19:45 | 0.5 s |
1/1
| ||||
| 547 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18822 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 11:37:26 | 0.5 s |
1/1
| ||||
| 546 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18822 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/04 11:37:26 | 0.5 s |
1/1
| ||||
| 545 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18821 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/03 17:32:16 | 0.5 s |
1/1
| ||||
| 544 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18821 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/03 17:32:16 | 0.5 s |
1/1
| ||||
| 543 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18820 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/03 12:18:19 | 0.5 s |
1/1
| ||||
| 542 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18820 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/03 12:18:19 | 0.5 s |
1/1
| ||||
| 541 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18819 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/03 12:10:51 | 0.5 s |
1/1
| ||||
| 540 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18819 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/03 12:10:51 | 0.5 s |
1/1
| ||||
| 539 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18818 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/03 10:41:19 | 0.5 s |
1/1
| ||||
| 538 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18818 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/03 10:41:19 | 0.5 s |
1/1
| ||||
| 537 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18817 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/02 20:37:48 | 0.5 s |
1/1
| ||||
| 536 |
id = 965e93fe-c8c5-4c91-bf03-7431991952a7
runId = 4862a00a-a55a-46e3-adea-84d336a00138
batch = 18817 start at KafkaDataFrameDataSource.scala:46 org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251) data.kafka.KafkaDataFrameDataSource.monitor(KafkaDataFrameDataSource.scala:46) data.kafka.KafkaDataFrameDataSource.start(KafkaDataFrameDataSource.scala:23) Main$.$anonfun$main$2(Main.scala:28) Main$.$anonfun$main$2$adapted(Main.scala:28) scala.collection.immutable.Set$Set1.foreach(Set.scala:141) Main$.main(Main.scala:28) Main.main(Main.scala) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52) org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029) org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194) org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217) org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91) org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120) org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129) org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) | 2026/02/02 20:37:48 | 0.5 s |
1/1
|