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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
