[typo-fix] Fix typo in DelimitedInputFormat.java

This closes #1405


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/804611ce
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/804611ce
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/804611ce

Branch: refs/heads/master
Commit: 804611ce28c9a840ae78bd43f36419b4b49537e4
Parents: e03e60d
Author: fversaci <francesco.vers...@gmail.com>
Authored: Wed Nov 25 12:12:50 2015 +0100
Committer: Fabian Hueske <fhue...@apache.org>
Committed: Wed Nov 25 23:51:28 2015 +0100

----------------------------------------------------------------------
 .../org/apache/flink/api/common/io/DelimitedInputFormat.java     | 4 ++--
 .../flink/api/common/io/DelimitedInputFormatSamplingTest.java    | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/804611ce/flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
----------------------------------------------------------------------
diff --git 
a/flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
 
b/flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
index a1b045f..78c6705 100644
--- 
a/flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
+++ 
b/flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
@@ -78,9 +78,9 @@ public abstract class DelimitedInputFormat<OT> extends 
FileInputFormat<OT> {
         */
        private static int MAX_SAMPLE_LEN;
        
-       static { loadGloablConfigParams(); }
+       static { loadGlobalConfigParams(); }
        
-       protected static void loadGloablConfigParams() {
+       protected static void loadGlobalConfigParams() {
                int maxSamples = 
GlobalConfiguration.getInteger(ConfigConstants.DELIMITED_FORMAT_MAX_LINE_SAMPLES_KEY,
                                
ConfigConstants.DEFAULT_DELIMITED_FORMAT_MAX_LINE_SAMPLES);
                int minSamples = 
GlobalConfiguration.getInteger(ConfigConstants.DELIMITED_FORMAT_MIN_LINE_SAMPLES_KEY,

http://git-wip-us.apache.org/repos/asf/flink/blob/804611ce/flink-core/src/test/java/org/apache/flink/api/common/io/DelimitedInputFormatSamplingTest.java
----------------------------------------------------------------------
diff --git 
a/flink-core/src/test/java/org/apache/flink/api/common/io/DelimitedInputFormatSamplingTest.java
 
b/flink-core/src/test/java/org/apache/flink/api/common/io/DelimitedInputFormatSamplingTest.java
index 5cae59b..fac979e 100644
--- 
a/flink-core/src/test/java/org/apache/flink/api/common/io/DelimitedInputFormatSamplingTest.java
+++ 
b/flink-core/src/test/java/org/apache/flink/api/common/io/DelimitedInputFormatSamplingTest.java
@@ -288,7 +288,7 @@ public class DelimitedInputFormatSamplingTest {
                }
                
                public static void prepare() {
-                       DelimitedInputFormat.loadGloablConfigParams();
+                       DelimitedInputFormat.loadGlobalConfigParams();
                }
        }
 }

Reply via email to