환경 변수
환경 변수 (Environment Variables)
PyFlink의 동작에 영향을 주는 환경 변수들을 설명합니다. 크게 FLINK_HOME처럼 PyFlink 작업을 컴파일하는 데 필요한 Flink 배포(distribution)를 지정하는 변수와, PYFLINK_CLIENT_EXECUTABLE처럼 Python 프로세스를 실행하는 데 사용할 Python 인터프리터의 경로를 지정하는 변수가 있습니다. 이러한 환경 변수를 이해하면 PyFlink 작업을 다양한 환경에서 올바르게 설정하고 실행할 수 있습니다.
출처: 문서
본문
다음 환경 변수들은 PyFlink의 동작에 영향을 줍니다.
| 환경 변수 (Environment Variable) | 설명 (Description) |
|---|---|
FLINK_HOME |
PyFlink 작업은 제출 전에 컴파일되며, 작업을 컴파일하려면 Flink의 배포가 필요합니다. PyFlink 설치 패키지에는 이미 Flink의 배포가 포함되어 있어 기본적으로 사용됩니다. 이 환경 변수를 사용하면 사용자 정의 Flink 배포를 지정할 수 있습니다. |
PYFLINK_CLIENT_EXECUTABLE |
"flink run"으로 Python 작업을 제출하거나 Python UDF를 포함한 Java/Scala 작업을 컴파일할 때 Python 프로세스를 시작하는 데 사용되는 Python 인터프리터의 경로입니다. 구성 옵션 python.client.executable과 동일합니다. 우선순위는 다음과 같습니다. |
우선순위:
- 소스 코드에 정의된
python.client.executable구성 PYFLINK_CLIENT_EXECUTABLE환경 변수- Flink 구성 파일에 정의된
python.client.executable구성
위 중 어느 것도 설정되지 않으면 기본 Python 인터프리터 python이 사용됩니다.