This is an automated email from the ASF dual-hosted git repository.
karan 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 eb842d3ddad Remove redundant check on optional in
BlockingQueueFrameChannel.Writable#isClosed (#16595)
eb842d3ddad is described below
commit eb842d3ddadb21718c1e9703976c305b60406623
Author: Virushade <[email protected]>
AuthorDate: Fri Jun 14 17:51:07 2024 +0800
Remove redundant check on optional in
BlockingQueueFrameChannel.Writable#isClosed (#16595)
* Remove redundant check on optional in
BlockingQueueFrameChannel.Writable#isClosed
* Rollback mistake
---
.../java/org/apache/druid/frame/channel/BlockingQueueFrameChannel.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/processing/src/main/java/org/apache/druid/frame/channel/BlockingQueueFrameChannel.java
b/processing/src/main/java/org/apache/druid/frame/channel/BlockingQueueFrameChannel.java
index 9010f620e55..12e14d0dfea 100644
---
a/processing/src/main/java/org/apache/druid/frame/channel/BlockingQueueFrameChannel.java
+++
b/processing/src/main/java/org/apache/druid/frame/channel/BlockingQueueFrameChannel.java
@@ -197,7 +197,7 @@ public class BlockingQueueFrameChannel
{
synchronized (lock) {
final Optional<Either<Throwable, FrameWithPartition>> lastElement =
queue.peekLast();
- return lastElement != null && END_MARKER.equals(lastElement);
+ return END_MARKER.equals(lastElement);
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
