flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject [7/8] flink git commit: [typo-fix] Fix typo in DelimitedInputFormat.java
Date Thu, 26 Nov 2015 00:20:45 GMT
[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.versaci@gmail.com>
Authored: Wed Nov 25 12:12:50 2015 +0100
Committer: Fabian Hueske <fhueske@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();
 		}
 	}
 }


Mime
View raw message