[flink] branch release-1.11 updated: [FLINK-19170][table] fix parameter naming error (#13361)

[rmetzger]

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

rmetzger pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.11 by this push:
     new ac4e2ac  [FLINK-19170][table] fix parameter naming error (#13361)
ac4e2ac is described below

commit ac4e2accaa53fd86e1f6ff7400bee5d4964f9525
Author: Alan Su <776531...@qq.com>
AuthorDate: Mon Sep 14 19:23:46 2020 +0800

    [FLINK-19170][table] fix parameter naming error (#13361)
---
 .../java/org/apache/flink/table/sinks/CsvTableSinkFactoryBase.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/CsvTableSinkFactoryBase.java
 
b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/CsvTableSinkFactoryBase.java
index 3b9bf55..a0675d6 100644
--- 
a/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/CsvTableSinkFactoryBase.java
+++ 
b/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/CsvTableSinkFactoryBase.java
@@ -125,9 +125,9 @@ public abstract class CsvTableSinkFactoryBase implements 
TableFactory {
 
                String path = params.getString(CONNECTOR_PATH);
                String fieldDelimiter = 
params.getOptionalString(FORMAT_FIELD_DELIMITER).orElse(",");
-               Optional<String> writeModeParm = 
params.getOptionalString(FORMAT_WRITE_MODE);
+               Optional<String> writeModeParam = 
params.getOptionalString(FORMAT_WRITE_MODE);
                FileSystem.WriteMode writeMode =
-                               (writeModeParm.isPresent()) ? 
FileSystem.WriteMode.valueOf(writeModeParm.get()) : null;
+                               (writeModeParam.isPresent()) ? 
FileSystem.WriteMode.valueOf(writeModeParam.get()) : null;
                int numFiles = 
params.getOptionalInt(FORMAT_NUM_FILES).orElse(-1);
 
                // bridge to java.sql.Timestamp/Time/Date