[beam] branch master updated: Fix a typo in Watch.java (#8267)

[lcwik]

This is an automated email from the ASF dual-hosted git repository.

lcwik 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 533b9d0  Fix a typo in Watch.java (#8267)
533b9d0 is described below

commit 533b9d02a82fad25ef201eec4c0b1e9b3849c364
Author: Yueyang Qiu <robiny...@gmail.com>
AuthorDate: Tue Apr 9 16:39:07 2019 -0700

    Fix a typo in Watch.java (#8267)
---
 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java 
b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java
index 1db0a48..093cf43 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java
@@ -895,7 +895,7 @@ public class Watch {
     private Growth.PollResult computeNeverSeenBeforeResults(
         PollingGrowthState<TerminationStateT> state, 
Growth.PollResult<OutputT> pollResult) {
       // Collect results to include as newly pending. Note that the poll 
result may in theory
-      // contain multiple outputs mapping to the the same output key - we need 
to ignore duplicates
+      // contain multiple outputs mapping to the same output key - we need to 
ignore duplicates
       // here already.
       Map<HashCode, TimestampedValue<OutputT>> newPending = Maps.newHashMap();
       for (TimestampedValue<OutputT> output : pollResult.getOutputs()) {