[flink] branch master updated: [FLINK-31761] Fix Some Typo And Improve lambda expressions.

[fanrui]

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

fanrui 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 0c6e51ffe3d [FLINK-31761] Fix Some Typo And Improve lambda expressions.
0c6e51ffe3d is described below

commit 0c6e51ffe3db98b2fa2a57cf7ee731b3f6885a6d
Author: slfan1989 <louj1988@@>
AuthorDate: Tue Apr 11 06:15:30 2023 +0800

    [FLINK-31761] Fix Some Typo And Improve lambda expressions.
---
 .../java/org/apache/flink/formats/csv/CsvFileFormatFactory.java   | 2 +-
 .../main/java/org/apache/flink/formats/csv/CsvReaderFormat.java   | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileFormatFactory.java
 
b/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileFormatFactory.java
index 9a4bf9bf540..d3a0d45b358 100644
--- 
a/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileFormatFactory.java
+++ 
b/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileFormatFactory.java
@@ -133,7 +133,7 @@ public class CsvFileFormatFactory implements 
BulkReaderFormatFactory, BulkWriter
                                     .createRowConverter(projectedRowType, 
true);
             CsvReaderFormat<RowData> csvReaderFormat =
                     new CsvReaderFormat<>(
-                            () -> JacksonMapperFactory.createCsvMapper(),
+                            JacksonMapperFactory::createCsvMapper,
                             ignored -> schema,
                             JsonNode.class,
                             converter,
diff --git 
a/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java
 
b/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java
index 02f3afbe43e..83da0a01ddb 100644
--- 
a/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java
+++ 
b/flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvReaderFormat.java
@@ -137,7 +137,7 @@ public class CsvReaderFormat<T> extends 
SimpleStreamFormat<T> {
      *
      * @param mapperFactory The factory creating the {@code CsvMapper}.
      * @param schemaGenerator A generator that creates and configures the 
Jackson CSV schema for
-     *     parsins specific CSV files, from a mapper created by the mapper 
factory.
+     *     parsing specific CSV files, from a mapper created by the mapper 
factory.
      * @param typeInformation The Flink type descriptor of the returned 
elements.
      * @param <T> The type of the returned elements.
      */
@@ -164,17 +164,17 @@ public class CsvReaderFormat<T> extends 
SimpleStreamFormat<T> {
      */
     public static <T> CsvReaderFormat<T> forPojo(Class<T> pojoType) {
         return forSchema(
-                () -> JacksonMapperFactory.createCsvMapper(),
+                JacksonMapperFactory::createCsvMapper,
                 mapper -> mapper.schemaFor(pojoType).withoutQuoteChar(),
                 TypeInformation.of(pojoType));
     }
 
     /**
-     * Returns a new {@code CsvReaderFormat} configured to ignore all parsing 
errors. All thye other
+     * Returns a new {@code CsvReaderFormat} configured to ignore all parsing 
errors. All the other
      * options directly carried over from the subject of the method call.
      */
     public CsvReaderFormat<T> withIgnoreParseErrors() {
-        return new CsvReaderFormat<T>(
+        return new CsvReaderFormat<>(
                 this.mapperFactory,
                 this.schemaGenerator,
                 this.rootType,