Apache Flink-taakbeheer® in HDInsight op AKS-clusters

Artikel
09/20/2024

Belangrijk

Azure HDInsight op AKS is op 31 januari 2025 buiten gebruik gesteld. Meer informatie in deze aankondiging.

U moet uw workloads migreren naar Microsoft Fabric- of een gelijkwaardig Azure-product om plotselinge beëindiging van uw workloads te voorkomen.

Belangrijk

Deze functie is momenteel beschikbaar als preview-versie. De aanvullende gebruiksvoorwaarden voor Microsoft Azure Previews meer juridische voorwaarden bevatten die van toepassing zijn op Azure-functies die bèta, in preview of anderszins nog niet in algemene beschikbaarheid zijn vrijgegeven. Zie Azure HDInsight in AKS preview-informatievoor meer informatie over deze specifieke preview. Voor vragen of suggesties voor functies dient u een aanvraag in op AskHDInsight- met de details en volgt u ons voor meer updates over Azure HDInsight Community-.

HDInsight in AKS biedt een functie voor het rechtstreeks beheren en verzenden van Apache Flink-taken® via de Azure-portal (gebruiksvriendelijke interface) en ARM Rest API's.

Met deze functie kunnen gebruikers hun Apache Flink-taken efficiënt beheren en bewaken zonder diepgaande kennis op clusterniveau te vereisen.

Voordelen

Vereenvoudigd taakbeheer: met de systeemeigen integratie van Apache Flink in Azure Portal hebben gebruikers geen uitgebreide kennis van Flink-clusters meer nodig om taken in te dienen, te beheren en te bewaken.
User-Friendly REST API-: HDInsight op AKS biedt gebruiksvriendelijke ARM Rest API's voor het verzenden en beheren van Flink-taken. Gebruikers kunnen Flink-taken verzenden vanuit elke Azure-service met behulp van deze Rest API's.
Moeiteloze taakupdates en statusbeheer: de systeemeigen Azure Portal-integratie biedt een probleemloze ervaring voor het bijwerken van taken en het herstellen ervan naar de laatst opgeslagen status (savepoint). Deze functionaliteit zorgt voor continuïteit en gegevensintegriteit gedurende de levenscyclus van de taak.
Flink-taak automatiseren met behulp van Azure Pipeline: Met HDInsight op AKS hebben Flink-gebruikers toegang tot gebruiksvriendelijke ARM Rest API, kunt u Flink-taakbewerkingen naadloos integreren in uw Azure Pipeline. Of u nu nieuwe taken start, actieve taken bijwerkt of verschillende taakbewerkingen uitvoert, deze gestroomlijnde aanpak elimineert handmatige stappen. Hiermee kunt u uw Flink-cluster efficiënt beheren.

Voorwaarden

Er zijn enkele vereisten voordat u taken verzendt en beheert vanuit de portal of REST API's.

Maak een map in het primaire opslagaccount van het cluster om het taak-JAR-bestand te uploaden.
Als de gebruiker savepoints wil maken, maakt u een map in de opslagruimte voor taak-savepoints.

Belangrijke functies en bewerkingen

Nieuwe taakverzending: gebruikers kunnen moeiteloos een nieuwe Flink indienen, waardoor complexe configuraties of externe hulpprogramma's niet meer nodig zijn.
Taken stoppen en starten met savepoints: Gebruikers kunnen hun Flink-taken zorgvuldig stoppen en starten vanaf hun vorige toestand (Savepoint). Savepoints zorgen ervoor dat de voortgang van taken behouden blijft, waardoor naadloze hervatting mogelijk is.
Jobupdates: De gebruiker kan de lopende opdracht bijwerken nadat het JAR-bestand in het opslagaccount is bijgewerkt. De update zorgt er automatisch voor dat het opslagpunt wordt genomen en start de taak door een nieuw JAR-bestand te gebruiken.
Stateless updates: Het uitvoeren van een herstart voor een taak wordt vereenvoudigd via stateless updates. Met deze functie kunnen gebruikers een schone herstart starten met behulp van bijgewerkte taak-JAR.
Savepoint-beheer: op elk gewenst moment kunnen gebruikers savepoints maken voor hun actieve taken. Deze opslagpunten kunnen indien nodig worden weergegeven en gebruikt om de taak opnieuw op te starten vanaf een specifiek controlepunt.
annuleren: hiermee wordt de taak definitief geannuleerd.
verwijderen: Taakgeschiedenisrecord verwijderen.

Opties voor het beheren van taken in HDInsight in AKS

HDInsight op AKS biedt manieren om Flink-taken te beheren.

Azure Portal
ARM REST API-

Taakbeheer vanuit de Azure-portal

Als u de Flink-taak vanuit de portal wilt uitvoeren, gaat u naar:

Portal --> HDInsight op AKS-clustergroep --> Flink Cluster --> Settings --> Flink Jobs

Nieuwe taak: Om een nieuwe taak te verzenden, uploadt u de job-jars naar het opslagaccount en maakt u een savepoint-directory aan. Voltooi de sjabloon met de benodigde configuraties en verzend de taak.

Details van het object:

Eigenschap	Beschrijving	Standaardwaarde	Verplicht
Taaknaam	Unieke naam voor taak. Dit wordt weergegeven in de portal. De taaknaam moet in kleine letters zijn.		Ja
Jar-pad	Opslagpad voor taak-JAR. Gebruikers moeten map maken in clusteropslag en taak-JAR uploaden.	Ja
Instapklasse	Invoerklasse voor taak waaruit de taakuitvoering wordt gestart.		Ja
Argumenten	Argument voor het hoofdprogramma van de taak. Scheid alle argumenten met spaties.		Nee
Parallellisme	Job Flink Parallelisme.	2	Ja
savepoint.directory	Savepoint-map voor taak. Het is raadzaam dat gebruikers een nieuwe map maken voor het taakbewaarpunt in het opslagaccount.	`abfs://<container>@<account>/<deployment-ID>/savepoints`	Nee

Zodra de taak is gestart, wordt de taakstatus in de portal ACTIEF.

Stoppen: Het stoppen van de taak vereist geen parameters, de gebruiker kan de taak stoppen door de actie te selecteren.

Zodra de taak gestopt is, wordt de taakstatus op de portal GESTOPT.

Start: Met deze actie wordt de taak gestart vanuit het opslagpunt. Als u de taak wilt starten, selecteert u de gestopte taak en start u deze.

Vul de stroomsjabloon met de vereiste opties en start deze. Gebruikers moeten het opslagpunt selecteren waaruit de gebruiker de taak wil starten. Standaard wordt het laatste geslaagde savepoint gebruikt.

eigenschapsdetails:

Eigenschap / Eigendom	Beschrijving	Verplicht
Argumenten	Argument voor het hoofdprogramma van de taak. Alle argumenten moeten worden gescheiden door spatie.	Nee
Laatste opslagpunt	Laatste geslaagde savepoint-take voordat de taak wordt gestopt. Dit wordt standaard gebruikt als er geen savepoint is geselecteerd.	Niet bewerkbaar
Naam van het opslagpunt	Gebruikers kunnen het beschikbare opslagpunt voor de taak vermelden en er een selecteren om de taak te starten.	Nee

Zodra de taak is gestart, zal de taakstatus in het portaal LOPENDEzijn.

Bijwerken: Bijwerken helpt bij het herstarten van taken met bijgewerkte taakcode. Gebruikers moeten de meest recente taak-JAR bijwerken in de opslaglocatie en de taak bijwerken vanuit de portal. Deze update stopt de taak met savepoint en begint opnieuw met de nieuwste JAR.

Sjabloon voor het bijwerken van de functie.

Zodra de taak is bijgewerkt, is de taakstatus in de portal actief.
Stateless update: Deze taak is net als een update, maar het gaat om een herstart van de klus met de meest recente code.

Sjabloon voor het bijwerken van de functie.

eigenschapsdetails:

Eigenschap Beschrijving Standaardwaarde Verplicht

Argumenten Argument voor het hoofdprogramma van de taak. Scheid alle argumenten met spatie. Nee

Zodra de taak is bijgewerkt, is de taakstatus op de portal LOPEND.
Savepoint: Maak een savepoint voor de Flink-taak.

Savepoint is tijdrovend proces en het duurt enige tijd. U kunt de status van de taakactie zien als in uitvoering.
Annuleren: Met deze taak kan de gebruiker de taak beëindigen.
Verwijderen: Verwijder taakgegevens uit het portaal.
Taakdetails weergeven: Als de gebruiker de taakdetails wil weergeven, kan hij of zij op de taaknaam klikken, waarna de details van de taak en het laatste actieresultaat worden weergegeven.

Voor een mislukte actie geeft deze taak-json gedetailleerde uitzonderingen en redenen voor fouten.

Eigenschap	Beschrijving	Standaardwaarde	Verplicht
Argumenten	Argument voor het hoofdprogramma van de taak. Scheid alle argumenten met spatie.		Nee

taakbeheer met rest API-

HDInsight in AKS biedt ondersteuning voor gebruiksvriendelijke ARM Rest API's voor het verzenden van taken en het beheren van taken. Met behulp van deze Flink REST API kunt u Flink-joboperaties naadloos integreren in uw Azure Pipeline. Of u nu nieuwe taken start, actieve taken bijwerkt of verschillende taakbewerkingen uitvoert, deze gestroomlijnde aanpak elimineert handmatige stappen en stelt u in staat om uw Flink-cluster efficiënt te beheren.

Basis-URL-indeling voor Rest API

Zie de volgende URL voor de REST API; gebruikers moeten het abonnement, de resourcegroep, de clusterpool, de clusternaam en de HDInsight op de AKS API-versie hierin vervangen voordat ze het gebruiken. 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}}

Met deze REST API kunnen gebruikers nieuwe taken initiëren, taken stoppen, taken starten, savepoints maken, taken annuleren en taken verwijderen. De huidige API_VERSION is 2023-06-01-preview.

Rest API-verificatie

Als u Flink ARM Rest API-gebruikers wilt verifiëren, moet u het bearer-token of toegangstoken voor ARM-resource ophalen. Als u de REST API van Azure ARM (Azure Resource Manager) wilt verifiëren met behulp van een service-principal, kunt u de volgende algemene stappen uitvoeren:

Maak een service-principal.

az ad sp create-for-rbac --name <your-SP-name>
Geef de eigenaar toestemming aan SP voor het flink-cluster.
Meld u aan met de service-principalgebruiker.

az login --service-principal -u <client_id> -p <client_secret> --tenant <tenant_id>
Toegangstoken ophalen.

$token = az account get-access-token --resource=https://management.azure.com/ | ConvertFrom-Json

$tok = $token.accesstoken

Gebruikers kunnen een token gebruiken in de weergegeven URL.

$data = Invoke-RestMethod -Uri $restUri -Method GET -Headers @{ Authorization = "Bearer $tok" }

Authenticatie met behulp van beheerde identiteit: Gebruikers kunnen gebruikmaken van resources die beheerde identiteit ondersteunen om aanroepen naar de REST API van de Job te doen. Raadpleeg de documentatie Managed Identity voor meer informatie.

LIJST van APIs en parameters

Nieuwe taak: REST API om een nieuwe taak in te dienen bij Flink.

Optie	Waarde
Methode	VERZENDEN
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}}`
Koptekst	Authorization = "Bearer $token"

Verzoekinhoud van :

{ 
    "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>" 
        } 
     } 
}

eigenschapsdetails voor JSON-hoofdtekst:

Eigendom	Beschrijving	Standaardwaarde	Verplicht
type functie	Soort baan. Het moet 'FlinkJob' zijn		Ja
taaknaam	Unieke naam voor taak. Dit wordt weergegeven in de portal. De taaknaam moet in kleine letters zijn.		Ja
actie	Hiermee wordt het bewerkingstype voor de taak aangegeven. Het moet altijd 'NIEUW' zijn voor het starten van nieuwe taken.		Ja
jobJarDirectory	Opslagpad voor taak-JAR-map. Gebruikers moeten map maken in clusteropslag en taak-JAR uploaden.	Ja
jarNaam	Naam van de taakcontainer.		Ja
entryClass	Invoerklasse voor taak waaruit de taakuitvoering wordt gestart.		Ja
args	Argument voor het hoofdprogramma van de taak. Scheid argumenten met spatie.		Nee
Parallellisme	Job Flink Parallelisme.	2	Ja
savepoint.directory	Opslagpuntmap voor werk. Het is raadzaam dat gebruikers een nieuwe map maken voor taakopslagpunt in het opslagaccount.	`abfs://<container>@<account>/<deployment-ID>/savepoints`	Nee

Voorbeeld:

Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"

taak stoppen: REST API voor het stoppen van de huidige actieve taak.

Optie	Waarde
Methode	VERZENDEN
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}}`
Rubriek	Authorization = "Bearer $token"

Verzoeklichaam

   {
      "properties": {
        "jobType": "FlinkJob",
        "jobName": "<JOB_NAME>",
        "action": "STOP"
      }
    }

Eigenschapsdetails voor JSON-hoofdtekst:

Vastgoed	Beschrijving	Standaardwaarde
type baan	Type van baan. Het moet 'FlinkJob' zijn	Ja
functieNaam	Taaknaam, die wordt gebruikt voor het starten van de taak	Ja
actie	Het moet 'STOP' zijn	Ja

Voorbeeld:

Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"

Taak starten: REST API om gestopte taak te starten.

Optie	Waarde
Methode	VERZENDEN
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}}`
Koptekst	Authorization = "Bearer $token"

Request Body

   {
      "properties": {
         "jobType": "FlinkJob",
         "jobName": "<JOB_NAME>",
         "action": "START",
         "savePointName": "<SAVEPOINT_NAME>"
      }
    }

eigenschapsdetails voor JSON-hoofdtekst:

Eigenschap	Beschrijving	Standaardwaarde
type baan	Soort baan. Het moet 'FlinkJob' zijn	Ja
functieNaam	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
actie	Het moet "START" zijn	Ja
opslaadPuntNaam	Sla de puntnaam op om de taak te starten. Het is een optionele eigenschap. Standaard neemt de beginbewerking het laatst geslaagde savepoint.	Nee

voorbeeld:

Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"

Taak bijwerken: REST API voor het bijwerken van de actieve lopende taak.

Optie	Waarde
Methode	VERZENDEN
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}}`
Koptekst	Authorization = "Bearer $token"

Aanvraaglichaam

  {
      "properties": {
          "jobType": "FlinkJob",
          "jobName": "<JOB_NAME>",
          "action": "UPDATE",
          “args” : “<JOB_JVM_ARGUMENT>”,
          "savePointName": "<SAVEPOINT_NAME>"
      }
  }

eigenschapsdetails voor JSON-hoofdtekst:

Eigendom	Beschrijving	Verplicht
functieType	Type van baan. Het moet 'FlinkJob' zijn	Ja
baanNaam	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
actie	Het moet altijd 'UPDATE' zijn voor de lancering van nieuwe taken.	Ja
args	JVM-argumenten voor taak	Nee
naamOpslagpunt	Sla de naam van het punt op om de taak te starten. Het is een optionele eigenschap, standaard zal de startoperatie het laatst geslaagde savepoint nemen.	Nee

Voorbeeld:

Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"

Stateless updatetaak: REST API voor stateless update.

Optie	Waarde
Methode	VERZENDEN
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}}`
Koptekst	Authorization = "Bearer $token"

verzoekinhoud

  {
      "properties": {
          "jobType": "FlinkJob",
          "jobName": "<JOB_NAME>",
          "action": "STATELESS_UPDATE",
          “args” : “<JOB_JVM_ARGUMENT>”
      }
  }

eigenschapsdetails voor JSON-hoofdtekst:

Vastgoed	Beschrijving	Verplicht
functieType	Soort baan. Het moet 'FlinkJob' zijn	Ja
functieNaam	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
actievoeren	Het moet altijd 'STATELESS_UPDATE' zijn bij het starten van nieuwe taken.	Ja
args	JVM-argumenten voor taak	Nee

voorbeeld:

Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"

Savepoint: REST API's om het opslagpunt voor de taak te activeren.

Optie	Waarde
Methode	VERZENDEN
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}}`
Koptekst	Authorization = "Bearer $token"

verzoekinhoud

  {
      "properties": {
          "jobType": "FlinkJob",
          "jobName": "<JOB_NAME>",
          "action": "SAVEPOINT"
      }
  }

eigenschapsdetails voor JSON-hoofdtekst:

Eigendom	Beschrijving	Verplicht
functieType	Soort baan. Het moet 'FlinkJob' zijn	Ja
functieNaam	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
actie	Het moet altijd 'SAVEPOINT' zijn voor het starten van een nieuwe taak.	Ja

voorbeeld:

Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"

Opslagpuntlijst: REST API om alle savepoints uit de savepoint-directory te tonen.

Optie	Waarde
Methode	VERZENDEN
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}}`
Koptekst	Autorisatie = "Bearer $token"

request body

  {
      "properties": {
          "jobType": "FlinkJob",
          "jobName": "<JOB_NAME>",
          "action": "LIST_SAVEPOINT"
      }
  }

eigenschapsdetails voor JSON-hoofdtekst:

Eigendom	Beschrijving	Verplicht
functiecategorie	Type taak. Het moet 'FlinkJob' zijn	Ja
jobName	Taaknaam die wordt gebruikt voor het starten van de taak	Ja
actie	Het moet 'LIST_SAVEPOINT' zijn	Ja

voorbeeld:

Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"

Annuleren: REST API om de taak te annuleren.

Optie	Waarde
Methode	VERZENDEN
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}}`
Koptekst	Authorization = "Bearer $token"

Request Body

  {
      "properties": {
          "jobType": "FlinkJob",
          "jobName": "<JOB_NAME>",
          "action": "CANCEL"
      }
  }

eigenschapsdetails voor JSON-hoofdtekst:

Eigentdom	Beschrijving	Verplicht
soort werk	Type baan. Het zou `FlinkJob` moeten zijn	Ja
jobName	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
actie	Het moet 'annuleren' zijn.	Ja

voorbeeld:

Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"

Verwijderen: REST API om de taak te verwijderen.

Optie	Waarde
Methode	VERZENDEN
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}}`
Koptekst	Authorization = "Bearer $token"

Verzoekbody

  {
      "properties": {
          "jobType": "FlinkJob",
          "jobName": "<JOB_NAME>",
          "action": "DELETE"
      }
  }

eigenschapsdetails voor JSON-hoofdtekst:

Eigenschap	Beschrijving	Verplicht
functietype	Soort werk. Het moet 'FlinkJob' zijn	Ja
jobName	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
actie	Dit moet verwijderd zijn.	Ja

voorbeeld:

Invoke-RestMethod -Uri $restUri -Method POST -Headers @{ Authorization = "Bearer $tok" } -Body $jsonString -ContentType "application/json"

Taken weergeven: REST API om alle taken en status van de huidige actie weer te geven.

Optie	Waarde
Methode	TOEVOEGEN
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}}`
Koptekst	Authorization = "Bearer $token"

uitvoer:

{ 
  "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" 
      } 
   }
  ]
}

Notitie

Wanneer een actie wordt uitgevoerd, geeft actionResult dit aan met de waarde 'IN_PROGRESS'. Bij geslaagde voltooiing wordt 'SUCCESS' weergegeven, en in het geval van een mislukking, zal het 'MISLUKT' zijn.

Referentie

Apache Flink Taakplanning
Apache, Apache Flink, Flink en bijbehorende opensource-projectnamen zijn handelsmerken van de Apache Software Foundation (ASF).

Delen via

Apache Flink-taakbeheer® in HDInsight op AKS-clusters

Voordelen

Voorwaarden

Belangrijke functies en bewerkingen

Opties voor het beheren van taken in HDInsight in AKS

Taakbeheer vanuit de Azure-portal

taakbeheer met rest API-

Basis-URL-indeling voor Rest API

Rest API-verificatie

LIJST van APIs en parameters

Referentie

Aanvullende resources