You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/08/08 17:08:20 UTC
[flink] 01/04: [hotfix][csv][tests] Open schemas
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit d442384309a1afee3a15aa8a3a47c352e2f8d695
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Sun Aug 7 17:22:42 2022 +0200
[hotfix][csv][tests] Open schemas
---
.../test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java b/flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java
index 22e84be6de7..ba4941099cf 100644
--- a/flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java
+++ b/flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java
@@ -256,6 +256,7 @@ public class CsvFormatFactoryTest extends TestLogger {
SerializationSchema<RowData> runtimeEncoder =
sinkMock.valueFormat.createRuntimeEncoder(null, schema.toPhysicalRowDataType());
+ open(runtimeEncoder);
RowData rowData =
GenericRowData.of(
@@ -282,6 +283,7 @@ public class CsvFormatFactoryTest extends TestLogger {
SerializationSchema<RowData> runtimeEncoder =
sinkMock.valueFormat.createRuntimeEncoder(null, schema.toPhysicalRowDataType());
+ open(runtimeEncoder);
RowData rowData =
GenericRowData.of(