You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bo...@apache.org on 2020/05/27 00:43:16 UTC

[beam] branch master updated: Clear redundant debug statements in pr-11756

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 <zy...@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;