diff --git a/flow/e2e/clickhouse/clickhouse.go b/flow/e2e/clickhouse/clickhouse.go
index 4ff697f263..76b369f84c 100644
--- a/flow/e2e/clickhouse/clickhouse.go
+++ b/flow/e2e/clickhouse/clickhouse.go
@@ -245,6 +245,8 @@ func (s ClickHouseSuite) GetRows(table string, cols string) (*model.QRecordBatch
 						} else {
 							qrow = append(qrow, qvalue.QValueTimestamp{Val: v.Values.Row(idx)})
 						}
+					case *chproto.ColDate32:
+						qrow = append(qrow, qvalue.QValueTimestamp{Val: v.Row(idx)})
 					case *chproto.ColDateTime64:
 						qrow = append(qrow, qvalue.QValueTimestamp{Val: v.Row(idx)})
 					case *chproto.ColNullable[chproto.Decimal32]: