fix: compare trimmed query string

johanneswuerbach · Feb 10, 2022 · e432d81 · e432d81
1 parent bd2d334
commit e432d81
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/plugin/s3spanstore/reader.go b/plugin/s3spanstore/reader.go
@@ -335,6 +335,7 @@ func (r *Reader) queryAthenaCached(ctx context.Context, queryString string, ttl
 
 	latestCompletionDateTime := time.Now()
 	latestQueryExecutionId := ""
+	trimmedQueryString := strings.TrimSpace(queryString)
 
 	for _, value := range queryExecutionIdChunks {
 		value := value
@@ -348,7 +349,7 @@ func (r *Reader) queryAthenaCached(ctx context.Context, queryString string, ttl
 
 			for _, v := range result.QueryExecutions {
 				// Different query
-				if *v.Query != queryString {
+				if *v.Query != trimmedQueryString {
 					continue
 				}