Skip to content

Commit f8fa151

Browse files
committed
fix
1 parent 0cea12e commit f8fa151

File tree

1 file changed

+13
-10
lines changed
  • src/query/service/src/sql/planner

1 file changed

+13
-10
lines changed

src/query/service/src/sql/planner/mod.rs

Lines changed: 13 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -115,17 +115,20 @@ impl Planner {
115115
}
116116
.await;
117117

118-
if res.is_err()
119-
&& tokens.len() < PROBE_INSERT_MAX_TOKENS
120-
&& matches!(tokenizer.peek(), Some(Ok(_)))
121-
{
118+
if res.is_err() && matches!(tokenizer.peek(), Some(Ok(_))) {
122119
// Tokenize more and try again.
123-
for token in (&mut tokenizer)
124-
.take(tokens.len() * 2)
125-
.take_while(|token| token.is_ok())
126-
{
127-
tokens.push(token.unwrap());
128-
}
120+
if tokens.len() < PROBE_INSERT_MAX_TOKENS {
121+
for token in (&mut tokenizer)
122+
.take(tokens.len() * 2)
123+
.take_while(|token| token.is_ok())
124+
{
125+
tokens.push(token.unwrap());
126+
}
127+
} else {
128+
for token in (&mut tokenizer).take_while(|token| token.is_ok()) {
129+
tokens.push(token.unwrap());
130+
}
131+
};
129132
} else {
130133
return res;
131134
}

0 commit comments

Comments
 (0)