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

Článek
09/20/2024

Důležitý

Azure HDInsight v AKS byl vyřazen 31. ledna 2025. Zjistěte více pomocí tohoto oznámení.

Abyste se vyhnuli náhlému ukončení úloh, musíte migrovat úlohy do Microsoft Fabric nebo ekvivalentního produktu Azure.

Důležitý

Tato funkce je aktuálně ve verzi Preview. Doplňkové smluvní podmínky použití pro předběžné verze Microsoft Azure obsahují další právní podmínky, které se vztahují na funkce Azure, které jsou v beta verzi, ve verzi předběžného náhledu nebo ještě nebyly vydány v obecné dostupnosti. Informace o této konkrétní verzi Preview najdete v tématu Azure HDInsight ve 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 pro další aktualizace 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.

Výhody

zjednodušené správy úloh: Díky nativní integraci Apache Flinku na webu Azure Portal už uživatelé k odesílání, správě a monitorování úloh nevyžadují rozsáhlé znalosti clusterů Flink.
User-Friendly rozhraní REST API: HDInsight v AKS poskytuje uživatelsky přívětivá rozhraní ARM REST API 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: Použitím HDInsight na AKS mají uživatelé Flink přístup k uživatelsky přívětivému ARM REST API, což umožňuje bezproblémovou integraci operací ú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 úložišti účtu clusteru pro umístění JAR souboru dané ú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

Nové odeslání úlohy: Uživatelé mohou snadno odeslat novou úlohu do Flink, což eliminuje potřebu složitých konfigurací nebo externích nástrojů.
Zastavit a spustit úlohy z uložených bodů: Uživatelé můžou řádně zastavit a spustit své Flink úlohy z předchozího stavu (uložený bod). Ukládací body zajišťují zachování průběhu úlohy a umožňují bezproblémové obnovení.
Aktualizace úloh: Uživatel může aktualizovat běžící úlohu po aktualizaci souboru JAR na úložném účtu. 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ý restart pomocí aktualizovaného JAR souboru úlohy.
Správa savepointů: Uživatelé mohou v libovolném okamžiku vytvářet ukládací body pro své běžící ú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 nástroje pro správu úloh Flink.

Azure portal
rozhraní REST API ARM

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: Chcete-li odeslat novou úlohu, nahrajte soubory JAR úloh do účtu úložiště a vytvořte adresář savepointu. Dokončete šablonu s potřebnými konfiguracemi a pak úlohu odešlete.

podrobnosti o nemovitosti :

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 malými písmeny.		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
Vstupní kategorie	Třída entry pro úlohu, ze které se spouští provádění úlohy.		Ano
Argumenty	Argument pro hlavní program úlohy. Oddělte všechny argumenty mezerami.		Ne
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`	Ne

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

Zastavení: Zastavení procesu nevyžaduje žádný parametr, uživatel může proces zastavit výběrem akce.

Po ukončení úlohy bude stav úlohy na portálu ZASTAVENO.

Zahájení: Tato akce spustí úlohu z bodu uložení. 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í používá poslední úspěšný bod uložení.

podrobnosti o nemovitosti:

Nemovitost	Popis	Povinný
Argumenty	Argument pro hlavní program úlohy. Všechny argumenty by měly být oddělené mezerou.	Ne
Poslední bod uložení	Poslední úspěšné uložení bodu před zastavením úlohy. Použije se ve výchozím nastavení, pokud není vybrán žádný bod uložení.	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.	Ne

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

Update: Update 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 pomocí savepointu a znovu ji spustí s nejnovější verzí souboru JAR.

Šablona pro aktualizaci úlohy

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

Šablona pro aktualizaci úlohy

Podrobnosti o nemovitosti:

Vlastnost Popis Výchozí hodnota Povinný

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

Po aktualizaci úlohy je stav úlohy na portálu nastaven na PROBÍHÁ.
Savepoint: Vytvořte savepoint 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: Odstranit data úlohy z portálu.
Zobrazit podrobnosti úlohy: Uživatel si může zobrazit podrobnosti úlohy kliknutím na název úlohy, což zobrazuje podrobnosti o úloze a výsledku poslední 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ý
Argumenty	Argument pro hlavní program úlohy. Oddělte všechny argumenty mezerou.		Ne

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

Podívejte se na následující 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í AKS API. 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 služební účet.

az ad sp create-for-rbac --name <your-SP-name>
Udělte oprávnění vlastníka SP do clusteru flink.
Přihlaste se pomocí objektu služby.

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í rozhraní REST API úlohy. Další podrobnosti najdete v dokumentaci k Managed Identity.

SEZNAM rozhraní API a parametrů

Nová úloha: 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}}`
Záhlaví	Autorizace = "Bearer $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 vlastnostech pro JSON text:

Vlastnost	Popis	Výchozí hodnota	Povinný
typ práce	Typ úlohy. Mělo by to být FlinkJob.		Ano
název úlohy	Jedinečný název úlohy Zobrazí se na portálu. Název práce by měl být malými písmeny.		Ano
akce	Označuje typ operace při práci. Mělo by být vždy uvedeno „NEW“ 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	Vstupní třída pro úlohu, ze které začíná provádění úlohy.		Ano
args	Argument pro hlavní program úlohy. Oddělte argumenty mezerou.		Ne
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`	Ne

Příklad:

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

zastavit úlohu: rozhraní 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}}`
Záhlaví	Autorizace = "Bearer $token"

text požadavku

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

Podrobnosti vlastností pro JSON tělo:

Vlastnost	Popis	Výchozí hodnota
typ práce	Typ úlohy. Mělo by to být FlinkJob.	Ano
název úlohy	Název úlohy, který se používá ke spuštění úlohy	Ano
akce	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"

spustit úlohu: rozhraní REST API ke spuštění zastavené ú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}}`
Záhlaví	Autorizace = "Bearer $token"

text požadavku

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

Podrobnosti o vlastnostech pro JSON text:

Vlastnost	Popis	Výchozí hodnota
typ práce	Typ úlohy. Mělo by to být FlinkJob.	Ano
názevÚlohy	Název úlohy, který se používá ke spuštění úlohy.	Ano
akce	Mělo by to být „START“.	Ano
savePointName	Uložte název bodu pro spuštění úlohy. Tato vlastnost je volitelná, ve výchozím nastavení počáteční operace využije poslední úspěšný savepoint.	Ne

Příklad :

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

Aktualizační úloha: REST API pro aktualizaci aktuální spuštěné úlohy.

Možnost	Hodnota
Metoda	Příspěvek
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}}`
Záhlaví	Autorizace = "Bearer $token"

text požadavku

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

Podrobnosti o vlastnosti pro JSON tělo:

Vlastnost	Popis	Povinný
typ práce	Typ úlohy. Mělo by to být FlinkJob.	Ano
název úlohy	Název úlohy, který se používá ke spuštění úlohy.	Ano
akce	Pro spuštění nové úlohy by mělo být vždy použito „UPDATE“.	Ano
args	Argumenty JVM úlohy	Ne
název uloženého bodu	Uložte název bodu pro spuštění úlohy. Jedná se o volitelnou vlastnost, ve výchozím nastavení použije počáteční operace poslední úspěšný stav.	Ne

Příklad:

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

Bezstavová úloha aktualizace: 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}}`
Záhlaví	Autorizace = "Bearer $token"

text požadavku

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

podrobnosti o vlastnosti textu JSON:

Vlastnost	Popis	Povinný
typ práce	Typ úlohy. Mělo by to být FlinkJob.	Ano
název úlohy	Název úlohy, který se používá ke spuštění úlohy.	Ano
akce	Mělo by to být vždy „STATELESS_UPDATE“ pro zahájení nové úlohy.	Ano
args	Argumenty JVM úlohy	Ne

Příklad :

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

Savepoint: REST API pro spuštění savepointu pro úlohu.

Možnost	Hodnota
Metoda	Příspěvek
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}}`
Záhlaví	Autorizace = "Bearer $token"

text požadavku

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

podrobnosti o vlastnosti textu JSON:

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

Příklad :

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

List savepoint: rest API k výpisu všech bodů uložení z adresáře savepoint.

Možnost	Hodnota
Metoda	Příspěvek
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}}`
Záhlaví	Autorizace = "Bearer $token"

text požadavku

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

Detaily vlastnosti pro tělo JSON:

Vlastnost	Popis	Povinný
typ práce	Typ úlohy. Mělo by to být FlinkJob.	Ano
název práce	Název úlohy, který se používá ke spuštění úlohy	Ano
akce	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: rozhraní REST API ke 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}}`
Záhlaví	Autorizace = "Bearer $token"

text požadavku

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

podrobnosti o vlastnosti textu JSON:

Vlastnost	Popis	Povinný
typ práce	Typ úlohy. Mělo by to být `FlinkJob`	Ano
název úlohy	Název úlohy, který se používá ke spuštění úlohy.	Ano
akce	Mělo by to být zrušeno.	Ano

Příklad :

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

Odstranit: REST API pro smazá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}}`
Záhlaví	Autorizace = "Bearer $token"

text požadavku

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

Podrobnosti o vlastnostech pro JSON text:

Vlastnost	Popis	Povinný
typ práce	Typ úlohy. Mělo by to být FlinkJob.	Ano
název úlohy	Název úlohy, který se používá ke spuštění úlohy.	Ano
akce	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"

Výpis úloh: rozhraní REST API pro výpis všech úloh a stavu aktuální akce.

Možnost	Hodnota
Metoda	DOSTAT
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}}`
Záhlaví	Autorizace = "Bearer $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.

Odkaz

Plánování úloh Apache Flink
Názvy Apache, Apache Flink, Flink a přidružených open-source 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

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ů

Odkaz

Další materiály