Repository: flink Updated Branches: refs/heads/master 79977158a -> 64bbf1d86
[hotfix] [runtime] Minor optimization in CheckpointMetrics Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/990df8f4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/990df8f4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/990df8f4 Branch: refs/heads/master Commit: 990df8f49ddf635bc357033db901bb87be224f42 Parents: 9ed01e6 Author: Stephan Ewen <[email protected]> Authored: Wed Oct 25 11:56:59 2017 +0200 Committer: Stephan Ewen <[email protected]> Committed: Fri Oct 27 17:37:22 2017 +0200 ---------------------------------------------------------------------- .../flink/runtime/checkpoint/CheckpointMetrics.java | 14 ++++---------- 1 file changed, 4 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/990df8f4/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java index a90a2e4..575dcbd 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java @@ -110,16 +110,10 @@ public class CheckpointMetrics implements Serializable { CheckpointMetrics that = (CheckpointMetrics) o; - if (bytesBufferedInAlignment != that.bytesBufferedInAlignment) { - return false; - } - if (alignmentDurationNanos != that.alignmentDurationNanos) { - return false; - } - if (syncDurationMillis != that.syncDurationMillis) { - return false; - } - return asyncDurationMillis == that.asyncDurationMillis; + return bytesBufferedInAlignment == that.bytesBufferedInAlignment && + alignmentDurationNanos == that.alignmentDurationNanos && + syncDurationMillis == that.syncDurationMillis && + asyncDurationMillis == that.asyncDurationMillis; }
