[flink] branch master updated: [hotfix] Fix CsvRowDataDeserializationSchema constructor

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser 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 92d8633  [hotfix] Fix CsvRowDataDeserializationSchema constructor
92d8633 is described below

commit 92d8633a87521f3ae51a3621eb2dce944f0fcb13
Author: Alexander Fedulov <14...@users.noreply.github.com>
AuthorDate: Mon Mar 28 12:58:37 2022 +0200

    [hotfix] Fix CsvRowDataDeserializationSchema constructor
---
 .../org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java b/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java
index 2d58007..7dfc565 100644
--- a/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java
+++ b/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java
@@ -72,7 +72,7 @@ public final class CsvRowDataDeserializationSchema implements DeserializationSch
         this.resultTypeInfo = resultTypeInfo;
         this.runtimeConverter =
                 new CsvToRowDataConverters(ignoreParseErrors).createRowConverter(rowType, true);
-        this.csvSchema = CsvRowSchemaConverter.convert(rowType);
+        this.csvSchema = csvSchema;
         this.objectReader = new CsvMapper().readerFor(JsonNode.class).with(csvSchema);
         this.ignoreParseErrors = ignoreParseErrors;
     }