[fix]: set maxVersion for tablestore offlineTable fetchFunc

aliyun · Aug 8, 2024 · c734aca · c734aca
1 parent 90dfade
commit c734aca
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dao/feature_view_tablestore_dao.go b/dao/feature_view_tablestore_dao.go
@@ -267,6 +267,7 @@ func (d *FeatureViewTableStoreDao) GetUserSequenceFeature(keys []interface{}, us
 				} else {
 					rangeRowQueryCriteria.ColumnsToGet = []string{sequenceConfig.ItemIdField, sequenceConfig.EventField, sequenceConfig.PlayTimeField, sequenceConfig.TimestampField}
 				}
+				rangeRowQueryCriteria.MaxVersion = 1
 
 				getRangeRequest.RangeRowQueryCriteria = rangeRowQueryCriteria
 				getRangeResp, err := d.tablestoreClient.GetRange(getRangeRequest)