You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kn...@apache.org on 2022/02/28 08:47:50 UTC
[flink] branch master updated: [hotfix] [docs] Typo in filesystem.md (#18788)
This is an automated email from the ASF dual-hosted git repository.
knaufk 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 145099b [hotfix] [docs] Typo in filesystem.md (#18788)
145099b is described below
commit 145099b9446d9b749747c2413923823748369415
Author: oogetyboogety <ho...@hotmail.com>
AuthorDate: Mon Feb 28 01:47:19 2022 -0700
[hotfix] [docs] Typo in filesystem.md (#18788)
with AvroParquetWriters from ParquetAvroWriters rename
---
docs/content/docs/connectors/datastream/filesystem.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/content/docs/connectors/datastream/filesystem.md b/docs/content/docs/connectors/datastream/filesystem.md
index 85224c1..4fce324 100644
--- a/docs/content/docs/connectors/datastream/filesystem.md
+++ b/docs/content/docs/connectors/datastream/filesystem.md
@@ -405,7 +405,7 @@ Schema schema = ...;
DataStream<GenericRecord> input = ...;
final FileSink<GenericRecord> sink = FileSink
- .forBulkFormat(outputBasePath, ParquetAvroWriters.forGenericRecord(schema))
+ .forBulkFormat(outputBasePath, AvroParquetWriters.forGenericRecord(schema))
.build();
input.sinkTo(sink);