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