This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 9c3613f [FLINK-22398][runtime] Fix incorrect comments in
InputOutputFormatVertex (#15705)
9c3613f is described below
commit 9c3613f27202d4cc58dbfc7b86fa47cd0536cc8f
Author: kanata163 <[email protected]>
AuthorDate: Fri Apr 23 19:54:54 2021 +0800
[FLINK-22398][runtime] Fix incorrect comments in InputOutputFormatVertex
(#15705)
---
.../org/apache/flink/runtime/jobgraph/InputOutputFormatVertex.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 b89a674..097ff18 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 class InputOutputFormatVertex extends JobVertex {
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 class InputOutputFormatVertex extends JobVertex {
// 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 :
