flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [1/2] flink git commit: [hotfix] [streaming] Properly mark non-transported fields as transient in AbstractStreamOperator
Date Wed, 15 Feb 2017 14:12:48 GMT
Repository: flink
Updated Branches:
  refs/heads/master b06522681 -> 04e6758ab


[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/d062448c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d062448c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d062448c

Branch: refs/heads/master
Commit: d062448c294d88e74fb5f8f2acd882850cad89bc
Parents: b065226
Author: Stephan Ewen <sewen@apache.org>
Authored: Tue Feb 14 18:16:36 2017 +0100
Committer: Stephan Ewen <sewen@apache.org>
Committed: Wed Feb 15 15:01:36 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/d062448c/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 05f2ed5..7a3e2ce 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 ------------------
 


Mime
View raw message