This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 2bbcb12  Move off of deprecated method in Guava.
2bbcb12 is described below

commit 2bbcb122bc34e668cdbebfae95c0505bfc58f43b
Author: Luke Cwik <lc...@google.com>
AuthorDate: Thu Feb 1 17:06:55 2018 -0800

    Move off of deprecated method in Guava.
---
 .../apache/beam/runners/fnexecution/control/SdkHarnessClient.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java
 
b/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java
index 27c9401..adaa2c7 100644
--- 
a/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java
+++ 
b/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java
@@ -119,7 +119,10 @@ public class SdkHarnessClient {
           processBundleDescriptorId);
 
       ListenableFuture<BeamFnApi.ProcessBundleResponse> specificResponse =
-          Futures.transform(genericResponse, 
InstructionResponse::getProcessBundle);
+          Futures.transform(
+              genericResponse,
+              InstructionResponse::getProcessBundle,
+              MoreExecutors.directExecutor());
       Map<BeamFnApi.Target, InboundDataClient> outputClients = new HashMap<>();
       for (Map.Entry<BeamFnApi.Target, RemoteOutputReceiver<?>> targetReceiver 
:
           outputReceivers.entrySet()) {
@@ -237,7 +240,8 @@ public class SdkHarnessClient {
 
     ListenableFuture<RegisterResponse> registerResponseFuture =
         Futures.transform(
-            genericResponse, InstructionResponse::getRegister,
+            genericResponse,
+            InstructionResponse::getRegister,
             MoreExecutors.directExecutor());
     for (Map.Entry<ProcessBundleDescriptor, 
RemoteInputDestination<WindowedValue<?>>>
         descriptorInputEntry : processBundleDescriptors.entrySet()) {

-- 
To stop receiving notification emails like this one, please contact
lc...@apache.org.

Reply via email to