This is an automated email from the ASF dual-hosted git repository. boyuanz 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 c77bee6 Clear redundant debug statements in pr-11756 new 32c6579 Merge pull request #11822 from y1chi/clean-up c77bee6 is described below commit c77bee6b83f76775945e92bda9e9a8e295a2ce4a Author: Yichi Zhang <zyi...@google.com> AuthorDate: Tue May 26 15:43:22 2020 -0700 Clear redundant debug statements in pr-11756 --- .../src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java index ab07ca3..0baf76b 100644 --- a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java +++ b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java @@ -1049,9 +1049,6 @@ public class FnApiDoFnRunner<InputT, RestrictionT, PositionT, WatermarkEstimator Instant elementTimestampOrTimerFireTimestamp, PaneInfo paneInfo, TimeDomain timeDomain) { - if (timerId.equals("ts-event") && timeDomain.equals(TimeDomain.PROCESSING_TIME)) { - throw new IllegalStateException("illegal"); - } this.timerId = timerId; this.userKey = userKey; this.dynamicTimerTag = dynamicTimerTag;