diff --git a/flow/e2e/clickhouse/clickhouse.go b/flow/e2e/clickhouse/clickhouse.go index d736957ed..d34222794 100644 --- a/flow/e2e/clickhouse/clickhouse.go +++ b/flow/e2e/clickhouse/clickhouse.go @@ -251,6 +251,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]: