Merge pull request apache#13 from bsidhom/cowboy

Reverse a bad if statement
aljoscha · Mar 13, 2018 · 2935eed · 2935eed
2 parents 6bbd8a3 + a937969
commit 2935eed
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ava/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunction.java b/...ava/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunction.java
@@ -138,9 +138,9 @@ public void accept(WindowedValue<OutputT> input) throws Exception {
     Map<BeamFnApi.Target,
         SdkHarnessClient.RemoteOutputReceiver<?>> receiverMap;
     if (outputTarget == null) {
-      receiverMap = ImmutableMap.of(outputTarget, mainOutputReceiver);
-    } else {
       receiverMap = ImmutableMap.of();
+    } else {
+      receiverMap = ImmutableMap.of(outputTarget, mainOutputReceiver);
     }
 
     SdkHarnessClient.ActiveBundle<InputT> bundle = processor.newBundle(receiverMap);