Hello Mike Percy, Alexey Serbin, Kudu Jenkins, Adar Dembo, Grant Henke,
I'd like you to reexamine a change. Please visit
http://gerrit.cloudera.org:8080/12363
to look at the new patch set (#5).
Change subject: KUDU-1868 Part 2: Eliminate socket read timeout except for
negotiation
......................................................................
KUDU-1868 Part 2: Eliminate socket read timeout except for negotiation
This removes all use of socket read timeouts from the Java client and
deprecates all public APIs involving the socket read timeout. The Java
client does not use socket read timeouts anymore except to time out
negotiation. This is OK because negotiation is the only activity on the
socket when negotiation occurs. Once negotiation succeeds, the socket
read timeout handler is removed from the pipeline, and the timeout tasks
from Part 1 handle RPC timeouts.
The C++ client does not allow setting the negotiation timeout, and I
chose not to expose it in the Java client because it didn't seem useful,
so I set the timeout to 10000ms, which is much larger than the default
for the C++ client. The C++ client uses 3000ms, which is the server-side
default. The server-side default is also 3000ms, so I left some room for
the server-side default to rise. I wrote a test case and checked that
negotiation did time out when the constant was lowered to a small number
for the purposes of the test.
Change-Id: I391374dd72b6f4a91a9f69cf34758703afbdc59e
---
M java/kudu-backup/src/main/scala/org/apache/kudu/backup/KuduBackup.scala
M java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java
M java/kudu-client/src/main/java/org/apache/kudu/client/Connection.java
M java/kudu-client/src/main/java/org/apache/kudu/client/ConnectionCache.java
M java/kudu-client/src/main/java/org/apache/kudu/client/KuduClient.java
M java/kudu-client/src/test/java/org/apache/kudu/client/ITClient.java
M java/kudu-client/src/test/java/org/apache/kudu/client/TestTimeouts.java
M
java/kudu-mapreduce/src/main/java/org/apache/kudu/mapreduce/CommandLineParser.java
M java/kudu-spark/src/main/scala/org/apache/kudu/spark/kudu/DefaultSource.scala
M java/kudu-spark/src/main/scala/org/apache/kudu/spark/kudu/KuduContext.scala
M
java/kudu-spark/src/main/scala/org/apache/kudu/spark/kudu/KuduReadOptions.scala
M
java/kudu-spark/src/test/scala/org/apache/kudu/spark/kudu/DefaultSourceTest.scala
12 files changed, 74 insertions(+), 147 deletions(-)
git pull ssh://gerrit.cloudera.org:29418/kudu refs/changes/63/12363/5
--
To view, visit http://gerrit.cloudera.org:8080/12363
To unsubscribe, visit http://gerrit.cloudera.org:8080/settings
Gerrit-Project: kudu
Gerrit-Branch: master
Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I391374dd72b6f4a91a9f69cf34758703afbdc59e
Gerrit-Change-Number: 12363
Gerrit-PatchSet: 5
Gerrit-Owner: Will Berkeley <[email protected]>
Gerrit-Reviewer: Adar Dembo <[email protected]>
Gerrit-Reviewer: Alexey Serbin <[email protected]>
Gerrit-Reviewer: Grant Henke <[email protected]>
Gerrit-Reviewer: Kudu Jenkins (120)
Gerrit-Reviewer: Mike Percy <[email protected]>
Gerrit-Reviewer: Will Berkeley <[email protected]>