[hotfix][streaming] Fix logging in TwoPhaseCommitSinkFunction

PangZhi · Aug 29, 2017 · 1e2a638 · 1e2a638
1 parent 9d9cdcb
commit 1e2a638
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...c/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java b/...c/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
@@ -285,7 +285,7 @@ public void initializeState(FunctionInitializationContext context) throws Except
 		}
 		// 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();
 		}