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 <[email protected]> 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(
