2026-01-27T06:50:57.866Z [DEBUG] [Query.streamInput] Starting to process input stream 2026-01-27T06:50:57.900Z [DEBUG] [Query.streamInput] Processing message 1: user 2026-01-27T06:51:55.064Z [DEBUG] [Query.streamInput] Processing message 2: user 2026-01-27T10:15:51.661Z [DEBUG] [Query.streamInput] Processing message 3: user 2026-01-27T10:17:45.610Z [DEBUG] [Query.streamInput] Processing message 4: user 2026-01-27T19:35:03.694Z [DEBUG] [Query.streamInput] Starting to process input stream 2026-01-27T19:35:03.721Z [DEBUG] [Query.streamInput] Processing message 1: user 2026-01-27T19:44:11.752Z [DEBUG] [Query.streamInput] Processing message 2: user 2026-01-27T19:48:45.768Z [DEBUG] [Query.streamInput] Processing message 3: user 2026-01-27T19:52:55.103Z [DEBUG] [Query.streamInput] Processing message 4: user 2026-01-27T20:00:16.275Z [DEBUG] [Query.streamInput] Processing message 5: user 2026-01-27T20:02:21.207Z [DEBUG] [Query.streamInput] Processing message 6: user 2026-01-27T20:17:19.478Z [DEBUG] [Query.streamInput] Processing message 7: user 2026-01-28T07:56:01.983Z [DEBUG] [Query.streamInput] Processing message 8: user 2026-01-28T07:56:47.341Z [DEBUG] [Query.streamInput] Processing message 9: user 2026-01-28T09:33:12.921Z [DEBUG] [Query.streamInput] Processing message 10: user 2026-01-28T09:45:43.730Z [DEBUG] [Query.streamInput] Processing message 11: user 2026-01-28T09:48:24.891Z [DEBUG] [Query.streamInput] Processing message 12: user 2026-01-28T09:51:15.293Z [DEBUG] [Query.streamInput] Processing message 13: user 2026-01-28T09:51:42.759Z [DEBUG] [Query.streamInput] Processing message 14: user 2026-01-28T09:53:38.516Z [DEBUG] [Query.streamInput] Processing message 15: user 2026-01-28T09:54:57.474Z [DEBUG] [Query.streamInput] Processing message 16: user 2026-01-28T09:55:32.087Z [DEBUG] [Query.streamInput] Processing message 17: user 2026-01-28T10:00:44.734Z [DEBUG] [Query.streamInput] Processing message 18: user 2026-01-28T18:03:42.332Z [DEBUG] [Query.streamInput] Processing message 19: user 2026-01-28T18:09:23.097Z [DEBUG] [Query.streamInput] Processing message 20: user 2026-01-28T18:22:39.246Z [DEBUG] [Query.streamInput] Processing message 21: user 2026-01-28T18:26:02.915Z [DEBUG] [Query.streamInput] Processing message 22: user 2026-01-28T18:31:43.685Z [DEBUG] [Query.streamInput] Processing message 23: user 2026-01-28T18:53:12.828Z [DEBUG] [Query.streamInput] Processing message 24: user 2026-01-28T18:59:25.532Z [DEBUG] [Query.streamInput] Processing message 25: user 2026-01-28T19:01:45.616Z [DEBUG] [Query.streamInput] Processing message 26: user 2026-01-28T19:01:45.617Z [DEBUG] [Query.streamInput] Processing message 27: user 2026-01-28T19:03:02.352Z [DEBUG] [Query.streamInput] Processing message 28: user 2026-01-28T19:03:09.313Z [DEBUG] [Query.streamInput] Processing message 29: user 2026-01-28T19:11:03.911Z [DEBUG] [Query.streamInput] Processing message 30: user 2026-01-28T19:13:19.722Z [DEBUG] [Query.streamInput] Processing message 31: user 2026-01-28T19:20:03.409Z [DEBUG] [Query.streamInput] Processing message 32: user 2026-01-28T19:22:29.622Z [DEBUG] [Query.streamInput] Processing message 33: user 2026-01-28T19:23:35.306Z [DEBUG] [Query.streamInput] Processing message 34: user 2026-01-28T19:59:41.691Z [DEBUG] [Query.streamInput] Processing message 35: user 2026-01-28T20:01:26.394Z [DEBUG] [Query.streamInput] Processing message 36: user 2026-01-28T20:14:26.287Z [DEBUG] [Query.streamInput] Processing message 37: user 2026-01-28T20:30:45.455Z [DEBUG] [Query.streamInput] Processing message 38: user 2026-01-28T20:42:05.714Z [DEBUG] [Query.streamInput] Processing message 39: user 2026-01-28T20:42:40.134Z [DEBUG] [Query.streamInput] Processing message 40: user 2026-01-28T23:52:26.621Z [DEBUG] [Query.streamInput] Processing message 41: user 2026-01-28T23:58:21.209Z [DEBUG] [Query.streamInput] Processing message 42: user 2026-01-29T00:02:41.936Z [DEBUG] [Query.streamInput] Processing message 43: user 2026-01-29T00:03:00.005Z [DEBUG] [Query.streamInput] Processing message 44: user 2026-01-29T00:05:21.515Z [DEBUG] [Query.streamInput] Processing message 45: user 2026-01-29T00:12:09.642Z [DEBUG] [Query.streamInput] Processing message 46: user 2026-01-29T00:14:25.971Z [DEBUG] [Query.streamInput] Processing message 47: user 2026-01-29T02:25:35.856Z [DEBUG] [Query.streamInput] Processing message 48: user 2026-01-29T02:26:43.076Z [DEBUG] [Query.streamInput] Processing message 49: user 2026-01-29T02:27:41.244Z [DEBUG] [Query.streamInput] Processing message 50: user 2026-01-29T02:28:45.585Z [DEBUG] [Query.streamInput] Processing message 51: user 2026-01-29T02:29:41.828Z [DEBUG] [Query.streamInput] Processing message 52: user 2026-01-29T02:31:06.397Z [DEBUG] [Query.streamInput] Processing message 53: user 2026-01-29T02:39:07.173Z [DEBUG] [Query.streamInput] Processing message 54: user 2026-01-29T02:43:46.967Z [DEBUG] [Query.streamInput] Processing message 55: user 2026-01-29T02:49:25.299Z [DEBUG] [Query.streamInput] Processing message 56: user 2026-01-29T02:49:38.300Z [DEBUG] [Query.streamInput] Processing message 57: user 2026-01-29T03:01:43.503Z [DEBUG] [Query.streamInput] Processing message 58: user 2026-01-29T03:05:50.041Z [DEBUG] [Query.streamInput] Processing message 59: user 2026-01-29T05:49:18.989Z [DEBUG] [Query.streamInput] Starting to process input stream 2026-01-29T05:49:19.014Z [DEBUG] [Query.streamInput] Processing message 1: user 2026-01-29T05:50:19.682Z [DEBUG] [Query.streamInput] Processing message 2: user 2026-01-29T06:01:23.243Z [DEBUG] [Query.streamInput] Processing message 3: user 2026-01-29T06:06:17.062Z [DEBUG] [Query.streamInput] Processing message 4: user 2026-01-29T06:16:50.315Z [DEBUG] [Query.streamInput] Processing message 5: user 2026-01-29T06:43:50.243Z [DEBUG] [Query.streamInput] Processing message 6: user 2026-01-29T08:50:44.502Z [DEBUG] [Query.streamInput] Processing message 7: user 2026-01-29T08:52:21.169Z [DEBUG] [Query.streamInput] Processing message 8: user 2026-01-29T09:02:59.990Z [DEBUG] [Query.streamInput] Processing message 9: user 2026-01-29T09:04:30.111Z [DEBUG] [Query.streamInput] Processing message 10: user 2026-01-29T18:29:32.840Z [DEBUG] [Query.streamInput] Processing message 11: user 2026-01-29T18:53:54.454Z [DEBUG] [Query.streamInput] Processing message 12: user 2026-01-29T18:57:21.297Z [DEBUG] [Query.streamInput] Processing message 13: user 2026-01-29T19:09:12.708Z [DEBUG] [Query.streamInput] Processing message 14: user 2026-01-29T19:09:24.713Z [DEBUG] [Query.streamInput] Processing message 15: user 2026-01-29T19:14:43.379Z [DEBUG] [Query.streamInput] Processing message 16: user 2026-01-29T19:15:33.185Z [DEBUG] [Query.streamInput] Processing message 17: user 2026-01-29T20:13:17.498Z [DEBUG] [Query.streamInput] Processing message 18: user 2026-01-29T20:15:46.810Z [DEBUG] [Query.streamInput] Processing message 19: user 2026-01-29T20:57:31.266Z [DEBUG] [Query.streamInput] Processing message 20: user 2026-01-29T21:26:02.742Z [DEBUG] [Query.streamInput] Processing message 21: user 2026-01-29T21:47:50.599Z [DEBUG] [Query.streamInput] Processing message 22: user 2026-01-29T23:09:38.686Z [DEBUG] [Query.streamInput] Processing message 23: user 2026-01-30T01:10:45.220Z [DEBUG] [Query.streamInput] Starting to process input stream 2026-01-30T01:10:45.250Z [DEBUG] [Query.streamInput] Processing message 1: user 2026-01-30T03:06:43.602Z [DEBUG] [Query.streamInput] Processing message 2: user 2026-01-30T03:07:44.071Z [DEBUG] [Query.streamInput] Processing message 3: user 2026-01-30T03:09:01.741Z [DEBUG] [Query.streamInput] Processing message 4: user 2026-01-30T03:14:54.882Z [DEBUG] [Query.streamInput] Processing message 5: user 2026-01-30T03:21:45.659Z [DEBUG] [Query.streamInput] Processing message 6: user 2026-01-30T03:36:23.234Z [DEBUG] [Query.streamInput] Processing message 7: user 2026-01-30T03:43:35.636Z [DEBUG] [Query.streamInput] Processing message 8: user 2026-01-30T03:44:37.605Z [DEBUG] [Query.streamInput] Processing message 9: user 2026-01-30T03:54:32.260Z [DEBUG] [Query.streamInput] Processing message 10: user 2026-01-30T03:55:50.525Z [DEBUG] [Query.streamInput] Processing message 11: user 2026-01-30T07:39:22.334Z [DEBUG] [Query.streamInput] Starting to process input stream 2026-01-30T07:39:22.362Z [DEBUG] [Query.streamInput] Processing message 1: user 2026-01-30T07:41:42.243Z [DEBUG] [Query.streamInput] Processing message 2: user 2026-01-30T10:01:07.003Z [DEBUG] [Query.streamInput] Processing message 3: user 2026-01-30T10:10:30.973Z [DEBUG] [Query.streamInput] Processing message 4: user