Skip to content

Commit e93e099

Browse files
fix: ingest new stream for distributed (#1005)
current - ingestor unable to create stream with ingest api fix - if stream exists in storage, create from storage else create stream in storage
1 parent fad6b4b commit e93e099

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/handlers/http/ingest.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -204,8 +204,10 @@ pub async fn create_stream_if_not_exists(
204204
// For distributed deployments, if the stream not found in memory map,
205205
//check if it exists in the storage
206206
//create stream and schema from storage
207-
if CONFIG.parseable.mode != Mode::All {
208-
return Ok(create_stream_and_schema_from_storage(stream_name).await?);
207+
if CONFIG.parseable.mode != Mode::All
208+
&& create_stream_and_schema_from_storage(stream_name).await?
209+
{
210+
return Ok(stream_exists);
209211
}
210212

211213
super::logstream::create_stream(

0 commit comments

Comments
 (0)