You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2015/12/01 19:09:01 UTC
[17/50] [abbrv] storm git commit: make BaseWorkerHook serializable by
default
make BaseWorkerHook serializable by default
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/4078d95e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/4078d95e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/4078d95e
Branch: refs/heads/STORM-1040
Commit: 4078d95e6f15fec386ecdfa4625cb3bd89906a61
Parents: fe64642
Author: Michael Schonfeld <mi...@schonfeld.org>
Authored: Tue Nov 17 12:26:18 2015 -0500
Committer: Michael Schonfeld <mi...@schonfeld.org>
Committed: Mon Nov 23 18:50:55 2015 -0500
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/hooks/BaseWorkerHook.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/4078d95e/storm-core/src/jvm/backtype/storm/hooks/BaseWorkerHook.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/hooks/BaseWorkerHook.java b/storm-core/src/jvm/backtype/storm/hooks/BaseWorkerHook.java
index 6fe9f19..e04f19b 100644
--- a/storm-core/src/jvm/backtype/storm/hooks/BaseWorkerHook.java
+++ b/storm-core/src/jvm/backtype/storm/hooks/BaseWorkerHook.java
@@ -19,10 +19,13 @@ package backtype.storm.hooks;
import backtype.storm.task.WorkerTopologyContext;
+import java.io.Serializable;
import java.util.List;
import java.util.Map;
-public class BaseWorkerHook implements IWorkerHook {
+public class BaseWorkerHook implements IWorkerHook, Serializable {
+ private static final long serialVersionUID = 2589466485198339529L;
+
@Override
public void start(Map stormConf, WorkerTopologyContext context, List taskIds) {