flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
/**
		 * Finds the Flink log directory using log.file Java property that is set during startup.
		 */
Finds the Flink log directory using log.file Java property that is set during startup.
Finds the Flink log directory using log . file Java property that is set during startup .
public static LogFileLocation find(Configuration config) {
			final String logEnv = "log.file";
			String logFilePath = System.getProperty(logEnv);
			if (logFilePath == null) {
				LOG.warn("Log file environment variable '{}' is not set.", logEnv);
				logFilePath = config.getString(WebOptions.LOG_PATH);
			}
			if (logFilePath == null || logFilePath.length() < 4) {
				LOG.warn("JobManager log files are unavailable in the web dashboard. " +
					"Log file location not found in environment variable '{}' or configuration key '{}'.",
					logEnv, WebOptions.LOG_PATH);
				return new LogFileLocation(null, null);
			}
			String outFilePath = logFilePath.substring(0, logFilePath.length() - 3).concat("out");
			LOG.info("Determined location of JobManager log file: {}", logFilePath);
			LOG.info("Determined location of JobManager stdout file: {}", outFilePath);
			return new LogFileLocation(resolveFileLocation(logFilePath), resolveFileLocation(outFilePath));
		}
public static LogFileLocation find ( Configuration config ) { final String logEnv = "log.file" ; String logFilePath = System . getProperty ( logEnv ) ; if ( logFilePath == null ) { LOG . warn ( "Log file environment variable '{}' is not set." , logEnv ) ; logFilePath = config . getString ( WebOptions . LOG_PATH ) ; } if ( logFilePath == null || logFilePath . length ( ) < 4 ) { LOG . warn ( "JobManager log files are unavailable in the web dashboard. " + "Log file location not found in environment variable '{}' or configuration key '{}'." , logEnv , WebOptions . LOG_PATH ) ; return new LogFileLocation ( null , null ) ; } String outFilePath = logFilePath . substring ( 0 , logFilePath . length ( ) - 3 ) . concat ( "out" ) ; LOG . info ( "Determined location of JobManager log file: {}" , logFilePath ) ; LOG . info ( "Determined location of JobManager stdout file: {}" , outFilePath ) ; return new LogFileLocation ( resolveFileLocation ( logFilePath ) , resolveFileLocation ( outFilePath ) ) ; }
Finds the Flink log directory using log.file Java property that is set during startup.
Finds the Flink log directory using log . file Java property that is set during startup .
// not configured, cannot serve log files