You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2015/01/15 17:23:04 UTC
flink git commit: [FLINK-1183] Generate gentle notification message
when Flink is started with Java 6 (backport)
Repository: flink
Updated Branches:
refs/heads/release-0.8 4c6f944ca -> 52a8f6cff
[FLINK-1183] Generate gentle notification message when Flink is started with Java 6 (backport)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/52a8f6cf
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/52a8f6cf
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/52a8f6cf
Branch: refs/heads/release-0.8
Commit: 52a8f6cff08de596d78316055de15d272f3747c5
Parents: 4c6f944
Author: Ufuk Celebi <uc...@apache.org>
Authored: Thu Jan 15 17:22:40 2015 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Thu Jan 15 17:22:40 2015 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/runtime/jobmanager/JobManager.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/52a8f6cf/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManager.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManager.java
index 0cd08f5..13b3c3d 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManager.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManager.java
@@ -239,6 +239,11 @@ public class JobManager implements ExtendedManagementProtocol, InputSplitProvide
throw new IllegalArgumentException("ExecutionMode");
}
+ String javaVersion = System.getProperty("java.version");
+ if (Double.valueOf(javaVersion.substring(0, 3)) < 1.7) {
+ LOG.warn("Warning: Flink is running with Java 6. Java 6 is not maintained any more by Oracle or the OpenJDK community. Flink currently supports Java 6, but may not in future releases, due to the unavailability of bug fixes security patched.");
+ }
+
// create the scheduler and make it listen at the availability of new instances
this.scheduler = new Scheduler(this.executorService);
this.instanceManager.addInstanceListener(this.scheduler);