Hello Attila Bukor, Kudu Jenkins, Andrew Wong, Adar Dembo,
I'd like you to reexamine a change. Please visit
http://gerrit.cloudera.org:8080/15210
to look at the new patch set (#4).
Change subject: [java] KUDU-2971: add an outbound queue
......................................................................
[java] KUDU-2971: add an outbound queue
This commit updates the writer tasks to put the responses to an outbound
queue, and uses a separate thread to poll the queue and write the messages
to stdout. So that in case stdout fills up, the message parser tasks
can continue processing the requests without blocking.
Change-Id: I0793ad35af5342bb9af4f2f0eaed4090f78ef3c6
---
M
java/kudu-subprocess-echo/src/test/java/org/apache/kudu/subprocess/echo/TestEchoSubprocess.java
A
java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/MessageParser.java
M
java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/MessageReader.java
M
java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/MessageWriter.java
A java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/QueueUtil.java
M
java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/SubprocessConfiguration.java
M
java/kudu-subprocess/src/main/java/org/apache/kudu/subprocess/SubprocessExecutor.java
M
java/kudu-subprocess/src/test/java/org/apache/kudu/subprocess/TestMessageIO.java
8 files changed, 289 insertions(+), 127 deletions(-)
git pull ssh://gerrit.cloudera.org:29418/kudu refs/changes/10/15210/4
--
To view, visit http://gerrit.cloudera.org:8080/15210
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings
Gerrit-Project: kudu
Gerrit-Branch: master
Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I0793ad35af5342bb9af4f2f0eaed4090f78ef3c6
Gerrit-Change-Number: 15210
Gerrit-PatchSet: 4
Gerrit-Owner: Hao Hao <hao....@cloudera.com>
Gerrit-Reviewer: Adar Dembo <a...@cloudera.com>
Gerrit-Reviewer: Andrew Wong <aw...@cloudera.com>
Gerrit-Reviewer: Attila Bukor <abu...@apache.org>
Gerrit-Reviewer: Hao Hao <hao....@cloudera.com>
Gerrit-Reviewer: Kudu Jenkins (120)
