Permalink
Browse files

Merge branch '0.7.2'

  • Loading branch information...
2 parents 2cf102d + 2f66e58 commit b74d32322c0b89b2e3870b1b74aee210374f0fe4 @nathanmarz nathanmarz committed May 17, 2012
View
@@ -32,6 +32,7 @@ NOTE: The change from 0.7.0 in which OutputCollector no longer assumes immutable
* More debug logging in supervisor
* "nohup" no longer used by supervisor to launch workers (unnecessary)
* Throw helpful error message if StormSubmitter used without using storm client script
+ * Add Values class as a default serialization
* Bug fix: give absolute piddir to subprocesses (so that relative paths can be used for storm local dir)
* Bug fix: Fixed critical bug in opaque transactional topologies that would lead to duplicate messages when using pipelining
* Bug fix: Workers will now die properly if a ShellBolt subprocess dies (thanks tomo)
@@ -4,6 +4,7 @@
import backtype.storm.generated.ComponentCommon;
import backtype.storm.generated.StormTopology;
import backtype.storm.transactional.TransactionAttempt;
+import backtype.storm.tuple.Values;
import backtype.storm.utils.ListDelegate;
import backtype.storm.utils.Utils;
import carbonite.JavaBridge;
@@ -52,6 +53,7 @@ public static ObjectBuffer getKryo(Map conf) {
k.register(HashSet.class);
k.register(BigInteger.class, new BigIntegerSerializer());
k.register(TransactionAttempt.class);
+ k.register(Values.class);
JavaBridge clojureSerializersBridge = new JavaBridge();
clojureSerializersBridge.registerClojureCollections(k);
clojureSerializersBridge.registerClojurePrimitives(k);
@@ -7,6 +7,10 @@
* syntax.
*/
public class Values extends ArrayList<Object>{
+ public Values() {
+
+ }
+
public Values(Object... vals) {
super(vals.length);
for(Object o: vals) {

0 comments on commit b74d323

Please sign in to comment.