diff --git a/ql/src/java/org/apache/hadoop/hive/llap/LlapOutputFormatService.java b/ql/src/java/org/apache/hadoop/hive/llap/LlapOutputFormatService.java index c71c637c71..99520a2dba 100644 --- a/ql/src/java/org/apache/hadoop/hive/llap/LlapOutputFormatService.java +++ b/ql/src/java/org/apache/hadoop/hive/llap/LlapOutputFormatService.java @@ -245,7 +245,7 @@ private void failChannel(ChannelHandlerContext ctx, String id, String error) { @Override public void operationComplete(ChannelFuture future) throws Exception { RecordWriter writer = null; - synchronized (INSTANCE) { + synchronized (lock) { writer = writers.remove(id); }