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 2016/01/11 18:28:36 UTC
[3/5] storm git commit: mark _groupFactory and _inputFactory as
transient
mark _groupFactory and _inputFactory as transient
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/46fbd2a5
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/46fbd2a5
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/46fbd2a5
Branch: refs/heads/master
Commit: 46fbd2a5159fccaa7608d0cad5d1fecd4bff7a18
Parents: 48c52db
Author: Xin Wang <be...@163.com>
Authored: Wed Jan 6 13:29:23 2016 +0800
Committer: vesense <be...@163.com>
Committed: Wed Jan 6 13:37:01 2016 +0800
----------------------------------------------------------------------
.../storm/trident/state/map/MapCombinerAggStateUpdater.java | 6 +++---
.../jvm/storm/trident/state/map/MapReducerAggStateUpdater.java | 6 +++---
2 files changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/46fbd2a5/storm-core/src/jvm/storm/trident/state/map/MapCombinerAggStateUpdater.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/storm/trident/state/map/MapCombinerAggStateUpdater.java b/storm-core/src/jvm/storm/trident/state/map/MapCombinerAggStateUpdater.java
index cefaf32..dc50419 100644
--- a/storm-core/src/jvm/storm/trident/state/map/MapCombinerAggStateUpdater.java
+++ b/storm-core/src/jvm/storm/trident/state/map/MapCombinerAggStateUpdater.java
@@ -34,13 +34,13 @@ import storm.trident.tuple.TridentTupleView.ProjectionFactory;
public class MapCombinerAggStateUpdater implements StateUpdater<MapState> {
//ANY CHANGE TO THIS CODE MUST BE SERIALIZABLE COMPATIBLE OR THERE WILL BE PROBLEMS
- private static final long serialVersionUID = 4783054195826968400L;
+ private static final long serialVersionUID = -3960578785572592092L;
CombinerAggregator _agg;
Fields _groupFields;
Fields _inputFields;
- ProjectionFactory _groupFactory;
- ProjectionFactory _inputFactory;
+ transient ProjectionFactory _groupFactory;
+ transient ProjectionFactory _inputFactory;
ComboList.Factory _factory;
public MapCombinerAggStateUpdater(CombinerAggregator agg, Fields groupFields, Fields inputFields) {
http://git-wip-us.apache.org/repos/asf/storm/blob/46fbd2a5/storm-core/src/jvm/storm/trident/state/map/MapReducerAggStateUpdater.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/storm/trident/state/map/MapReducerAggStateUpdater.java b/storm-core/src/jvm/storm/trident/state/map/MapReducerAggStateUpdater.java
index 00a6c73..589d8bd 100644
--- a/storm-core/src/jvm/storm/trident/state/map/MapReducerAggStateUpdater.java
+++ b/storm-core/src/jvm/storm/trident/state/map/MapReducerAggStateUpdater.java
@@ -35,13 +35,13 @@ import storm.trident.tuple.TridentTupleView.ProjectionFactory;
public class MapReducerAggStateUpdater implements StateUpdater<MapState> {
//ANY CHANGE TO THIS CODE MUST BE SERIALIZABLE COMPATIBLE OR THERE WILL BE PROBLEMS
- private static final long serialVersionUID = 4382969836839584102L;
+ private static final long serialVersionUID = 8667174018978959987L;
ReducerAggregator _agg;
Fields _groupFields;
Fields _inputFields;
- ProjectionFactory _groupFactory;
- ProjectionFactory _inputFactory;
+ transient ProjectionFactory _groupFactory;
+ transient ProjectionFactory _inputFactory;
ComboList.Factory _factory;
public MapReducerAggStateUpdater(ReducerAggregator agg, Fields groupFields, Fields inputFields) {