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 <[email protected]>
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;