Spark Jobs (?)

  • User: spark
  • Total Uptime: 4.8 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 582
Event Timeline

Completed Jobs (582)

Page:
Job Id (Job Group) Description ▾ Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
141 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 99 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:09:32 5 s 1/1
3/3
139 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 98 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:08:32 5 s 1/1
3/3
137 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 97 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:07:32 5 s 1/1
3/3
134 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 96 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:06:32 2 s 1/1
3/3
132 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 95 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:05:32 2 s 1/1
3/3
130 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 94 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:04:31 2 s 1/1
3/3
128 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 93 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:03:32 2 s 1/1
3/3
127 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 92 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:02:32 6 s 1/1
3/3
125 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 91 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:01:32 5 s 1/1
3/3
122 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 90 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:00:32 2 s 1/1
3/3
120 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 89 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:59:32 2 s 1/1
3/3
118 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 88 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:58:31 2 s 1/1
3/3
117 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 87 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:57:31 5 s 1/1
3/3
114 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 86 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:56:32 2 s 1/1
3/3
113 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 85 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:55:32 6 s 1/1
3/3
110 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 84 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:54:32 2 s 1/1
3/3
108 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 83 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:53:31 2 s 1/1
3/3
107 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 82 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:52:32 6 s 1/1
3/3
105 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 81 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:51:32 6 s 1/1
3/3
103 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 80 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:50:32 5 s 1/1
3/3
101 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 79 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:49:32 5 s 1/1
3/3
99 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 78 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:48:32 5 s 1/1
3/3
96 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 77 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:47:32 2 s 1/1
4/4
94 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 76 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:46:32 2 s 1/1
3/3
93 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 75 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:45:32 6 s 1/1
3/3
90 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 74 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:44:32 2 s 1/1
4/4
88 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 73 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:43:32 2 s 1/1
3/3
87 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 72 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:42:32 5 s 1/1
3/3
84 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 71 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:41:32 2 s 1/1
3/3
83 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 70 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:40:32 5 s 1/1
3/3
80 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 69 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:39:32 2 s 1/1
4/4
79 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 68 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:38:32 5 s 1/1
3/3
77 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 67 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:37:32 8 s 1/1
4/4
74 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 66 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:36:32 2 s 1/1
3/3
72 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 65 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:35:32 2 s 1/1
3/3
71 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 64 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:34:32 6 s 1/1
3/3
69 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 63 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:33:32 7 s 1/1
4/4
66 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 62 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:32:32 2 s 1/1
3/3
65 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 61 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:31:33 5 s 1/1
3/3
63 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 60 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:30:32 6 s 1/1
3/3
61 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 59 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:29:32 6 s 1/1
3/3
59 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 58 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:28:32 5 s 1/1
3/3
57 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 57 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:27:32 7 s 1/1
4/4
55 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 56 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:26:32 5 s 1/1
3/3
52 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 55 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:25:32 2 s 1/1
4/4
51 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 54 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:24:32 5 s 1/1
3/3
49 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 53 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:23:33 5 s 1/1
3/3
47 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 52 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:22:32 5 s 1/1
3/3
45 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 51 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:21:32 5 s 1/1
3/3
43 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 50 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:20:32 5 s 1/1
3/3
41 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 49 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:19:32 6 s 1/1
3/3
39 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 48 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:18:32 5 s 1/1
3/3
37 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 47 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:17:32 7 s 1/1
4/4
35 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 46 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:16:32 6 s 1/1
3/3
32 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 45 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:15:32 3 s 1/1
3/3
31 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 44 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:14:32 5 s 1/1
3/3
28 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 43 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:13:31 2 s 1/1
3/3
27 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 42 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:12:32 5 s 1/1
3/3
25 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 41 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:11:33 8 s 1/1
4/4
23 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 40 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:10:33 5 s 1/1
3/3
20 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 39 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:09:32 2 s 1/1
3/3
19 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 38 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:08:32 5 s 1/1
3/3
17 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 37 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:07:32 6 s 1/1
3/3
15 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 36 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:06:32 6 s 1/1
3/3
13 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 35 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:05:33 6 s 1/1
3/3
11 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 34 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:04:33 5 s 1/1
3/3
9 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 33 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:03:33 6 s 1/1
3/3
7 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 32 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:02:33 7 s 1/1
3/3
580 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 319 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:49:32 2 s 1/1
3/3
578 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 318 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:48:32 2 s 1/1
4/4
576 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 317 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:47:32 2 s 1/1
3/3
574 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 316 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:46:32 2 s 1/1
3/3
572 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 315 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:45:32 2 s 1/1
3/3
571 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 314 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:44:32 5 s 1/1
3/3
569 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 313 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:43:32 5 s 1/1
3/3
566 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 312 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:42:32 2 s 1/1
4/4
565 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 311 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:41:32 5 s 1/1
3/3
563 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 310 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:40:32 4 s 1/1
3/3
4 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 31 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:02:08 2 s 1/1
3/3
560 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 309 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:39:32 2 s 1/1
3/3
559 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 308 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:38:32 5 s 1/1
3/3
556 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 307 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:37:32 2 s 1/1
3/3
554 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 306 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:36:32 2 s 1/1
3/3
553 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 305 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:35:32 6 s 1/1
3/3
550 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 304 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:34:32 2 s 1/1
3/3
548 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 303 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:33:32 2 s 1/1
3/3
547 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 302 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:32:32 5 s 1/1
3/3
544 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 301 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:31:31 2 s 1/1
3/3
543 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 300 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:30:32 4 s 1/1
3/3
3 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 30 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:02:01 2 s 1/1
3/3
541 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 299 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:29:32 5 s 1/1
3/3
538 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 298 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:28:32 2 s 1/1
3/3
536 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 297 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:27:32 2 s 1/1
3/3
535 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 296 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:26:32 5 s 1/1
3/3
532 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 295 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:25:32 2 s 1/1
3/3
530 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 294 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:24:32 2 s 1/1
3/3
529 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 293 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:23:32 5 s 1/1
3/3
527 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 292 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:22:32 6 s 1/1
3/3
524 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 291 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:21:32 2 s 1/1
3/3
523 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 290 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:20:32 6 s 1/1
3/3
Page: