diff --git a/src/flow/src/adapter.rs b/src/flow/src/adapter.rs index 5c70862109..712cd5cbf2 100644 --- a/src/flow/src/adapter.rs +++ b/src/flow/src/adapter.rs @@ -319,7 +319,7 @@ impl FlownodeManager { ); // TODO(discord9): bugged so we can't infer time index from flow plan, so we have to manually set one let ts_col = ColumnSchema::new( - "GREPTIME_TIMESTAMP", + GREPTIME_TIMESTAMP, ConcreteDataType::timestamp_millisecond_datatype(), true, )