Repository: samza Updated Branches: refs/heads/master 958edc42f -> cc1ca2c9d
StreamOperatorTask does not need to be final. Author: Boris S <[email protected]> Author: Boris Shkolnik <[email protected]> Reviewers: Xinyu Liu <[email protected]> Closes #336 from sborya/UnmakeStreamOperatorTaskFinal and squashes the following commits: c44ee58 [Boris S] StreamOperatorTask does not need to be final d4620d6 [Boris S] Merge branch 'master' of https://github.com/apache/samza 410ce78 [Boris S] Merge branch 'master' of https://github.com/apache/samza a31a7aa [Boris Shkolnik] reduce debugging from info to debug in KafkaCheckpointManager.java Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/cc1ca2c9 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/cc1ca2c9 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/cc1ca2c9 Branch: refs/heads/master Commit: cc1ca2c9d5014811f8570512a3e598d58b2560bf Parents: 958edc4 Author: Boris S <[email protected]> Authored: Tue Oct 24 17:44:21 2017 -0700 Committer: Boris S <[email protected]> Committed: Tue Oct 24 17:44:21 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/samza/task/StreamOperatorTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/cc1ca2c9/samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java b/samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java index 87af392..e4b3c62 100644 --- a/samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java +++ b/samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java @@ -41,7 +41,7 @@ import org.slf4j.LoggerFactory; * A {@link StreamTask} implementation that brings all the operator API implementation components together and * feeds the input messages into the user-defined transformation chains in {@link StreamApplication}. */ -public final class StreamOperatorTask implements StreamTask, InitableTask, WindowableTask, ClosableTask { +public class StreamOperatorTask implements StreamTask, InitableTask, WindowableTask, ClosableTask { private static final Logger LOG = LoggerFactory.getLogger(StreamOperatorTask.class); private final StreamApplication streamApplication;
