diff --git a/src/stream/src/from_proto/temporal_join.rs b/src/stream/src/from_proto/temporal_join.rs
index 3caca5cd872ee..43404b9eb129f 100644
--- a/src/stream/src/from_proto/temporal_join.rs
+++ b/src/stream/src/from_proto/temporal_join.rs
@@ -47,7 +47,7 @@ impl ExecutorBuilder for TemporalJoinExecutorBuilder {
             let order_types = table_desc
                 .pk
                 .iter()
-                .map(|desc| OrderType::from_protobuf(&desc.get_order_type().unwrap().direction()))
+                .map(|desc| OrderType::from_protobuf(desc.get_order_type().unwrap()))
                 .collect_vec();
 
             let column_descs = table_desc