We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent df12dcd commit 25ee2d6Copy full SHA for 25ee2d6
src/query/service/src/persistent_log/global_persistent_log.rs
@@ -186,15 +186,9 @@ impl GlobalPersistentLog {
186
// alter the table if schema is changed
187
if !prepared {
188
let prepare_guard = self.acquire(&meta_key, self.interval, 0).await?;
189
- match self.prepare().await {
190
- Ok(_) => {
191
- info!("Persistent log prepared successfully");
192
- prepared = true;
193
- }
194
- Err(e) => {
195
- error!("Persistent log prepare failed: {:?}", e);
196
197
+ self.prepare().await?;
+ info!("Persistent log prepared successfully");
+ prepared = true;
198
drop(prepare_guard);
199
}
200
let may_permit = self
0 commit comments