diff --git a/server/src/main/java/io/druid/segment/realtime/plumber/Sink.java b/server/src/main/java/io/druid/segment/realtime/plumber/Sink.java index 8b4afa7904b..cb95217a23a 100644 --- a/server/src/main/java/io/druid/segment/realtime/plumber/Sink.java +++ b/server/src/main/java/io/druid/segment/realtime/plumber/Sink.java @@ -50,7 +50,7 @@ public class Sink implements Iterable private static final Logger log = new Logger(Sink.class); private volatile FireHydrant currHydrant; - private final transient Object hydrantLock = new Object(); + private final Object hydrantLock = new Object(); private final Interval interval; private final DataSchema schema;