인자 가 있 는 Flink 작업 시작

1. 작성 목적
Flink 작업 방법 을 시작 하 는 명령 은 bin/flink run examples/myflink.jar 입 니 다. 그러나 가끔 은 우리 가 시작 할 때 파일 의 경 로 를 설정 하 는 등 인 자 를 안 으로 전달 해 야 합 니 다.
2. 상세 한 과정
Flink 작업 을 시작 할 때 인자 path 를 추가 하고 프로필 의 절대 경 로 를 지정 해 야 합 니 다.예 를 들 어 bin/flink run examples/myflink.jar -path /usr/local/config/config.properties

ParameterTool parameters = ParameterTool.fromArgs(args);
String path = parameters.get("path",null);

//     
String configFilePath = "/opt/flink-1.8.1/yan-flink/config.properties";

//        ，     
if(path != null) {
	if(path.startsWith("./")) {
		System.out.println("error: Please use absolute path such as '/opt/...'");
		return;
	}
	configFilePath = path;
}

//         
ParameterTool configParameterTool = null;
try {
	configParameterTool = ParameterTool.fromPropertiesFile(configFilePath);
} catch (IOException e) {
	if(e instanceof java.io.FileNotFoundException) {
		System.out.println("error: configFilePath:"+configFilePath + " doesn't exist.");
		return;
	}
}

//         ,              
try {
	//           ，                 
	initProperties(configParameterTool);
} catch (Exception e) {
	e.printStackTrace();
	return;
}
		

3. 총화
이러한 방식 으로 설정 을 하 는 것 이 편리 합 니 다. 포장 후 서버 에 올 려 놓 고 실행 하면 서로 다른 설정 파일 에 따라 실행 환경 등의 변경 사항 에 적응 할 수 있 습 니 다. 다시 포장 할 필요 가 없습니다. 필요 하 다 면 포장 후 실행 과정 에서 도 설정 파일 을 수정 한 다음 에 Flink 라 는 작업 을 다시 시작 하면 됩 니 다.
Smileyan 2019 년 8 월 14 일 17: 23