emkornfield commented on a change in pull request #7012:
URL: https://github.com/apache/arrow/pull/7012#discussion_r419200568
##
File path:
java/flight/flight-core/src/test/java/org/apache/arrow/flight/TestDoExchange.java
##
@@ -0,0 +1,395 @@
+/*
+ * Licensed to the Apache Sof
emkornfield commented on a change in pull request #7012:
URL: https://github.com/apache/arrow/pull/7012#discussion_r419200063
##
File path:
java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightClient.java
##
@@ -293,6 +292,76 @@ public void onCompleted() {
emkornfield commented on a change in pull request #7012:
URL: https://github.com/apache/arrow/pull/7012#discussion_r419200128
##
File path:
java/flight/flight-core/src/test/java/org/apache/arrow/flight/TestDoExchange.java
##
@@ -0,0 +1,407 @@
+/*
+ * Licensed to the Apache Sof
emkornfield commented on a change in pull request #7012:
URL: https://github.com/apache/arrow/pull/7012#discussion_r419199838
##
File path:
java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightService.java
##
@@ -155,79 +152,35 @@ public void setOnCancelHandler(
emkornfield commented on a change in pull request #7012:
URL: https://github.com/apache/arrow/pull/7012#discussion_r417067307
##
File path:
java/flight/flight-core/src/main/java/org/apache/arrow/flight/ArrowMessage.java
##
@@ -154,6 +154,20 @@ public ArrowMessage(ArrowDictiona