AKS 클러스터의 HDInsight에서 Apache Flink® 작업 관리
중요하다
AKS의 Azure HDInsight는 2025년 1월 31일에 사용 중지되었습니다. 이 공지에서 을/를 더 알아보세요.
워크로드가 갑자기 종료되는 것을 방지하기 위해 워크로드를 Microsoft Fabric 또는 동등한 Azure 제품으로 워크로드를 마이그레이션해야 합니다.
중요하다
이 기능은 현재 미리 보기로 제공됩니다. Microsoft Azure 미리 보기에 대한 추가 사용 약관은 베타, 미리 보기 또는 아직 일반 공급으로 출시되지 않은 Azure 기능에 적용되는 더 많은 법적 조건을 포함하고 있습니다. 이 특정 미리 보기에 대한 자세한 내용은 Azure HDInsight on AKS 미리 보기 정보 를 참조하십시오. 질문이나 기능 제안이 있으시면 AskHDInsight에 요청을 제출해 주세요. 또한, 더 많은 업데이트를 받으시려면 Azure HDInsight Community를 팔로우해 주세요.
AKS의 HDInsight는 Azure Portal(사용자 친화적인 인터페이스) 및 ARM Rest API를 통해 직접 Apache Flink® 작업을 관리하고 제출하는 기능을 제공합니다.
이 기능을 통해 사용자는 심층 클러스터 수준 지식 없이도 Apache Flink 작업을 효율적으로 제어하고 모니터링할 수 있습니다.
혜택
간소화된 작업 관리: Azure Portal에서 Apache Flink의 네이티브 통합을 통해 사용자는 더 이상 작업을 제출, 관리 및 모니터링하기 위해 Flink 클러스터에 대한 광범위한 지식이 필요하지 않습니다.
User-Friendly REST API: AKS의 HDInsight는 사용자에게 친숙한 ARM Rest API를 제공하여 Flink 작업을 제출하고 관리합니다. 사용자는 이러한 Rest API를 사용하여 모든 Azure 서비스에서 Flink 작업을 제출할 수 있습니다.
간편한 작업 업데이트 및 상태 관리: 네이티브 Azure Portal 통합은 작업을 업데이트하고 마지막으로 저장된 상태(저장점)로 복원하기 위한 번거롭지 않은 경험을 제공합니다. 이 기능은 작업 수명 주기 내내 연속성 및 데이터 무결성을 보장합니다.
Azure 파이프라인 사용하여 Flink 작업 자동화: AKS에서 HDInsight를 사용하면 Flink 사용자가 사용자에게 친숙한 ARM Rest API에 액세스할 수 있으므로 Flink 작업 작업을 Azure Pipeline에 원활하게 통합할 수 있습니다. 새 작업을 시작하든, 실행 중인 작업을 업데이트하든, 다양한 작업 작업을 수행하든 관계없이 이 간소화된 접근 방식은 수동 단계를 제거합니다. Flink 클러스터를 효율적으로 관리할 수 있습니다.
필수 구성 요소
포털 또는 Rest API에서 작업을 제출하고 관리하기 전에 몇 가지 필수 구성 요소가 있습니다.
클러스터의 기본 스토리지 계정에 디렉터리를 만들어 작업 jar를 업로드합니다.
사용자가 저장점을 생성하려는 경우 스토리지 계정에 작업 저장점에 대한 디렉터리를 만듭니다.
주요 기능 및 작업
새 작업 제출: 사용자는 새 Flink를 손쉽게 제출하여 복잡한 구성 또는 외부 도구가 필요하지 않습니다.
저장점을 사용하여 작업을 중지하고 시작합니다: 사용자는 저장점에서 이전의 상태로 Flink 작업을 매끄럽게 중지하고 시작할 수 있습니다. 저장점을 사용하면 작업 진행률이 유지되어 원활한 재개가 가능합니다.
작업 업데이트: 사용자는 스토리지 계정에서 jar를 업데이트한 후 실행 중인 작업을 업데이트할 수 있습니다. 이 업데이트는 자동으로 저장점을 가져와서 새 jar로 작업을 시작합니다.
비상태 업데이트: 작업을 새로 시작하는 것은 비상태 업데이트를 통해 간소화됩니다. 이 기능을 사용하면 사용자가 업데이트된 작업 jar를 사용하여 새로 다시 시작을 시작할 수 있습니다.
Savepoint 관리: 지정된 순간에 사용자는 실행 중인 작업에 대한 저장점을 만들 수 있습니다. 이러한 저장점을 나열하고 필요에 따라 특정 검사점에서 작업을 다시 시작하는 데 사용할 수 있습니다.
취소: 작업을 영구적으로 취소합니다.
삭제: 작업 기록 레코드를 삭제합니다.
AKS의 HDInsight에서 작업을 관리하는 옵션
AKS의 HDInsight는 Flink 작업을 관리하는 방법을 제공합니다.
Azure 포털에서의 작업 관리
포털에서 Flink 작업을 실행하려면 다음으로 이동합니다.
포털 -- AKS 클러스터 풀의 HDInsight> -> Flink 클러스터 -> 설정 -> Flink 작업
새 작업: 새 작업을 제출하려면 스토리지 계정에 작업 관련 jar 파일을 업로드하고 저장점 디렉터리를 생성하십시오. 필요한 구성으로 템플릿을 완료한 다음 작업을 제출합니다.
속성 세부 정보:
재산 묘사 기본값 필수 작업 이름 작업의 이름은 고유해야 합니다. 포털에 표시됩니다. 작업 이름은 소문자로 작성해야 합니다. 예 Jar 경로 작업 jar에 대한 스토리지 경로입니다. 사용자는 클러스터 스토리지에 디렉터리를 만들고 작업 jar을 업로드해야 합니다. 예 항목 클래스 작업 실행이 시작되는 작업의 진입 클래스를 나타냅니다. 예 인수(Args) 작업의 기본 프로그램에 대한 인수입니다. 모든 인수를 공백으로 구분합니다. 아니요 평행도 작업 Flink 병렬 처리입니다. 2 예 savepoint.directory 작업에 대한 Savepoint 디렉터리입니다. 사용자가 스토리지 계정에서 작업 저장점에 대한 새 디렉터리를 만드는 것이 좋습니다. abfs://<container>@<account>/<deployment-ID>/savepoints아니요 작업이 시작되면 포털의 작업 상태가 실행.
중지: 중지 작업에 매개 변수가 필요하지 않은 경우 사용자가 작업을 선택하여 작업을 중지할 수 있습니다.
작업이 중지되면 포털의 작업 상태가 중지됨.
시작: 이 작업을 저장점에서 시작합니다. 작업을 시작하려면 중지된 작업을 선택하고 시작합니다.
필요한 옵션으로 흐름 템플릿을 채우고 시작합니다. 사용자는 사용자가 작업을 시작하려는 저장점을 선택해야 합니다. 기본적으로 마지막으로 성공한 저장점을 사용합니다.
속성 세부 정보:
재산 설명 기본값 필수 인수(Args) 작업의 기본 프로그램에 대한 인수입니다. 모든 인수는 공백으로 구분해야 합니다. 아니요 마지막 저장점 마지막으로 성공한 저장점은 작업을 중지하기 전에 수행합니다. 저장점이 선택되지 않은 경우 기본적으로 사용됩니다. 편집할 수 없음 저장 지점 이름 사용자는 작업에 사용할 수 있는 저장점을 나열하고 하나를 선택하여 작업을 시작할 수 있습니다. 아니요 작업이 시작되면 포털의 작업 상태가 실행.
업데이트: 업데이트는 업데이트된 작업 코드로 작업을 다시 시작하는 데 도움이 됩니다. 사용자는 스토리지 위치에서 최신 작업 jar를 업데이트하고 포털에서 작업을 업데이트해야 합니다. 이 업데이트는 저장점이 있는 작업을 중지하고 최신 jar로 다시 시작합니다.
작업을 업데이트하기 위한 템플릿입니다.
작업이 업데이트되면 포털의 작업 상태가 "실행 중"입니다.
상태 비지정 업데이트: 이 작업은 업데이트와 같지만 최신 코드로 작업을 새로 다시 시작해야 합니다.
작업을 업데이트하기 위한 템플릿입니다.
속성 세부 정보:
재산 설명 기본값 필수 인수(Args) 작업 기본 프로그램에 대한 매개변수입니다. 모든 인수를 공백으로 구분합니다. 아니요 작업이 업데이트되면 포털의 작업 상태가 실행 중으로 표시됩니다.
저장점: Flink 작업의 저장점을 설정합니다.
저장점은 시간이 많이 걸리는 프로세스이며 시간이 좀 걸립니다. 작업 상태를 진행 중으로 볼 수 있습니다.
취소: 이 작업은 사용자가 작업을 종료하는 데 도움이 됩니다.
삭제: 포털에서 작업 데이터를 삭제합니다.
작업 세부 정보 보기: 사용자가 작업 이름을 클릭할 수 있는 작업 세부 정보를 보려면 작업 및 마지막 작업 결과에 대한 세부 정보를 제공합니다.
실패한 작업의 경우 이 작업 json은 자세한 예외 및 실패 이유를 제공합니다.
Rest API를 사용한 작업 관리
AKS의 HDInsight는 사용자에게 친숙한 ARM Rest API를 지원하여 작업을 제출하고 작업을 관리합니다. 이 Flink REST API를 사용하여 Flink 작업 작업을 Azure Pipeline에 원활하게 통합할 수 있습니다. 새 작업을 시작하든, 실행 중인 작업을 업데이트하든, 다양한 작업 작업을 수행하든, 이 간소화된 접근 방식은 수동 단계를 제거하고 Flink 클러스터를 효율적으로 관리할 수 있도록 합니다.
Rest API의 기본 URL 형식
REST API에 대한 다음 URL을 참조하세요. 사용자는 사용하기 전에 AKS API 버전의 구독, 리소스 그룹, 클러스터 풀, 클러스터 이름 및 HDInsight를 대체해야 합니다.
https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runjob?api-version={{API_VERSION}}
이 REST API를 사용하여 사용자는 새 작업을 시작하고, 작업을 중지하고, 작업을 시작하고, 저장점을 만들고, 작업을 취소하고, 작업을 삭제할 수 있습니다. 현재 API_VERSION 2023-06-01-preview입니다.
Rest API 인증
Flink ARM Rest API 사용자를 인증하려면 ARM 리소스에 대한 전달자 토큰 또는 액세스 토큰을 가져와야 합니다. 서비스 주체를 사용하여 Azure ARM(Azure Resource Manager) REST API를 인증하려면 다음 일반 단계를 수행할 수 있습니다.
서비스 주체를 만듭니다.
az ad sp create-for-rbac --name <your-SP-name>flink클러스터의 소유자 권한을 SP에 부여합니다.서비스 주체를 사용하여 로그인합니다.
az login --service-principal -u <client_id> -p <client_secret> --tenant <tenant_id>액세스 토큰을 가져옵니다.
$token = az account get-access-token --resource=https://management.azure.com/ | ConvertFrom-Json$tok = $token.accesstoken사용자는 표시된 URL에서 토큰을 사용할 수 있습니다.
$data = Invoke-RestMethod -Uri $restUri -Method GET -Headers @{ Authorization = "Bearer $tok" }
관리 ID를 사용한 인증: 사용자는 관리 ID를 지원하는 리소스를 활용하여 작업 REST API를 호출할 수 있습니다. 자세한 내용은 관리 ID 설명서를 참조하세요.
API 및 매개 변수 목록
새 작업: 새 작업을 Flink에 제출하는 Rest API입니다.
선택 값 메서드 올리기 URL https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runJob?api-version={{API_VERSION}}머리글 권한 부여 = "전달자 $token" 요청 본문:
{ "properties": { "jobType": "FlinkJob", "jobName": "<JOB_NAME>", "action": "NEW", "jobJarDirectory": "<JOB_JAR_STORAGE_PATH>", "jarName": "<JOB_JAR_NAME>", "entryClass": "<JOB_ENTRY_CLASS>", “args”: ”<JOB_JVM_ARGUMENT>” "flinkConfiguration": { "parallelism": "<JOB_PARALLELISM>", "savepoint.directory": "<JOB_SAVEPOINT_DIRECTORY_STORAGE_PATH>" } } }JSON 본문에 대한 속성 세부 정보:
재산 묘사 기본값 필수 직무 유형 작업 유형입니다. "FlinkJob"이어야 합니다. 예 작업명 작업의 고유 이름입니다. 포털에 표시됩니다. 작업 이름은 소문자로 입력해야 합니다. 예 행동 작업에 대한 작업 유형을 나타냅니다. 새 작업 시작의 경우 항상 "NEW"여야 합니다. 예 jobJarDirectory 작업 jar 디렉터리에 대한 스토리지 경로입니다. 사용자는 클러스터 스토리지에 디렉터리를 만들고 작업 jar을 업로드해야 합니다. 예 jarName 작업용 jar의 이름입니다. 예 진입클래스 작업 실행이 시작되는 작업의 입력 클래스입니다. 예 인수(args) 작업의 메인 프로그램을 위한 인수입니다. 인수를 공백으로 구분합니다. 아니요 평행도 Flink 작업의 병렬 처리. 2 예 savepoint.directory 작업에 대한 Savepoint 디렉터리입니다. 사용자가 스토리지 계정에서 작업 저장점에 대한 새 디렉터리를 만드는 것이 좋습니다. abfs://<container>@<account>/<deployment-ID>/savepoints아니요 본보기:
Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"중지 작업: 현재 실행 중인 작업을 중지하기 위한 Rest API입니다.
선택 값 메서드 올리기 URL https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runJob?api-version={{API_VERSION}}머리글 권한 부여 = "전달자 $token" 요청 본문
{ "properties": { "jobType": "FlinkJob", "jobName": "<JOB_NAME>", "action": "STOP" } }JSON 본문에 대한 속성 세부 정보:
재산 묘사 기본값 필수 직무 유형 작업 유형입니다. "FlinkJob"이어야 합니다. 예 작업명 작업을 시작하는 데 사용되는 작업 이름 예 행동 "STOP"이어야 합니다. 예 본보기:
Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"작업 시작: Rest API로 중지된 작업을 시작합니다.
선택 값 메서드 올리기 URL https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runJob?api-version={{API_VERSION}}머리글 권한 부여 = "전달자 $token" 요청 본문
{ "properties": { "jobType": "FlinkJob", "jobName": "<JOB_NAME>", "action": "START", "savePointName": "<SAVEPOINT_NAME>" } }JSON 본문에 대한 속성 세부 정보:
재산 묘사 기본값 필수 직무유형 작업 유형입니다. "FlinkJob"이어야 합니다. 예 작업 이름 작업을 시작하는 데 사용되는 작업 이름입니다. 예 행동 "START"라는 표현이어야 합니다. 예 저장지점이름 작업을 시작할 지점 이름을 저장합니다. 기본적으로 시작 작업은 마지막으로 성공한 저장점을 사용하는 선택적 속성입니다. 아니요 예제:
Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"업데이트 작업: 현재 실행 중인 작업을 업데이트하기 위한 Rest API입니다.
선택 값 메서드 게시하기 URL https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runJob?api-version={{API_VERSION}}머리글 권한 부여 = "전달자 $token" 요청 본문
{ "properties": { "jobType": "FlinkJob", "jobName": "<JOB_NAME>", "action": "UPDATE", “args” : “<JOB_JVM_ARGUMENT>”, "savePointName": "<SAVEPOINT_NAME>" } }JSON 본문에 대한 속성 세부 정보:
재산 묘사 기본값 필수 직업 유형 작업 유형입니다. "FlinkJob"이어야 합니다. 예 작업명 작업을 시작하는 데 사용되는 작업 이름입니다. 예 행동 새 작업 시작의 경우 항상 "UPDATE"여야 합니다. 예 인수(args) 작업 JVM 인수 아니요 세이브포인트 이름 작업을 시작할 지점 이름을 저장합니다. 선택적 속성입니다. 기본적으로 시작 작업은 마지막으로 성공한 저장점을 사용합니다. 아니요 본보기:
Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"무상태 업데이트 작업: 무상태 업데이트를 위한 Rest API.
선택 값 메서드 올리기 URL https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runJob?api-version={{API_VERSION}}머리글 권한 부여 = "전달자 $token" 요청 본문
{ "properties": { "jobType": "FlinkJob", "jobName": "<JOB_NAME>", "action": "STATELESS_UPDATE", “args” : “<JOB_JVM_ARGUMENT>” } }JSON 본문에 대한 속성 세부 정보:
재산 묘사 기본값 필수 직무 유형 작업 유형입니다. "FlinkJob"이어야 합니다. 예 작업 이름 작업을 시작하는 데 사용되는 작업 이름입니다. 예 행동 새 작업을 시작할 때는 항상 "STATELESS_UPDATE"이어야 합니다. 예 인수(args) 작업 JVM 인수 아니요 예제:
Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"저장점: 작업에 대한 저장점을 트리거하는 Rest API입니다.
선택 값 메서드 올리기 URL https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runJob?api-version={{API_VERSION}}머리글 권한 부여 = "전달자 $token" 요청 본문
{ "properties": { "jobType": "FlinkJob", "jobName": "<JOB_NAME>", "action": "SAVEPOINT" } }JSON 본문에 대한 속성 세부 정보:
재산 묘사 기본값 필수 직무 유형 작업 유형입니다. "FlinkJob"이어야 합니다. 예 작업 이름 작업을 시작하는 데 사용되는 작업 이름입니다. 예 행동 새 작업을 시작할 때는 항상 "SAVEPOINT"으로 해야 합니다. 예 예제:
Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"저장점 나열: 저장점 디렉터리에 있는 모든 저장점을 나열하는 REST API입니다.
선택 값 메서드 올리기 URL https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runJob?api-version={{API_VERSION}}머리글 권한 부여 = "Bearer $token" 요청 본문
{ "properties": { "jobType": "FlinkJob", "jobName": "<JOB_NAME>", "action": "LIST_SAVEPOINT" } }JSON 본문에 대한 속성 세부 정보:
재산 묘사 기본값 필수 직무 유형 작업 유형입니다. "FlinkJob"이어야 합니다. 예 작업 이름 작업을 시작하는 데 사용되는 작업 이름 예 행동 "LIST_SAVEPOINT"라고 해야 합니다. 예 예제:
Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"취소: 작업을 취소하기 위한 REST API.
선택 값 메서드 올리기 URL https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runJob?api-version={{API_VERSION}}머리글 권한 부여 = "전달자 $token" 요청 내용
{ "properties": { "jobType": "FlinkJob", "jobName": "<JOB_NAME>", "action": "CANCEL" } }JSON 본문에 대한 속성 세부 정보:
재산 묘사 기본값 필수 직무 유형 작업 유형입니다. FlinkJob예 작업이름 작업을 시작하는 데 사용되는 작업 이름입니다. 예 행동 CANCEL이어야 합니다. 예 예제:
Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"삭제: 작업을 삭제하는 REST API는입니다.
선택 값 메서드 올리기 URL https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/runJob?api-version={{API_VERSION}}머리글 권한 부여 = "전달자 $token" 요청 본문
{ "properties": { "jobType": "FlinkJob", "jobName": "<JOB_NAME>", "action": "DELETE" } }JSON 본문에 대한 속성 세부 정보:
재산 묘사 기본값 필수 직무 유형 작업 유형입니다. "FlinkJob"이어야 합니다. 예 작업명 작업을 시작하는 데 사용되는 작업 이름입니다. 예 행동 DELETE 여야 합니다. 예 예제:
Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"작업 나열: Rest API를 사용하여 현재 작업의 모든 작업 및 상태를 나열합니다.
선택 값 메서드 가져오기 URL https://management.azure.com/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/jobs?api-version={{API_VERSION}}머리글 권한 부여 = "전달자 $token" 출력:
{ "value": [ { "id": "/subscriptions/{{USER_SUBSCRIPTION}}/resourceGroups/{{USER_RESOURCE_GROUP}}/providers/Microsoft.HDInsight/clusterpools/{{CLUSER_POOL}}/clusters/{{FLINK_CLUSTER}}/jobs/job1", "properties": { "jobType": "FlinkJob", "jobName": "job1", "jobJarDirectory": "<JOB_JAR_STORAGE_PATH>", "jarName": "<JOB_JAR_NAME>", "action": "STOP", "entryClass": "<JOB_ENTRY_CLASS>", "flinkConfiguration": { "parallelism": "2", "savepoint.directory": "<JOB_SAVEPOINT_DIRECTORY_STORAGE_PATH>s" }, "jobId": "20e9e907eb360b1c69510507f88cdb7b", "status": "STOPPED", "jobOutput": "Savepoint completed. Path: <JOB_SAVEPOINT_DIRECTORY_STORAGE_PATH>s/savepoint-20e9e9-8a48c6b905e5", "actionResult": "SUCCESS", "lastSavePoint": "<JOB_SAVEPOINT_DIRECTORY_STORAGE_PATH>s/savepoint-20e9e9-8a48c6b905e5" } } ] }
메모
작업이 진행 중인 경우 actionResult는 성공적으로 완료될 때 'IN_PROGRESS' 값으로 표시하고, 'SUCCESS'를 표시하고, 실패할 경우 'FAILED'가 됩니다.
참조
- Apache Flink 작업 예약
- Apache, Apache Flink, Flink 및 관련 오픈 소스 프로젝트 이름은 asF(Apache Software Foundation)의 상표입니다.