flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [1/2] flink git commit: [hotfix] Add trace logging to state object discarding
Date Mon, 24 Jul 2017 09:08:49 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.3 618d54449 -> ab28c8e84


[hotfix] Add trace logging to state object discarding


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9416357a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9416357a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9416357a

Branch: refs/heads/release-1.3
Commit: 9416357a4f91afe2c2388ae10b71477608ed905a
Parents: 618d544
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Fri Jul 21 18:43:39 2017 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Mon Jul 24 11:05:37 2017 +0200

----------------------------------------------------------------------
 .../org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/9416357a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java
index 7c3edee..56aa19d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java
@@ -224,7 +224,9 @@ public class CompletedCheckpoint implements Serializable {
 
 			// discard private state objects
 			try {
-				StateUtil.bestEffortDiscardAllStateObjects(operatorStates.values());
+				Collection<OperatorState> values = operatorStates.values();
+				LOG.trace("About to discard operator states {}.", values);
+				StateUtil.bestEffortDiscardAllStateObjects(values);
 			} catch (Exception e) {
 				exception = ExceptionUtils.firstOrSuppressed(e, exception);
 			}


Mime
View raw message