You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2023/01/09 12:26:46 UTC
[flink] 01/08: Revert "[FLINK-30166][ORC] Refactor deprecated StreamingFileSink usage with target FileSink"
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a commit to branch revert-21371-30166
in repository https://gitbox.apache.org/repos/asf/flink.git
commit cc12d4dad0904f6a367c0e35db2d1f63bae9b03d
Author: Matthias Pohl <ma...@aiven.io>
AuthorDate: Mon Jan 9 13:26:23 2023 +0100
Revert "[FLINK-30166][ORC] Refactor deprecated StreamingFileSink usage with target FileSink"
This reverts commit 1ac202dd8c21a9362611f45b6de2773699790acf.
---
.../java/org/apache/flink/orc/writer/OrcBulkWriterITCase.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/flink-formats/flink-orc/src/test/java/org/apache/flink/orc/writer/OrcBulkWriterITCase.java b/flink-formats/flink-orc/src/test/java/org/apache/flink/orc/writer/OrcBulkWriterITCase.java
index b8152ff7dde..aefcf188b23 100644
--- a/flink-formats/flink-orc/src/test/java/org/apache/flink/orc/writer/OrcBulkWriterITCase.java
+++ b/flink-formats/flink-orc/src/test/java/org/apache/flink/orc/writer/OrcBulkWriterITCase.java
@@ -19,13 +19,13 @@
package org.apache.flink.orc.writer;
import org.apache.flink.api.common.typeinfo.TypeInformation;
-import org.apache.flink.connector.file.sink.FileSink;
import org.apache.flink.core.fs.Path;
import org.apache.flink.orc.data.Record;
import org.apache.flink.orc.util.OrcBulkWriterTestUtil;
import org.apache.flink.orc.vector.RecordVectorizer;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
+import org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink;
import org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners.UniqueBucketAssigner;
import org.apache.flink.streaming.util.FiniteTestSource;
@@ -38,7 +38,7 @@ import java.util.Arrays;
import java.util.List;
import java.util.Properties;
-/** Integration test for writing data in ORC bulk format using FileSink. */
+/** Integration test for writing data in ORC bulk format using StreamingFileSink. */
class OrcBulkWriterITCase {
private final String schema = "struct<_col0:string,_col1:int>";
@@ -61,8 +61,8 @@ class OrcBulkWriterITCase {
DataStream<Record> stream =
env.addSource(new FiniteTestSource<>(testData), TypeInformation.of(Record.class));
stream.map(str -> str)
- .sinkTo(
- FileSink.forBulkFormat(new Path(outDir.toURI()), factory)
+ .addSink(
+ StreamingFileSink.forBulkFormat(new Path(outDir.toURI()), factory)
.withBucketAssigner(new UniqueBucketAssigner<>("test"))
.build());