From a359409c256109b50f236761e03a52cfd1a32340 Mon Sep 17 00:00:00 2001
From: Pei He <peihe@google.com>
Date: Wed, 2 Mar 2016 13:36:23 -0800
Subject: [PATCH] [BEAM-80] Swap the order of timers and elements sent to
 ReduceFnRunner

---
 .../dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java b/sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java
index f6246d16414d..89a4fcb72022 100644
--- a/sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java
+++ b/sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java
@@ -80,10 +80,10 @@ public void processElement(ProcessContext c) throws Exception {
             reduceFn,
             c.getPipelineOptions());
 
+    reduceFnRunner.processElements(element.elementsIterable());
     for (TimerData timer : element.timersIterable()) {
       reduceFnRunner.onTimer(timer);
     }
-    reduceFnRunner.processElements(element.elementsIterable());
     reduceFnRunner.persist();
   }