Skip to content

Commit

Permalink
[FLINK-1183] Generate gentle notification message when Flink is start…
Browse files Browse the repository at this point in the history
…ed with Java 6

This closes apache#296.
  • Loading branch information
Ajay Bhat authored and uce committed Jan 16, 2015
1 parent 2b16c60 commit c236df0
Showing 1 changed file with 12 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -60,6 +60,8 @@ Actor with ActorLogMessages with ActorLogging {

log.info(s"Starting job manager at ${self.path}.")

checkJavaVersion

val (archiveCount,
profiling,
cleanupInterval,
Expand Down Expand Up @@ -443,6 +445,16 @@ Actor with ActorLogMessages with ActorLogging {
log.error(t, s"Could not properly unregister job ${jobID} form the library cache.")
}
}

private def checkJavaVersion {
var javaVersion = System.getProperty("java.version")
if (javaVersion.substring(0, 3).toDouble < 1.7) {
JobManager.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.")
}
}
}

object JobManager {
Expand Down

0 comments on commit c236df0

Please sign in to comment.