[hotfix] [streaming] Properly mark non-transported fields as transient in AbstractStreamOperator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8837c0c5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8837c0c5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8837c0c5 Branch: refs/heads/release-1.2 Commit: 8837c0c5f357c52c15e139ed0697e3710c610db9 Parents: 8fd374c Author: Stephan Ewen <[email protected]> Authored: Tue Feb 14 18:16:36 2017 +0100 Committer: Stephan Ewen <[email protected]> Committed: Thu Feb 16 14:51:01 2017 +0100 ---------------------------------------------------------------------- .../flink/streaming/api/operators/AbstractStreamOperator.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/8837c0c5/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java index 16fe2c1..9d56626 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java @@ -134,9 +134,9 @@ public abstract class AbstractStreamOperator<OUT> // --------------- Metrics --------------------------- /** Metric group for the operator */ - protected MetricGroup metrics; + protected transient MetricGroup metrics; - protected LatencyGauge latencyGauge; + protected transient LatencyGauge latencyGauge; // ---------------- timers ------------------
