Správa úloh Apache Flink® ve službě HDInsight v clusterech AKS

Článek
09/20/2024

Poznámka:

Azure HDInsight vyřadíme ze služby AKS 31. ledna 2025. Před 31. lednem 2025 budete muset migrovat úlohy do Microsoft Fabric nebo ekvivalentního produktu Azure, abyste se vyhnuli náhlému ukončení úloh. Zbývající clustery ve vašem předplatném se zastaví a odeberou z hostitele.

Do data vyřazení bude k dispozici pouze základní podpora.

Důležité

Tato funkce je aktuálně dostupná jako ukázková verze. Doplňkové podmínky použití pro Microsoft Azure Preview obsahují další právní podmínky, které se vztahují na funkce Azure, které jsou v beta verzi, ve verzi Preview nebo ještě nejsou vydány v obecné dostupnosti. Informace o této konkrétní verzi Preview najdete v tématu Azure HDInsight o službě AKS ve verzi Preview. Pokud máte dotazy nebo návrhy funkcí, odešlete prosím žádost na AskHDInsight s podrobnostmi a sledujte nás o dalších aktualizacích v komunitě Azure HDInsight.

HDInsight v AKS poskytuje funkci pro správu a odesílání úloh Apache Flink® přímo prostřednictvím webu Azure Portal (uživatelsky přívětivé rozhraní) a rozhraní REST API ARM.

Tato funkce umožňuje uživatelům efektivně řídit a monitorovat úlohy Apache Flink bez nutnosti hlubších znalostí na úrovni clusteru.

Zaměstnanecké výhody

Zjednodušená správa úloh: Díky nativní integraci Apache Flinku na webu Azure Portal už uživatelé nevyžadují rozsáhlé znalosti clusterů Flink k odesílání, správě a monitorování úloh.
Uživatelsky přívětivé rozhraní REST API: HDInsight v AKS poskytuje uživatelsky přívětivá rozhraní REST API ARM pro odesílání a správu úloh Flink. Uživatelé mohou odesílat úlohy Flink z libovolné služby Azure pomocí těchto rozhraní REST API.
Snadné aktualizace úloh a správa stavu: Nativní integrace webu Azure Portal poskytuje bezproblémové prostředí pro aktualizaci úloh a jejich obnovení do posledního uloženého stavu (savepoint). Tato funkce zajišťuje kontinuitu a integritu dat v průběhu životního cyklu úlohy.
Automatizace úlohy Flink pomocí kanálu Azure: Pomocí SLUŽBY HDInsight v AKS mají uživatelé Flink přístup k uživatelsky přívětivým rozhraním REST API ARM, můžete bezproblémově integrovat operace úloh Flink do kanálu Azure. Bez ohledu na to, jestli spouštíte nové úlohy, aktualizujete spuštěné úlohy nebo provádíte různé operace úloh, tento zjednodušený přístup eliminuje ruční kroky. Umožňuje efektivní správu clusteru Flink.

Požadavky

Před odesláním a správou úloh z portálu nebo rozhraní REST API existují některé požadavky.

Vytvořte adresář v primárním účtu úložiště clusteru pro nahrání souboru JAR úlohy.
Pokud chce uživatel uložit body, vytvořte adresář v účtu úložiště pro body ukládání úloh.

Klíčové funkce a operace

Odeslání nové úlohy: Uživatelé můžou snadno odeslat nový Flink, což eliminuje potřebu složitých konfigurací nebo externích nástrojů.
Zastavte a spusťte úlohy pomocí bodů ukládání: Uživatelé mohou řádně zastavit a spustit úlohy Flink z předchozího stavu (Uložit bod). Body ukládání zajišťují zachování průběhu úlohy a umožňují bezproblémové obnovení.
Aktualizace úloh: Uživatel může aktualizovat spuštěnou úlohu po aktualizaci souboru JAR v účtu úložiště. Tato aktualizace automaticky převezme bod uložení a spustí úlohu s novým souborem JAR.
Bezstavové aktualizace: Provádění nového restartování úlohy je zjednodušeno prostřednictvím bezstavových aktualizací. Tato funkce umožňuje uživatelům zahájit čisté restartování pomocí aktualizovaného souboru JAR úlohy.
Správa služby SavePoint: V libovolném okamžiku můžou uživatelé vytvářet body ukládání pro své spuštěné úlohy. Tyto body ukládání je možné uvést a použít k restartování úlohy z konkrétního kontrolního bodu podle potřeby.
Zrušit: Tím se úloha trvale zruší.
Odstranit: Odstranit záznam historie úloh.

Možnosti správy úloh ve službě HDInsight v AKS

HDInsight v AKS poskytuje způsoby správy úloh Flink.

Azure Portal
ARM Rest API

Správa úloh z webu Azure Portal

Pokud chcete spustit úlohu Flink z portálu, přejděte na:

Portál –> HDInsight ve fondu clusterů AKS –> Cluster Flink –> Nastavení –> Úlohy Flink

Nová úloha: Pokud chcete odeslat novou úlohu, nahrajte soubory JAR úloh do účtu úložiště a vytvořte adresář uložit. Dokončete šablonu s potřebnými konfiguracemi a pak úlohu odešlete.

Podrobnosti o vlastnosti:

Vlastnost	Popis	Výchozí hodnota	Povinné
Název úlohy	Jedinečný název úlohy Zobrazí se na portálu. Název úlohy by měl být v malém počtu.		Ano
Cesta JAR	Cesta k úložišti pro soubor JAR úlohy Uživatelé by měli vytvořit adresář v úložišti clusteru a nahrát soubor JAR úlohy.	Ano
Entry – třída	Třída entry pro úlohu, ze které se spouští provádění úlohy.		Ano
Args	Argument pro hlavní program úlohy. Oddělte všechny argumenty mezerami.		No
rovnoběžnost	Paralelismus úlohy Flink.	2	Ano
savepoint.directory	Uložit adresář pro úlohu. Doporučuje se, aby uživatelé vytvořili nový adresář pro uložení úlohy v účtu úložiště.	`abfs://<container>@<account>/<deployment-ID>/savepoints`	No

Po spuštění úlohy se stav úlohy na portálu spustí.

Stop: Zastavení úlohy nepožadovalo žádný parametr, uživatel může úlohu zastavit výběrem akce.

Po zastavení úlohy se stav úlohy na portálu zastaví.

Zahájení: Tato akce spustí úlohu z aplikace SavePoint. Pokud chcete úlohu spustit, vyberte zastavenou úlohu a spusťte ji.

Vyplňte šablonu toku požadovanými možnostmi a spusťte ji. Uživatelé musí vybrat bod uložení, ze kterého chce uživatel úlohu spustit. Ve výchozím nastavení trvá poslední úspěšný bod uložení.

Podrobnosti o vlastnosti:

Vlastnost	Popis	Povinné
Args	Argument pro hlavní program úlohy. Všechny argumenty by měly být oddělené mezerou.	No
Poslední bod uložení	Poslední úspěšné uložení bodu před zastavením úlohy. Tato možnost se použije ve výchozím nastavení, pokud není vybrána možnost uložit bod.	Nelze upravit.
Uložit název bodu	Uživatelé můžou zobrazit seznam dostupných bodů ukládání pro úlohu a vybrat jeden z nich, aby mohli úlohu spustit.	No

Po spuštění úlohy bude stav úlohy na portálu SPUŠTĚNÝ.

Aktualizace: Aktualizace pomáhá restartovat úlohy s aktualizovaným kódem úlohy. Uživatelé musí aktualizovat nejnovější soubor JAR úlohy v umístění úložiště a aktualizovat úlohu z portálu. Tato aktualizace zastaví úlohu s savepointem a spustí se znovu s nejnovějším souborem JAR.

Šablona pro aktualizaci úlohy

Jakmile se úloha aktualizuje, stav úlohy na portálu je SPUŠTĚNÝ.
Bezstavová aktualizace: Tato úloha se podobá aktualizaci, ale zahrnuje nové restartování úlohy s nejnovějším kódem.

Šablona pro aktualizaci úlohy

Podrobnosti o vlastnosti:

Vlastnost Popis Výchozí hodnota Povinné

Args Argument pro hlavní program úlohy. Oddělte všechny argumenty mezerou. No

Po aktualizaci úlohy se stav úlohy na portálu spustí.
Savepoint: Převezměte bod uložení pro úlohu Flink.

Savepoint je časově náročný proces a nějakou dobu trvá. Stav akce úlohy můžete zobrazit jako probíhající.
Zrušit: Tato úloha pomáhá uživateli ukončit úlohu.
Odstranit: Odstraňte data úlohy z portálu.
Zobrazit podrobnosti o úloze: Uživatel podrobností úlohy může kliknout na název úlohy, zobrazí podrobnosti o úloze a posledním výsledku akce.

V případě jakékoli neúspěšné akce poskytne json této úlohy podrobné výjimky a důvody selhání.

Vlastnost	Popis	Výchozí hodnota	Povinné
Args	Argument pro hlavní program úlohy. Oddělte všechny argumenty mezerou.		No

Správa úloh pomocí rozhraní REST API

HDInsight v AKS podporuje uživatelsky přívětivá rozhraní REST API ARM k odesílání úloh a správě úloh. Pomocí tohoto rozhraní Flink REST API můžete bezproblémově integrovat operace úloh Flink do kanálu Azure. Ať už spouštíte nové úlohy, aktualizujete spuštěné úlohy nebo provádíte různé operace úloh, tento zjednodušený přístup eliminuje ruční kroky a umožňuje efektivní správu clusteru Flink.

Formát základní adresy URL pro rozhraní REST API

Viz následující adresa URL pro rozhraní REST API, uživatelé musí před použitím nahradit předplatné, skupinu prostředků, fond clusteru, název clusteru a HDInsight ve verzi rozhraní API AKS. 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}}

Pomocí tohoto rozhraní REST API můžou uživatelé iniciovat nové úlohy, zastavit úlohy, spustit úlohy, vytvářet body ukládání, rušit úlohy a odstraňovat úlohy. Aktuální API_VERSION je 2023-06-01-preview.

Ověřování rozhraní REST API

Pokud chcete ověřit uživatele rozhraní REST API Flink, potřebujete získat nosný token nebo přístupový token pro prostředek ARM. Pokud chcete ověřit rozhraní REST API Azure ARM (Azure Resource Manager) pomocí instančního objektu, můžete postupovat podle těchto obecných kroků:

Vytvořte instanční objekt.

az ad sp create-for-rbac --name <your-SP-name>
Udělení oprávnění vlastníka sp pro flink cluster.
Přihlaste se pomocí instančního objektu.

az login --service-principal -u <client_id> -p <client_secret> --tenant <tenant_id>
Získání přístupového tokenu

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

$tok = $token.accesstoken

Uživatelé můžou použít token v zobrazené adrese URL.

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

Ověřování pomocí spravované identity: Uživatelé můžou využívat prostředky, které podporují spravovanou identitu k volání do rozhraní REST API úlohy. Další podrobnosti najdete v dokumentaci ke spravované identitě .

SEZNAM rozhraní API a parametrů

Nová úloha: Rozhraní REST API pro odeslání nové úlohy do Flinku

Možnost	Hodnota
metoda	POST
Adresa 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}}`
Hlavička	Autorizace = "Nosný $token"

Text požadavku:

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

Podrobnosti o vlastnosti pro text JSON:

Vlastnost	Popis	Výchozí hodnota	Povinné
jobType	Typ úlohy. Mělo by to být FlinkJob.		Ano
jobName	Jedinečný název úlohy Zobrazí se na portálu. Název úlohy by měl být v malém počtu.		Ano
action	Označuje typ operace v úloze. Měla by být vždy nová pro spuštění nové úlohy.		Ano
jobJarDirectory	Cesta k úložišti pro adresář jar úlohy. Uživatelé by měli vytvořit adresář v úložišti clusteru a nahrát soubor JAR úlohy.	Ano
jarName	Název souboru JAR úlohy.		Ano
entryClass	Třída entry pro úlohu, ze které se spouští provádění úlohy.		Ano
args	Argument pro hlavní program úlohy. Oddělte argumenty mezerou.		No
rovnoběžnost	Paralelismus úlohy Flink.	2	Ano
savepoint.directory	Uložit adresář pro úlohu. Doporučuje se, aby uživatelé vytvořili nový adresář pro uložení úlohy v účtu úložiště.	`abfs://<container>@<account>/<deployment-ID>/savepoints`	No

Příklad:

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

Zastavit úlohu: Rest API pro zastavení aktuální spuštěné úlohy.

Možnost	Hodnota
metoda	POST
Adresa 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}}`
Hlavička	Autorizace = "Nosný $token"

Text požadavku

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

Podrobnosti o vlastnosti pro text JSON:

Vlastnost	Popis	Výchozí hodnota
jobType	Typ úlohy. Mělo by to být FlinkJob.	Ano
jobName	Název úlohy, který se používá ke spuštění úlohy	Ano
action	Mělo by to být STOP.	Ano

Příklad:

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

Spouštěcí úloha: Rozhraní REST API pro spuštění úlohy ZASTAVENO.

Možnost	Hodnota
metoda	POST
Adresa 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}}`
Hlavička	Autorizace = "Nosný $token"

Text požadavku

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

Podrobnosti o vlastnosti pro text JSON:

Vlastnost	Popis	Výchozí hodnota
jobType	Typ úlohy. Mělo by to být FlinkJob.	Ano
jobName	Název úlohy, který se používá ke spuštění úlohy.	Ano
action	Mělo by to být START.	Ano
savePointName	Uložte název bodu pro spuštění úlohy. Je to volitelná vlastnost, ve výchozím nastavení počáteční operace trvá poslední úspěšný savepoint.	No

Příklad:

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

Úloha aktualizace: Rozhraní REST API pro aktualizaci aktuální spuštěné úlohy.

Možnost	Hodnota
metoda	POST
Adresa 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}}`
Hlavička	Autorizace = "Nosný $token"

Text požadavku

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

Podrobnosti o vlastnosti pro text JSON:

Vlastnost	Popis	Povinné
jobType	Typ úlohy. Mělo by to být FlinkJob.	Ano
jobName	Název úlohy, který se používá ke spuštění úlohy.	Ano
action	Pro spuštění nové úlohy by měla být vždy "UPDATE".	Ano
args	Argumenty JVM úlohy	No
savePointName	Uložte název bodu pro spuštění úlohy. Jedná se o volitelnou vlastnost, ve výchozím nastavení bude počáteční operace trvat poslední úspěšný savepoint.	No

Příklad:

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

Úloha bezstavové aktualizace: Rozhraní REST API pro bezstavovou aktualizaci

Možnost	Hodnota
metoda	POST
Adresa 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}}`
Hlavička	Autorizace = "Nosný $token"

Text požadavku

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

Podrobnosti o vlastnosti pro text JSON:

Vlastnost	Popis	Povinné
jobType	Typ úlohy. Mělo by to být FlinkJob.	Ano
jobName	Název úlohy, který se používá ke spuštění úlohy.	Ano
action	Měla by být vždy STATELESS_UPDATE pro spuštění nové úlohy.	Ano
args	Argumenty JVM úlohy	No

Příklad:

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

Savepoint: Rozhraní REST API pro aktivaci bodu ukládání pro úlohu.

Možnost	Hodnota
metoda	POST
Adresa 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}}`
Hlavička	Autorizace = "Nosný $token"

Text požadavku

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

Podrobnosti o vlastnosti pro text JSON:

Vlastnost	Popis	Povinné
jobType	Typ úlohy. Mělo by to být FlinkJob.	Ano
jobName	Název úlohy, který se používá ke spuštění úlohy.	Ano
action	Pro spuštění nové úlohy by měl být vždy "SAVEPOINT".	Ano

Příklad:

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

Uložit bod seznamu: Rozhraní REST API pro výpis všech bodů uložení z adresáře savepoint.

Možnost	Hodnota
metoda	POST
Adresa 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}}`
Hlavička	Autorizace = "Nosný $token"

Text požadavku

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

Podrobnosti o vlastnosti pro text JSON:

Vlastnost	Popis	Povinné
jobType	Typ úlohy. Mělo by to být FlinkJob.	Ano
jobName	Název úlohy, který se používá ke spuštění úlohy	Ano
action	Mělo by to být "LIST_SAVEPOINT"	Ano

Příklad:

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

Zrušit: Rest API pro zrušení úlohy.

Možnost	Hodnota
metoda	POST
Adresa 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}}`
Hlavička	Autorizace = "Nosný $token"

Text požadavku

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

Podrobnosti o vlastnosti pro text JSON:

Vlastnost	Popis	Povinné
jobType	Typ úlohy. Mělo by to být `FlinkJob`	Ano
jobName	Název úlohy, který se používá ke spuštění úlohy.	Ano
action	Mělo by to být CANCEL.	Ano

Příklad:

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

Odstranit: Rozhraní REST API pro odstranění úlohy.

Možnost	Hodnota
metoda	POST
Adresa 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}}`
Hlavička	Autorizace = "Nosný $token"

Text požadavku

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

Podrobnosti o vlastnosti pro text JSON:

Vlastnost	Popis	Povinné
jobType	Typ úlohy. Mělo by to být FlinkJob.	Ano
jobName	Název úlohy, který se používá ke spuštění úlohy.	Ano
action	Mělo by to být DELETE.	Ano

Příklad:

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

Úlohy seznamu: Rozhraní REST API pro výpis všech úloh a stavu aktuální akce.

Možnost	Hodnota
metoda	GET
Adresa 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}}`
Hlavička	Autorizace = "Nosný $token"

Výstup:

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

Poznámka:

Když nějaká akce probíhá, actionResult ji označí hodnotou "IN_PROGRESS" Při úspěšném dokončení se zobrazí "ÚSPĚCH" a v případě selhání se zobrazí hodnota FAILED.

Reference

Plánování úloh Apache Flink
Názvy apache, Apache Flink, Flink a přidružených opensourcových projektů jsou ochranné známky Apache Software Foundation (ASF).

Sdílet prostřednictvím

Správa úloh Apache Flink® ve službě HDInsight v clusterech AKS

Zaměstnanecké výhody

Požadavky

Klíčové funkce a operace

Možnosti správy úloh ve službě HDInsight v AKS

Správa úloh z webu Azure Portal

Správa úloh pomocí rozhraní REST API

Formát základní adresy URL pro rozhraní REST API

Ověřování rozhraní REST API

SEZNAM rozhraní API a parametrů

Reference

Váš názor

Další materiály