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 <[email protected]>
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
[email protected].
