You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/03/18 20:39:21 UTC
[14/16] storm git commit: Fixing a failing unit test.
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 <br...@gmail.com>
Authored: Wed Mar 18 10:34:56 2015 -0700
Committer: Parth Brahmbhatt <br...@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);
}
}