Apache Flink-taakbeheer® in HDInsight op AKS-clusters

Artikel
09/20/2024

Notitie

Op 31 januari 2025 wordt Azure HDInsight buiten gebruik gesteld op AKS. Vóór 31 januari 2025 moet u uw workloads migreren naar Microsoft Fabric of een gelijkwaardig Azure-product om te voorkomen dat uw workloads plotseling worden beëindigd. De resterende clusters in uw abonnement worden gestopt en verwijderd van de host.

Alleen basisondersteuning is beschikbaar tot de buitengebruikstellingsdatum.

Belangrijk

Deze functie is momenteel beschikbaar in preview. De aanvullende gebruiksvoorwaarden voor Microsoft Azure Previews bevatten meer juridische voorwaarden die van toepassing zijn op Azure-functies die bèta, in preview of anderszins nog niet beschikbaar zijn in algemene beschikbaarheid. Zie Azure HDInsight op AKS Preview-informatie voor 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 in de 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.

Vergoedingen

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.
Gebruiksvriendelijke 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 Integratie van Azure Portal biedt een probleemloze ervaring voor het bijwerken van taken en het herstellen ervan naar hun 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-pijplijn: 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.

Vereisten

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 het opslagaccount voor taakopslagpunten.

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 op een goede manier stoppen en starten vanaf hun vorige status (Savepoint). Savepoints zorgen ervoor dat de voortgang van taken behouden blijft, waardoor naadloze hervatting mogelijk is.
Taakupdates: De gebruiker kan de actieve taak bijwerken na het bijwerken van het JAR-bestand in het opslagaccount. Deze update neemt automatisch het opslagpunt en start de taak met een nieuw JAR-bestand.
Stateless updates: het uitvoeren van een nieuwe 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 permanent 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 Azure Portal

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

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

Nieuwe taak: Als u een nieuwe taak wilt verzenden, uploadt u de taak-JAR's naar het opslagaccount en maakt u een savepoint-map. Voltooi de sjabloon met de benodigde configuraties en verzend de taak.

Details van eigenschap:

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

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

Stoppen: Taak stoppen heeft geen parameter nodig, gebruiker kan de taak stoppen door de actie te selecteren.

Zodra de taak is gestopt, wordt de taakstatus in de portal gestopt.

Start: Met deze actie wordt de taak gestart vanaf 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.

Details van eigenschap:

Eigenschappen	Beschrijving	Verplicht
Args	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, wordt de taakstatus in de portal uitgevoerd.

Update: Bijwerken helpt bij het opnieuw opstarten 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 taak.

Zodra de taak is bijgewerkt, is de taakstatus in de portal actief.
Stateless update: deze taak is net als een update, maar het omvat een nieuwe herstart van de taak met de nieuwste code.

Sjabloon voor het bijwerken van de taak.

Details van eigenschap:

Eigenschappen Beschrijving Standaardwaarde Verplicht

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

Zodra de taak is bijgewerkt, wordt de taakstatus in de portal uitgevoerd.
Savepoint: Neem het savepoint voor de Flink Job.

Savepoint is tijdrovend proces en het duurt enige tijd. U kunt de status van de taakactie zien als wordt uitgevoerd.
Annuleren: met deze taak kan de gebruiker de taak beëindigen.
Verwijderen: taakgegevens verwijderen uit de portal.
Taakdetails weergeven: als u de gebruiker met taakdetails wilt weergeven, kunt u op de taaknaam klikken, maar worden de details van de taak en het laatste actieresultaat weergegeven.

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

Eigenschappen	Beschrijving	Standaardwaarde	Verplicht
Args	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-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 en stelt u in staat om uw Flink-cluster efficiënt te beheren.

Basis-URL-indeling voor Rest API

Zie de volgende URL voor rest API, gebruikers moeten abonnement, resourcegroep, clustergroep, clusternaam en HDInsight in deze AKS API-versie vervangen voordat ze deze 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 voor SP voor flink het cluster.
Meld u aan met de service-principal.

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

Verificatie met behulp van beheerde identiteit: gebruikers kunnen resources gebruiken die beheerde identiteit ondersteunen om aanroepen naar de REST API van de taak uit te voeren. Raadpleeg de documentatie voor beheerde identiteiten voor meer informatie.

LIJST met API's en parameters

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

Optie	Weergegeven als
Wijze	POSTEN
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"

Aanvraagbody:

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

Eigenschappen	Beschrijving	Standaardwaarde	Verplicht
jobType	Type taak. Het moet 'FlinkJob' zijn		Ja
jobName	Unieke naam voor taak. Dit wordt weergegeven in de portal. De taaknaam moet klein zijn.		Ja
action	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
jarName	Naam van taak-JAR.		Ja
entryClass	Invoerklasse voor taak waaruit de taakuitvoering wordt gestart.		Ja
argumenten	Argument voor het hoofdprogramma van de taak. Scheid argumenten met spatie.		Nee
Parallellisme	Job Flink Parallellisme.	2	Ja
savepoint.directory	Savepoint-map voor taak. 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	Weergegeven als
Wijze	POSTEN
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"

Hoofdtekst van aanvraag

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

Eigenschapsdetails voor JSON-hoofdtekst:

Eigenschappen	Beschrijving	Standaardwaarde
jobType	Type taak. Het moet 'FlinkJob' zijn	Ja
jobName	Taaknaam, die wordt gebruikt voor het starten van de taak	Ja
action	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	Weergegeven als
Wijze	POSTEN
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"

Hoofdtekst van aanvraag

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

Eigenschapsdetails voor JSON-hoofdtekst:

Eigenschappen	Beschrijving	Standaardwaarde
jobType	Type taak. Het moet 'FlinkJob' zijn	Ja
jobName	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
action	Het moet "START" zijn	Ja
savePointName	Sla de naam van het punt op om de taak te starten. Dit is een optionele eigenschap. Standaard wordt de beginbewerking voor het laatst geslaagd opgeslagen.	Nee

Voorbeeld:

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

Updatetaak: Rest API voor het bijwerken van de huidige actieve taak.

Optie	Weergegeven als
Wijze	POSTEN
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"

Hoofdtekst van aanvraag

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

Eigenschapsdetails voor JSON-hoofdtekst:

Eigenschappen	Beschrijving	Verplicht
jobType	Type taak. Het moet 'FlinkJob' zijn	Ja
jobName	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
action	Het moet altijd 'UPDATE' zijn voor het starten van nieuwe taken.	Ja
argumenten	JVM-argumenten voor taak	Nee
savePointName	Sla de naam van het punt op om de taak te starten. Het is een optionele eigenschap. De standaardbewerking voor het starten van de bewerking duurt het laatste geslaagde savepoint.	Nee

Voorbeeld:

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

Statusloze updatetaak: Rest API voor stateless update.

Optie	Weergegeven als
Wijze	POSTEN
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"

Hoofdtekst van aanvraag

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

Eigenschapsdetails voor JSON-hoofdtekst:

Eigenschappen	Beschrijving	Verplicht
jobType	Type taak. Het moet 'FlinkJob' zijn	Ja
jobName	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
action	Het moet altijd 'STATELESS_UPDATE' zijn voor het starten van nieuwe taken.	Ja
argumenten	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	Weergegeven als
Wijze	POSTEN
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"

Hoofdtekst van aanvraag

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

Eigenschapsdetails voor JSON-hoofdtekst:

Eigenschappen	Beschrijving	Verplicht
jobType	Type taak. Het moet 'FlinkJob' zijn	Ja
jobName	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
action	Het moet 'SAVEPOINT' zijn voor het starten van nieuwe taken.	Ja

Voorbeeld:

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

Savepoint weergeven: Rest API om alle savepoints weer te geven vanuit de savepoint-map.

Optie	Weergegeven als
Wijze	POSTEN
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"

Hoofdtekst van aanvraag

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

Eigenschapsdetails voor JSON-hoofdtekst:

Eigenschappen	Beschrijving	Verplicht
jobType	Type taak. Het moet 'FlinkJob' zijn	Ja
jobName	Taaknaam die wordt gebruikt voor het starten van de taak	Ja
action	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	Weergegeven als
Wijze	POSTEN
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"

Hoofdtekst van aanvraag

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

Eigenschapsdetails voor JSON-hoofdtekst:

Eigenschappen	Beschrijving	Verplicht
jobType	Type taak. Het zou moeten zijn `FlinkJob`	Ja
jobName	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
action	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	Weergegeven als
Wijze	POSTEN
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"

Hoofdtekst van aanvraag

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

Eigenschapsdetails voor JSON-hoofdtekst:

Eigenschappen	Beschrijving	Verplicht
jobType	Type taak. Het moet 'FlinkJob' zijn	Ja
jobName	Taaknaam die wordt gebruikt voor het starten van de taak.	Ja
action	Dit moet DELETE 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	Weergegeven als
Wijze	GET
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 deze aan met de waarde 'IN_PROGRESS' Bij geslaagde voltooiing wordt 'GESLAAGD' weergegeven en in het geval van een fout is het mislukt.

Verwijzing

Apache Flink Job Scheduling
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

Vergoedingen

Vereisten

Belangrijke functies en bewerkingen

Opties voor het beheren van taken in HDInsight in AKS

Taakbeheer vanuit Azure Portal

Taakbeheer met rest API

Basis-URL-indeling voor Rest API

Rest API-verificatie

LIJST met API's en parameters

Verwijzing

Feedback

Aanvullende resources