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;