add serialVersionUID's

nathanmarz · Oct 22, 2011 · 4ba4e02 · 4ba4e02
1 parent f39c0bd
commit 4ba4e02
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 1 deletion.
diff --git a/src/jvm/backtype/storm/drpc/DRPCSpout.java b/src/jvm/backtype/storm/drpc/DRPCSpout.java
@@ -21,8 +21,9 @@
 import org.apache.thrift7.TException;
 import org.json.simple.JSONValue;
 
-//for local mode, should have a service lookup of some sort. DRPCSpout(LocalDRPC...)
 public class DRPCSpout implements IRichSpout {
+    private static final long serialVersionUID = 1L;
+
     public static Logger LOG = Logger.getLogger(DRPCSpout.class);
 
     SpoutOutputCollector _collector;

diff --git a/src/jvm/backtype/storm/drpc/ReturnResults.java b/src/jvm/backtype/storm/drpc/ReturnResults.java
@@ -18,6 +18,7 @@
 
 
 public class ReturnResults implements IRichBolt {
+    private static final long serialVersionUID = 1L;
 
     OutputCollector _collector;
     boolean local;

diff --git a/src/jvm/backtype/storm/task/CoordinatedBolt.java b/src/jvm/backtype/storm/task/CoordinatedBolt.java
@@ -20,6 +20,8 @@
 
 
 public class CoordinatedBolt implements IRichBolt {
+    private static final long serialVersionUID = 1L;
+
     public static Logger LOG = Logger.getLogger(CoordinatedBolt.class);
 
     public static interface FinishedCallback {

diff --git a/src/jvm/backtype/storm/task/KeyedFairBolt.java b/src/jvm/backtype/storm/task/KeyedFairBolt.java
@@ -9,6 +9,8 @@
 
 
 public class KeyedFairBolt implements IRichBolt, FinishedCallback {
+    private static final long serialVersionUID = 1L;
+
     IRichBolt _delegate;
     KeyedRoundRobinQueue<Tuple> _rrQueue;
     Thread _executor;

diff --git a/src/jvm/backtype/storm/task/ShellBolt.java b/src/jvm/backtype/storm/task/ShellBolt.java
@@ -47,6 +47,8 @@
  * </pre>
  */
 public class ShellBolt implements IBolt {
+    private static final long serialVersionUID = 1L;
+
     public static Logger LOG = Logger.getLogger(ShellBolt.class);
 
     String _shellCommand;