[incubator-seatunnel] branch dev updated: [Bug][Connector-V2] Fix error option (#2775)

[gaojun2048]

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

gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 488e561ee [Bug][Connector-V2] Fix error option (#2775)
488e561ee is described below

commit 488e561eef40f547b741473c8d01e4fc502aea71
Author: TyrantLucifer <tyrantluci...@gmail.com>
AuthorDate: Mon Sep 19 14:54:37 2022 +0800

    [Bug][Connector-V2] Fix error option (#2775)
---
 .../connectors/seatunnel/file/local/source/LocalFileSource.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/source/LocalFileSource.java
 
b/seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/source/LocalFileSource.java
index 2196227de..c4879482a 100644
--- 
a/seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/source/LocalFileSource.java
+++ 
b/seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/source/LocalFileSource.java
@@ -61,7 +61,7 @@ public class LocalFileSource extends BaseFileSource {
             throw new PrepareFailException(getPluginName(), PluginType.SOURCE, 
"Check file path fail.");
         }
         // support user-defined schema
-        FileFormat fileFormat = 
FileFormat.valueOf(pluginConfig.getString(LocalSourceConfig.FILE_PATH).toUpperCase());
+        FileFormat fileFormat = 
FileFormat.valueOf(pluginConfig.getString(LocalSourceConfig.FILE_TYPE).toUpperCase());
         // only json type support user-defined schema now
         if (pluginConfig.hasPath(SeaTunnelSchema.SCHEMA) && 
fileFormat.equals(FileFormat.JSON)) {
             Config schemaConfig = 
pluginConfig.getConfig(SeaTunnelSchema.SCHEMA);