From e7f433720e229dcc296d279c459ed65c08fbb531 Mon Sep 17 00:00:00 2001
From: Dan Halperin <dhalperi@google.com>
Date: Tue, 11 Apr 2017 16:26:41 -0700
Subject: [PATCH] Triggers: handle missing case

---
 .../java/org/apache/beam/sdk/transforms/windowing/Triggers.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Triggers.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Triggers.java
index ec82114de606..591af373ff1a 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Triggers.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Triggers.java
@@ -287,6 +287,8 @@ public static Trigger fromProto(RunnerApi.Trigger triggerProto) {
         return trigger;
       case AFTER_SYNCHRONIZED_PROCESSING_TIME:
         return AfterSynchronizedProcessingTime.ofFirstElement();
+      case ALWAYS:
+        return new ReshuffleTrigger();
       case ELEMENT_COUNT:
         return AfterPane.elementCountAtLeast(triggerProto.getElementCount().getElementCount());
       case NEVER: