Skip to content

Commit 9c3613f

Browse files
authored
[FLINK-22398][runtime] Fix incorrect comments in InputOutputFormatVertex (#15705)
1 parent 223dd2b commit 9c3613f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/InputOutputFormatVertex.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ public void initializeOnMaster(ClassLoader loader) throws Exception {
8787
setInputSplitSource(inputFormat);
8888
}
8989

90-
// configure input formats and invoke initializeGlobal()
90+
// configure output formats and invoke initializeGlobal()
9191
Map<OperatorID, UserCodeWrapper<? extends OutputFormat<?>>> outputFormats =
9292
formatContainer.getOutputFormats();
9393
for (Map.Entry<OperatorID, UserCodeWrapper<? extends OutputFormat<?>>> entry :
@@ -125,7 +125,7 @@ public void finalizeOnMaster(ClassLoader loader) throws Exception {
125125
// set user classloader before calling user code
126126
Thread.currentThread().setContextClassLoader(loader);
127127

128-
// configure input formats and invoke finalizeGlobal()
128+
// configure output formats and invoke finalizeGlobal()
129129
Map<OperatorID, UserCodeWrapper<? extends OutputFormat<?>>> outputFormats =
130130
formatContainer.getOutputFormats();
131131
for (Map.Entry<OperatorID, UserCodeWrapper<? extends OutputFormat<?>>> entry :

0 commit comments

Comments
 (0)