Spark Jobs (?)

  • User: spark
  • Total Uptime: 95.8 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 1172, only showing 972
Event Timeline

Completed Jobs (1172, only showing 972)

Job Id (Job Group) Description Submitted Duration ▾ Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
1170 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1925 start at KafkaDataFrameDataSource.scala:46 2026/07/02 10:00:23 0.6 s 1/1
1/1
975 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1827 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:38:01 0.5 s 1/1
1/1
1169 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1924 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:39:38 0.5 s 1/1
1/1
313 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1496 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:07:35 0.5 s 1/1
3/3
909 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1794 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:28 0.5 s 1/1
1/1
445 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1562 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:12 0.5 s 1/1
1/1
1119 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1899 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:39:13 0.5 s 1/1
1/1
443 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1561 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:11 0.5 s 1/1
1/1
227 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1453 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:29 0.5 s 1/1
1/1
451 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1565 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:15 0.5 s 1/1
1/1
319 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1499 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:07:38 0.5 s 1/1
2/2
439 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1559 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:09 0.5 s 1/1
1/1
1171 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1925 start at KafkaDataFrameDataSource.scala:46 2026/07/02 10:00:23 0.5 s 1/1
2/2
1007 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1843 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:38:17 0.5 s 1/1
1/1
318 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1499 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:07:38 0.5 s 1/1
1/1
447 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1563 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:13 0.5 s 1/1
1/1
311 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1495 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:48:11 0.5 s 1/1
1/1
217 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1448 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:24 0.5 s 1/1
1/1
907 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1793 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:27 0.5 s 1/1
1/1
839 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1759 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:36:29 0.5 s 1/1
1/1
891 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1785 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:19 0.5 s 1/1
1/1
838 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1759 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:36:29 0.5 s 1/1
1/1
257 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1468 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:44 0.5 s 1/1
1/1
435 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1557 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:07 0.5 s 1/1
1/1
423 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1551 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:01 0.5 s 1/1
1/1
895 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1787 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:21 0.5 s 1/1
1/1
429 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1554 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:04 0.5 s 1/1
1/1
261 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1470 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:46 0.5 s 1/1
1/1
221 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1450 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:26 0.5 s 1/1
1/1
871 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1775 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:09 0.5 s 1/1
1/1
431 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1555 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:05 0.5 s 1/1
1/1
427 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1553 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:03 0.5 s 1/1
1/1
239 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1459 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:35 0.5 s 1/1
1/1
893 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1786 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:20 0.5 s 1/1
1/1
889 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1784 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:18 0.5 s 1/1
1/1
433 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1556 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:06 0.5 s 1/1
1/1
211 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1445 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:21 0.5 s 1/1
1/1
885 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1782 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:16 0.5 s 1/1
1/1
421 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1550 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:00 0.5 s 1/1
1/1
215 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1447 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:23 0.5 s 1/1
1/1
887 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1783 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:17 0.5 s 1/1
1/1
879 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1779 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:13 0.5 s 1/1
1/1
875 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1777 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:11 0.5 s 1/1
1/1
415 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1547 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:57 0.5 s 1/1
1/1
413 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1546 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:56 0.5 s 1/1
1/1
209 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1444 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:20 0.5 s 1/1
1/1
425 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1552 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:33:02 0.5 s 1/1
1/1
417 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1548 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:58 0.5 s 1/1
1/1
229 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1454 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:30 0.5 s 1/1
1/1
219 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1449 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:25 0.5 s 1/1
1/1
1009 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1844 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:38:18 0.5 s 1/1
1/1
867 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1773 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:07 0.5 s 1/1
1/1
205 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1442 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:18 0.5 s 1/1
1/1
873 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1776 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:10 0.5 s 1/1
1/1
841 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1760 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:36:54 0.5 s 1/1
1/1
981 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1830 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:38:04 0.5 s 1/1
1/1
977 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1828 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:38:02 0.5 s 1/1
1/1
409 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1544 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:54 0.5 s 1/1
1/1
905 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1792 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:26 0.5 s 1/1
1/1
321 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1500 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:10 0.5 s 1/1
1/1
317 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1498 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:07:37 0.5 s 1/1
2/2
883 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1781 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:15 0.5 s 1/1
1/1
405 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1542 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:52 0.5 s 1/1
1/1
1121 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1900 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:39:14 0.5 s 1/1
1/1
419 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1549 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:59 0.5 s 1/1
1/1
407 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1543 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:53 0.5 s 1/1
1/1
403 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1541 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:51 0.5 s 1/1
1/1
877 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1778 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:12 0.5 s 1/1
1/1
411 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1545 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:55 0.5 s 1/1
1/1
395 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1537 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:47 0.5 s 1/1
1/1
207 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1443 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:19 0.5 s 1/1
1/1
840 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1760 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:36:54 0.5 s 1/1
1/1
397 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1538 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:48 0.5 s 1/1
1/1
213 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1446 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:22 0.5 s 1/1
1/1
869 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1774 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:08 0.5 s 1/1
1/1
865 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1772 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:06 0.5 s 1/1
1/1
401 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1540 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:50 0.5 s 1/1
1/1
399 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1539 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:49 0.5 s 1/1
1/1
393 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1536 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:46 0.5 s 1/1
1/1
201 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1440 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:16 0.5 s 1/1
1/1
857 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1768 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:02 0.5 s 1/1
1/1
387 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1533 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:43 0.5 s 1/1
1/1
863 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1771 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:05 0.5 s 1/1
1/1
859 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1769 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:03 0.5 s 1/1
1/1
389 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1534 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:44 0.5 s 1/1
1/1
312 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1496 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:07:35 0.5 s 1/1
1/1
851 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1765 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:36:59 0.5 s 1/1
1/1
881 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1780 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:14 0.5 s 1/1
1/1
861 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1770 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:04 0.5 s 1/1
1/1
853 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1766 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:00 0.5 s 1/1
1/1
385 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1532 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:42 0.5 s 1/1
1/1
381 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1530 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:40 0.5 s 1/1
1/1
379 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1529 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:39 0.5 s 1/1
1/1
203 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1441 start at KafkaDataFrameDataSource.scala:46 2026/06/30 15:47:17 0.5 s 1/1
1/1
391 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1535 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:45 0.5 s 1/1
1/1
373 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1526 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:36 0.5 s 1/1
1/1
383 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1531 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:41 0.5 s 1/1
1/1
371 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1525 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:35 0.5 s 1/1
1/1
897 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1788 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:37:22 0.5 s 1/1
1/1
377 (e9e78797-ba70-41c2-b77c-aa61944c2294) id = ad147f87-0482-487b-9087-002036153ffd runId = e9e78797-ba70-41c2-b77c-aa61944c2294 batch = 1528 start at KafkaDataFrameDataSource.scala:46 2026/06/30 16:32:38 0.5 s 1/1
1/1