You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by jm...@apache.org on 2017/03/07 00:18:52 UTC
[3/9] samza git commit: Fixing checkstyle error in StreamGraphImpl
causing build failures
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/samza-fluent-api-v1
Commit: 65df0b5df2931f9383e4b1f21e5b9f0901b6286f
Parents: f1bc1d0
Author: navina <na...@apache.org>
Authored: Fri Feb 24 18:17:29 2017 -0800
Committer: navina <na...@apache.org>
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;