You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/02/16 16:08:01 UTC
[3/6] flink git commit: [hotfix] [streaming] Properly mark
non-transported fields as transient in AbstractStreamOperator
[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 <se...@apache.org>
Authored: Tue Feb 14 18:16:36 2017 +0100
Committer: Stephan Ewen <se...@apache.org>
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 ------------------