You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2016/07/18 15:16:31 UTC
[1/2] flink git commit: [hotfix] correct typo in method name
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 <mx...@apache.org>
Authored: Mon Jul 18 14:47:18 2016 +0200
Committer: Maximilian Michels <mx...@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.");
[2/2] flink git commit: [hotfix] fix warning b/c of unspecified
exception type
Posted by mx...@apache.org.
[hotfix] fix warning b/c of unspecified exception type
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ceef8ad3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ceef8ad3
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ceef8ad3
Branch: refs/heads/master
Commit: ceef8ad3565af04f024c03208da1c72e937fc453
Parents: ea13637
Author: Maximilian Michels <mx...@apache.org>
Authored: Mon Jul 18 17:18:30 2016 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Mon Jul 18 17:19:31 2016 +0200
----------------------------------------------------------------------
.../scala/org/apache/flink/runtime/jobmanager/JobManager.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ceef8ad3/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
index 3f3c02e..3c8e716 100644
--- a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
+++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
@@ -2060,7 +2060,7 @@ object JobManager {
try {
webMonitor.stop()
} catch {
- case t =>
+ case t: Throwable =>
LOG.warn("Could not properly stop the web monitor.", t)
}
}