You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2021/02/18 23:18:33 UTC

[flink] branch test created (now dd5149d)

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

kkloudas pushed a change to branch test
in repository https://gitbox.apache.org/repos/asf/flink.git.


      at dd5149d  test

This branch includes the following new commits:

     new dd5149d  test

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[flink] 01/01: test

Posted by kk...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

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

commit dd5149ddc8d46ca13b3a2cf5355864a9f2b777c9
Author: Kostas Kloudas <kk...@Kostass-MacBook-Pro.local>
AuthorDate: Fri Feb 19 00:16:00 2021 +0100

    test
---
 .../streaming/api/functions/sink/filesystem/StreamingFileSink.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
index e9ae77d..6af9c01 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
@@ -85,7 +85,7 @@ import java.io.Serializable;
  * state while any {@code in-progress} files are rolled back, so that they do not contain data that
  * arrived after the checkpoint from which we restore.
  *
- * @param <IN> Type of the elements emitted by this sink
+ * @param <IN> Type of the elements emitted by this sink.
  */
 @PublicEvolving
 public class StreamingFileSink<IN> extends RichSinkFunction<IN>