diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/InputOutputFormatVertex.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/InputOutputFormatVertex.java
index b89a67499af25..097ff181b45ee 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/InputOutputFormatVertex.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/InputOutputFormatVertex.java
@@ -87,7 +87,7 @@ public void initializeOnMaster(ClassLoader loader) throws Exception {
                 setInputSplitSource(inputFormat);
             }
 
-            // configure input formats and invoke initializeGlobal()
+            // configure output formats and invoke initializeGlobal()
             Map<OperatorID, UserCodeWrapper<? extends OutputFormat<?>>> outputFormats =
                     formatContainer.getOutputFormats();
             for (Map.Entry<OperatorID, UserCodeWrapper<? extends OutputFormat<?>>> entry :
@@ -125,7 +125,7 @@ public void finalizeOnMaster(ClassLoader loader) throws Exception {
             // set user classloader before calling user code
             Thread.currentThread().setContextClassLoader(loader);
 
-            // configure input formats and invoke finalizeGlobal()
+            // configure output formats and invoke finalizeGlobal()
             Map<OperatorID, UserCodeWrapper<? extends OutputFormat<?>>> outputFormats =
                     formatContainer.getOutputFormats();
             for (Map.Entry<OperatorID, UserCodeWrapper<? extends OutputFormat<?>>> entry :