You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by bo...@apache.org on 2017/10/25 00:44:30 UTC
samza git commit: StreamOperatorTask does not need to be final.
Repository: samza
Updated Branches:
refs/heads/master 958edc42f -> cc1ca2c9d
StreamOperatorTask does not need to be final.
Author: Boris S <bo...@apache.org>
Author: Boris Shkolnik <bs...@linkedin.com>
Reviewers: Xinyu Liu <xi...@apache.org>
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 <bo...@apache.org>
Authored: Tue Oct 24 17:44:21 2017 -0700
Committer: Boris S <bo...@apache.org>
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;