Fixing a failing unit test.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/93b1b656 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/93b1b656 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/93b1b656 Branch: refs/heads/master Commit: 93b1b656013a941b03c51936ea2c95cd7952fbc5 Parents: 47bcf3e Author: Parth Brahmbhatt <brahmbhatt.pa...@gmail.com> Authored: Wed Mar 18 10:34:56 2015 -0700 Committer: Parth Brahmbhatt <brahmbhatt.pa...@gmail.com> Committed: Wed Mar 18 10:34:56 2015 -0700 ---------------------------------------------------------------------- .../src/jvm/backtype/storm/coordination/BatchBoltExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/93b1b656/storm-core/src/jvm/backtype/storm/coordination/BatchBoltExecutor.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/backtype/storm/coordination/BatchBoltExecutor.java b/storm-core/src/jvm/backtype/storm/coordination/BatchBoltExecutor.java index 89ef028..8653010 100644 --- a/storm-core/src/jvm/backtype/storm/coordination/BatchBoltExecutor.java +++ b/storm-core/src/jvm/backtype/storm/coordination/BatchBoltExecutor.java @@ -103,6 +103,6 @@ public class BatchBoltExecutor implements IRichBolt, FinishedCallback, TimeoutCa } private IBatchBolt newTransactionalBolt() { - return Utils.deserialize(_boltSer, IBatchBolt.class); + return Utils.javaDeserialize(_boltSer, IBatchBolt.class); } }
