This is an automated email from the ASF dual-hosted git repository.

gian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git


The following commit(s) were added to refs/heads/master by this push:
     new a964220260d StreamAppenderator: Add sink prior to announcing it. 
(#17649)
a964220260d is described below

commit a964220260dd41d4084e653158fd7ec45092d716
Author: Gian Merlino <gianmerl...@gmail.com>
AuthorDate: Tue Jan 21 16:49:05 2025 -0800

    StreamAppenderator: Add sink prior to announcing it. (#17649)
    
    Fixes #17633.
---
 .../druid/segment/realtime/appenderator/StreamAppenderator.java      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/server/src/main/java/org/apache/druid/segment/realtime/appenderator/StreamAppenderator.java
 
b/server/src/main/java/org/apache/druid/segment/realtime/appenderator/StreamAppenderator.java
index 9597ae0b54c..8a7b3b535f5 100644
--- 
a/server/src/main/java/org/apache/druid/segment/realtime/appenderator/StreamAppenderator.java
+++ 
b/server/src/main/java/org/apache/druid/segment/realtime/appenderator/StreamAppenderator.java
@@ -528,6 +528,9 @@ public class StreamAppenderator implements Appenderator
       );
       bytesCurrentlyInMemory.addAndGet(calculateSinkMemoryInUsed(retVal));
 
+      // Add sink prior to announcing it, to ensure it is immediately 
queryable.
+      addSink(identifier, retVal);
+
       try {
         segmentAnnouncer.announceSegment(retVal.getSegment());
       }
@@ -536,8 +539,6 @@ public class StreamAppenderator implements Appenderator
            .addData("interval", retVal.getInterval())
            .emit();
       }
-
-      addSink(identifier, retVal);
     }
 
     return retVal;


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@druid.apache.org
For additional commands, e-mail: commits-h...@druid.apache.org

Reply via email to