Github user sohami commented on a diff in the pull request:
https://github.com/apache/drill/pull/950#discussion_r140621635
--- Diff: exec/rpc/src/main/java/org/apache/drill/exec/rpc/BasicClient.java
---
@@ -179,6 +203,13 @@ void send(RpcOutcomeListener<RECEIVE> listener, T
rpcType, SEND protobufBody,
return super.send(connection, rpcType, protobufBody, clazz,
dataBodies);
}
+ public <SEND extends MessageLite, RECEIVE extends MessageLite> void send(
+ RpcOutcomeListener<RECEIVE> listener, SEND protobufBody, boolean
allowInEventLoop,
+ ByteBuf... dataBodies) {
+ super.send(listener, connection, handshakeType, protobufBody,
(Class<RECEIVE>) responseClass,
+ allowInEventLoop, dataBodies);
--- End diff --
Seeing unchecked warning for this function. Please resolve this.
---