[flink] 02/07: [hotfix] Remove outdated description in Javadoc of RecordWriter

[ar...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

arvid pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 0c8a7c1ea3470f1ba647a9ea891b4e0204cc5ac6
Author: kevin.cyj <ke...@alibaba-inc.com>
AuthorDate: Thu Sep 3 16:29:30 2020 +0800

    [hotfix] Remove outdated description in Javadoc of RecordWriter
    
    This closes #13447
---
 .../org/apache/flink/runtime/io/network/api/writer/RecordWriter.java | 5 -----
 1 file changed, 5 deletions(-)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
index d5d47c5..995e670 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
@@ -53,11 +53,6 @@ import static org.apache.flink.util.Preconditions.checkState;
  * <p>The RecordWriter wraps the runtime's {@link ResultPartitionWriter} and takes care of
  * serializing records into buffers.
  *
- * <p><strong>Important</strong>: it is necessary to call {@link #flushAll()} after
- * all records have been written with {@link #emit(IOReadableWritable)}. This
- * ensures that all produced records are written to the output stream (incl.
- * partially filled ones).
- *
  * @param <T> the type of the record that can be emitted with this record writer
  */
 public abstract class RecordWriter<T extends IOReadableWritable> implements AvailabilityProvider {