flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject [1/2] flink git commit: [hotfix] correct typo in method name
Date Mon, 18 Jul 2016 15:16:31 GMT
Repository: flink
Updated Branches:
  refs/heads/master b67e508d0 -> ceef8ad35


[hotfix] correct typo in method name


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

Branch: refs/heads/master
Commit: ea13637bdab0bbf9abc97dec68ea0277e686cc4e
Parents: b67e508
Author: Maximilian Michels <mxm@apache.org>
Authored: Mon Jul 18 14:47:18 2016 +0200
Committer: Maximilian Michels <mxm@apache.org>
Committed: Mon Jul 18 17:16:45 2016 +0200

----------------------------------------------------------------------
 .../src/main/java/org/apache/flink/client/CliFrontend.java       | 2 +-
 .../java/org/apache/flink/api/common/JobSubmissionResult.java    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/ea13637b/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
----------------------------------------------------------------------
diff --git a/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java b/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
index 8d36715..a4691c9 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
@@ -781,7 +781,7 @@ public class CliFrontend {
 			program.deleteExtractedLibraries();
 		}
 
-		if(result.isJobExecutionResults()) {
+		if (result.isJobExecutionResult()) {
 			logAndSysout("Program execution finished");
 			JobExecutionResult execResult = result.getJobExecutionResult();
 			System.out.println("Job with JobID " + execResult.getJobID() + " has finished.");

http://git-wip-us.apache.org/repos/asf/flink/blob/ea13637b/flink-core/src/main/java/org/apache/flink/api/common/JobSubmissionResult.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/JobSubmissionResult.java
b/flink-core/src/main/java/org/apache/flink/api/common/JobSubmissionResult.java
index 4928b25..c5dc869 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/JobSubmissionResult.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/JobSubmissionResult.java
@@ -46,7 +46,7 @@ public class JobSubmissionResult {
 	 * See {@code getJobExecutionResult} to retrieve the JobExecutionResult.
 	 * @return True if this is a JobExecutionResult, false otherwise
 	 */
-	public boolean isJobExecutionResults() {
+	public boolean isJobExecutionResult() {
 		return this instanceof JobExecutionResult;
 	}
 
@@ -56,7 +56,7 @@ public class JobSubmissionResult {
 	 * @throws ClassCastException if this is not a JobExecutionResult
 	 */
 	public JobExecutionResult getJobExecutionResult() {
-		if (isJobExecutionResults()) {
+		if (isJobExecutionResult()) {
 			return (JobExecutionResult) this;
 		} else {
 			throw new ClassCastException("This JobSubmissionResult is not a JobExecutionResult.");


Mime
View raw message