Repository: samza Updated Branches: refs/heads/master f1bc1d0b3 -> 65df0b5df
Fixing checkstyle error in StreamGraphImpl causing build failures Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/65df0b5d Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/65df0b5d Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/65df0b5d Branch: refs/heads/master Commit: 65df0b5df2931f9383e4b1f21e5b9f0901b6286f Parents: f1bc1d0 Author: navina <[email protected]> Authored: Fri Feb 24 18:17:29 2017 -0800 Committer: navina <[email protected]> Committed: Fri Feb 24 18:17:44 2017 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/samza/operators/StreamGraphImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/65df0b5d/samza-core/src/main/java/org/apache/samza/operators/StreamGraphImpl.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/operators/StreamGraphImpl.java b/samza-core/src/main/java/org/apache/samza/operators/StreamGraphImpl.java index 353f455..8ca8157 100644 --- a/samza-core/src/main/java/org/apache/samza/operators/StreamGraphImpl.java +++ b/samza-core/src/main/java/org/apache/samza/operators/StreamGraphImpl.java @@ -207,7 +207,7 @@ public class StreamGraphImpl implements StreamGraph { * @return a {@link MessageStreamImpl} object corresponding to the {@code systemStream} */ public MessageStreamImpl getInputStream(SystemStream sstream) { - for(MessageStream entry: this.inStreams.values()) { + for (MessageStream entry: this.inStreams.values()) { if (((InputStreamImpl) entry).getSpec().getSystemName() == sstream.getSystem() && ((InputStreamImpl) entry).getSpec().getPhysicalName() == sstream.getStream()) { return (MessageStreamImpl) entry;
