From ef6e2919975afe8805535072d7cdb7340d5f163d Mon Sep 17 00:00:00 2001 From: maqingxiang-it Date: Mon, 21 May 2018 15:39:47 +0800 Subject: [PATCH] hotfix the bucket path in the annotation of DateTimeBucketer.java --- .../apache/flink/streaming/connectors/fs/DateTimeBucketer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/DateTimeBucketer.java b/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/DateTimeBucketer.java index 72b482368c52a..96c743bbf47d2 100644 --- a/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/DateTimeBucketer.java +++ b/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/DateTimeBucketer.java @@ -51,7 +51,7 @@ * } * *

This will create for example the following bucket path: - * {@code /base/1976-12-31-14/} + * {@code /base/1976-12-31--14/} * * @deprecated use {@link org.apache.flink.streaming.connectors.fs.bucketing.DateTimeBucketer} instead. */