flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [1/4] flink git commit: [hotfix][streaming] Fix logging in TwoPhaseCommitSinkFunction
Date Tue, 29 Aug 2017 12:46:57 GMT
Repository: flink
Updated Branches:
  refs/heads/master 257a5a541 -> 1e2a63874


[hotfix][streaming] Fix logging in TwoPhaseCommitSinkFunction


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

Branch: refs/heads/master
Commit: 1e2a63874f848fc97b4bceae54fb646c3b128f4f
Parents: 9d9cdcb
Author: Piotr Nowojski <piotr.nowojski@gmail.com>
Authored: Tue Aug 22 16:06:33 2017 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Tue Aug 29 14:45:34 2017 +0200

----------------------------------------------------------------------
 .../streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/1e2a6387/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
index 18f74b6..6040979 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
@@ -285,7 +285,7 @@ public abstract class TwoPhaseCommitSinkFunction<IN, TXN, CONTEXT>
 		}
 		// if in restore we didn't get any userContext or we are initializing from scratch
 		if (userContext == null) {
-			LOG.info("{} - no state to restore {}", name());
+			LOG.info("{} - no state to restore", name());
 
 			userContext = initializeUserContext();
 		}


Mime
View raw message