Apache Flink-feladatkezelés® a HDInsightban AKS-fürtökön

Cikk
04/05/2024

Fontos

Ez a szolgáltatás jelenleg előzetes kiadásban elérhető. A Microsoft Azure Előzetes verzió kiegészítő használati feltételei további jogi feltételeket tartalmaznak, amelyek a bétaverzióban, előzetes verzióban vagy egyébként még nem általánosan elérhető Azure-funkciókra vonatkoznak. Erről az adott előzetes verzióról az Azure HDInsight az AKS előzetes verziójában tájékozódhat. Ha kérdése vagy funkciójavaslata van, küldjön egy kérést az AskHDInsightban a részletekkel együtt, és kövessen minket további frissítésekért az Azure HDInsight-közösségről.

Az AKS HDInsight szolgáltatása lehetővé teszi az Apache Flink-feladatok® kezelését és elküldését közvetlenül az Azure Portalon (felhasználóbarát felületen) és az ARM Rest API-kon keresztül.

Ez a funkció lehetővé teszi, hogy a felhasználók hatékonyan vezérelhessék és monitorozzák Apache Flink-feladataikat anélkül, hogy mély fürtszintű ismeretekre van szükségük.

Juttatások

Egyszerűsített feladatkezelés: Az Apache Flink Azure Portalon való natív integrációjával a felhasználók már nem igényelnek átfogó ismereteket az Flink-fürtökről a feladatok elküldéséhez, kezeléséhez és monitorozásához.
Felhasználóbarát REST API: Az AKS HDInsightja felhasználóbarát ARM Rest API-kat biztosít az Flink-feladatok elküldéséhez és kezeléséhez. A felhasználók bármely Azure-szolgáltatásból küldhetnek Flink-feladatokat ezen Rest API-k használatával.
Egyszerű feladatfrissítések és állapotkezelés: A natív Azure Portal-integráció zökkenőmentes felületet biztosít a feladatok frissítéséhez és az utolsó mentett állapotba (savepoint) való visszaállításához. Ez a funkció biztosítja a folyamatosságot és az adatintegritást a feladat teljes életciklusa során.
Flink-feladat automatizálása az Azure-folyamattal: A HDInsight AKS-en való használatával az Flink-felhasználók hozzáférhetnek a felhasználóbarát ARM Rest API-hoz, zökkenőmentesen integrálhatja a Flink-feladatműveleteket az Azure Pipeline-ba. Akár új feladatokat indít, akár futó feladatokat frissít, akár különböző feladatműveleteket hajt végre, ez az egyszerűsített módszer kiküszöböli a manuális lépéseket. Lehetővé teszi az Flink-fürt hatékony kezelését.

Előfeltételek

A feladatok portálról vagy Rest API-ból való elküldése és kezelése előtt vannak előfeltételek.

Hozzon létre egy könyvtárat a fürt elsődleges tárfiókjában a feladat jar feltöltéséhez.
Ha a felhasználó menteni szeretné a mentési pontokat, hozzon létre egy könyvtárat a tárfiókban a feladatmentési pontokhoz.

Főbb funkciók és műveletek

Új feladatbeküldés: A felhasználók könnyedén küldhetnek be egy új Flinket, így nincs szükség összetett konfigurációkra vagy külső eszközökre.
Feladatok leállítása és indítása mentési pontokkal: A felhasználók kecsesen állíthatják le és indíthatják el a Flink-feladatokat az előző állapotukból (Savepoint). A mentési pontok biztosítják a feladatok előrehaladásának megőrzését, ami zökkenőmentes újraküldést tesz lehetővé.
Feladatfrissítések: A felhasználó a tárfiók jarjának frissítése után frissítheti a futó feladatot. Ez a frissítés automatikusan átveszi a mentési pontot, és elindítja a feladatot egy új jar használatával.
Állapot nélküli frissítések: A feladatok új újraindításának végrehajtása állapot nélküli frissítésekkel egyszerűsítve történik. Ez a funkció lehetővé teszi, hogy a felhasználók tiszta újraindítást kezdeményezhessenek a frissített feladat jar használatával.
Mentési pontok kezelése: A felhasználók bármikor létrehozhatnak mentési pontokat a futó feladataikhoz. Ezek a mentési pontok listázhatók, és szükség szerint újraindulhatnak a feladat egy adott ellenőrzőpontról.
Megszakítás: Ez véglegesen megszakítja a feladatot.
Törlés: Feladatelőzményrekord törlése.

Feladatok kezelésének lehetőségei a HDInsightban az AKS-en

Az AKS-en futó HDInsight módot kínál az Flink-feladatok kezelésére.

Azure Portalra
ARM Rest API

Feladatkezelés az Azure Portalról

A Flink-feladat portálról való futtatásához lépjen a következőre:

Portál –-> HDInsight az AKS-fürtkészleten –-> Flink-fürt --> Gépház --> Flink-feladatok

Új feladat: Új feladat beküldéséhez töltse fel a feladat jarokat a tárfiókba, és hozzon létre egy SavePoint-címtárat. Töltse ki a sablont a szükséges konfigurációkkal, majd küldje el a feladatot.

Tulajdonság részletei:

Tulajdonság	Leírás	Alapértelmezett érték	Kötelező
Feladat neve	A feladat egyedi neve. Ez megjelenik a portálon. A feladat nevének kis méretűnek kell lennie.		Igen
Jar elérési útja	A feladat jar tárolási útvonala. A felhasználóknak címtárat kell létrehozniuk a fürttárolóban, és fel kell tölteni a feladat jart.	Igen
Belépési osztály	A feladat belépési osztálya, amelyből a feladat végrehajtása elindul.		Igen
Arg	A feladat fő programjának argumentuma. Az összes argumentumot szóközökkel elválasztja.		Nem
Párhuzamosság	Feladat flink párhuzamossága.	2	Igen
savepoint.directory	Mentési könyvtár feladathoz. Javasoljuk, hogy a felhasználók hozzon létre egy új könyvtárat a tárfiókban található feladat mentési ponthoz.	`abfs://<container>@<account>/<deployment-ID>/savepoints`	Nem

A feladat elindítása után a portálon futó feladat állapota FUT.

Leállítás: A feladat leállítása nem igényel paramétert, a felhasználó a művelet kiválasztásával leállíthatja a feladatot.

A feladat leállítása után a portálon a feladat állapota LEÁLL.

Kezdés: Ez a művelet elindítja a feladatot a SavePointból. A feladat elindításához válassza ki a leállított feladatot, és indítsa el.

Töltse ki a folyamatsablont a szükséges beállításokkal, és indítsa el. A felhasználóknak ki kell választaniuk azt a mentési pontot, amelyből a felhasználó el szeretné indítani a feladatot. Alapértelmezés szerint az utolsó sikeres mentési pontot használja.

Tulajdonság részletei:

Tulajdonság	Leírás	Kötelező
Arg	A feladat fő programjának argumentuma. Minden argumentumot szóközzel kell elválasztani.	Nem
Utolsó mentési pont	A feladat leállítása előtt az utolsó sikeres mentési pont. Alapértelmezés szerint ezt fogja használni, ha nincs kiválasztva a SavePoint.	Nem szerkeszthető
Mentési pont neve	A felhasználók listázhatják a feladathoz elérhető mentési pontot, és kiválaszthatnak egyet a feladat elindításához.	Nem

A feladat elindítása után a feladat állapota a portálon FUT.

Frissítés: A frissítés segít újraindítani a feladatokat a frissített feladatkóddal. A felhasználóknak frissítenie kell a legújabb feladat jar-t a tárolóhelyen, és frissítenie kell a feladatot a portálról. Ez a frissítés leállítja a feladatot a SavePointtal, és a legújabb jar használatával indul újra.

Sablon a feladat frissítéséhez.

A feladat frissítése után a portálon a feladat állapota "FUT" lesz.
Állapot nélküli frissítés: Ez a feladat olyan, mint egy frissítés, de a feladat új újraindítását igényli a legújabb kóddal.

Sablon a feladat frissítéséhez.

Tulajdonság részletei:

Tulajdonság Leírás Alapértelmezett érték Kötelező

Arg A feladat fő programjának argumentuma. Az összes argumentumot szóközzel elválasztja. Nem

A feladat frissítése után a feladat állapota a portálon FUT.
Savepoint: A Flink-feladat mentési pontjának használata.

A Savepoint időigényes folyamat, és időbe telik. A feladatművelet állapota folyamatban van.
Megszakítás: Ez a feladat segít a felhasználónak a feladat leállításában.
Törlés: Feladatadatok törlése a portálról.
Feladat részleteinek megtekintése: A feladat részleteinek megtekintéséhez a felhasználó rákattinthat a feladat nevére, és megadja a feladat részleteit és az utolsó művelet eredményét.

Minden sikertelen művelet esetén ez a feladat json részletes kivételeket és a hiba okait ismerteti.

Tulajdonság	Leírás	Alapértelmezett érték	Kötelező
Arg	A feladat fő programjának argumentuma. Az összes argumentumot szóközzel elválasztja.		Nem

Feladatkezelés Rest API használatával

Az AKS-en futó HDInsight támogatja a felhasználóbarát ARM Rest API-kat a feladatok elküldéséhez és a feladatok kezeléséhez. Ezzel a Flink REST API-val zökkenőmentesen integrálhatja a Flink-feladatműveleteket az Azure Pipeline-ba. Akár új feladatokat indít, akár futó feladatokat frissít, akár különböző feladatműveleteket hajt végre, ez az egyszerűsített megközelítés kiküszöböli a manuális lépéseket, és lehetővé teszi az Flink-fürt hatékony kezelését.

Alap URL-formátum a Rest API-hoz

A rest API következő URL-címét itt tekintheti meg. A használat előtt a felhasználóknak az előfizetést, az erőforráscsoportot, a fürtkészletet, a fürt nevét és a HDInsightot kell lecserélniük az AKS API-verzióra. 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}}

Ezzel a REST API-val a felhasználók új feladatokat kezdeményezhetnek, feladatokat állíthatnak le, feladatokat indíthatnak, mentési pontokat hozhatnak létre, feladatokat mondhatnak le és törölhetnek. A jelenlegi API_VERSION 2023-06-01-preview.

Rest API-hitelesítés

Az Flink ARM Rest API-felhasználók hitelesítéséhez le kell kérnie az ARM-erőforrás tulajdonosi jogkivonatát vagy hozzáférési jogkivonatát. Az Azure ARM (Azure Resource Manager) REST API szolgáltatásnévvel történő hitelesítéséhez kövesse az alábbi általános lépéseket:

Hozzon létre egy szolgáltatásnevet.

az ad sp create-for-rbac --name <your-SP-name>
Adjon tulajdonosi engedélyt a fürt sp-jének flink .
Bejelentkezés szolgáltatásnévvel.

az login --service-principal -u <client_id> -p <client_secret> --tenant <tenant_id>
Hozzáférési jogkivonat lekérése.

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

$tok = $token.accesstoken

A felhasználók jogkivonatot használhatnak a megjelenített URL-címben.

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

Hitelesítés felügyelt identitással: A felhasználók olyan erőforrásokat használhatnak, amelyek támogatják a felügyelt identitást a feladat REST API-jának hívásához. További részletekért tekintse meg a Managed Identity dokumentációját.

API-k és paraméterek listája

Új feladat: Rest API az új feladat Flinkbe való elküldéséhez.

Lehetőség	Érték
Metódus	POST
URL-cím	`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}}`
Fejléc	Engedélyezés = "Tulajdonosi $token"

Kérelem törzse:

{ 
    "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-törzs tulajdonságadatai:

Tulajdonság	Leírás	Alapértelmezett érték	Kötelező
jobType	Feladat típusa. Ennek "FlinkJob" kell lennie		Igen
jobName	A feladat egyedi neve. Ez megjelenik a portálon. A feladat nevének kis méretűnek kell lennie.		Igen
művelet	A feladat művelettípusát jelzi. Mindig "ÚJ"-nak kell lennie az új feladatok indításához.		Igen
jobJarDirectory	A feladat jar könyvtárának tárolási elérési útja. A felhasználóknak címtárat kell létrehozniuk a fürttárolóban, és fel kell tölteni a feladat jart.	Igen
jarName	Feladat jar neve.		Igen
entryClass	A feladat belépési osztálya, amelyből a feladat végrehajtása elindul.		Igen
args	A feladat fő programjának argumentuma. Elválasztja az argumentumokat szóközzel.		Nem
Párhuzamosság	Feladat flink párhuzamossága.	2	Igen
savepoint.directory	Mentési könyvtár feladathoz. Javasoljuk, hogy a felhasználók hozzon létre egy új könyvtárat a tárfiókban található feladat mentési ponthoz.	`abfs://<container>@<account>/<deployment-ID>/savepoints`	Nem

Példa:

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

Feladat leállítása: Rest API az aktuális futó feladat leállításához.

Lehetőség	Érték
Metódus	POST
URL-cím	`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}}`
Fejléc	Engedélyezés = "Tulajdonosi $token"

Kérelem törzse

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

JSON-törzs tulajdonságadatai:

Tulajdonság	Leírás	Alapértelmezett érték
jobType	Feladat típusa. Ennek "FlinkJob" kell lennie	Igen
jobName	Feladat neve, amely a feladat elindításához használatos	Igen
művelet	Ennek "STOP" kell lennie	Igen

Példa:

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

Feladat indítása: Rest API a STOPPED feladat elindításához.

Lehetőség	Érték
Metódus	POST
URL-cím	`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}}`
Fejléc	Engedélyezés = "Tulajdonosi $token"

Kérelem törzse

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

JSON-törzs tulajdonságadatai:

Tulajdonság	Leírás	Alapértelmezett érték
jobType	Feladat típusa. Ennek "FlinkJob" kell lennie	Igen
jobName	A feladat elindításához használt feladat neve.	Igen
művelet	Ennek a "START" értéknek kell lennie	Igen
savePointName	A feladat elindításához mentse a pont nevét. Nem kötelező tulajdonság, alapértelmezés szerint az indítási művelet a legutóbbi sikeres mentési pontot veszi igénybe.	Nem

Példa:

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

Frissítési feladat: Rest API az aktuális futó feladat frissítéséhez.

Lehetőség	Érték
Metódus	POST
URL-cím	`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}}`
Fejléc	Engedélyezés = "Tulajdonosi $token"

Kérelem törzse

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

JSON-törzs tulajdonságadatai:

Tulajdonság	Leírás	Kötelező
jobType	Feladat típusa. Ennek "FlinkJob" kell lennie	Igen
jobName	A feladat elindításához használt feladat neve.	Igen
művelet	Mindig "UPDATE" legyen az új feladatok indításakor.	Igen
args	Feladat JVM-argumentumai	Nem
savePointName	A feladat elindításához mentse a pont nevét. Ez nem kötelező tulajdonság, alapértelmezés szerint az indítási művelet a legutóbbi sikeres SavePoint-műveletet fogja végrehajtani.	Nem

Példa:

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

Állapot nélküli frissítési feladat: Rest API állapot nélküli frissítéshez.

Lehetőség	Érték
Metódus	POST
URL-cím	`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}}`
Fejléc	Engedélyezés = "Tulajdonosi $token"

Kérelem törzse

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

JSON-törzs tulajdonságadatai:

Tulajdonság	Leírás	Kötelező
jobType	Feladat típusa. Ennek "FlinkJob" kell lennie	Igen
jobName	A feladat elindításához használt feladat neve.	Igen
művelet	Mindig "STATELESS_UPDATE" kell lennie az új feladatok indításához.	Igen
args	Feladat JVM-argumentumai	Nem

Példa:

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

Savepoint: Rest API a mentési pont feladathoz való aktiválásához.

Lehetőség	Érték
Metódus	POST
URL-cím	`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}}`
Fejléc	Engedélyezés = "Tulajdonosi $token"

Kérelem törzse

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

JSON-törzs tulajdonságadatai:

Tulajdonság	Leírás	Kötelező
jobType	Feladat típusa. Ennek "FlinkJob" kell lennie	Igen
jobName	A feladat elindításához használt feladat neve.	Igen
művelet	Mindig "SAVEPOINT"-nak kell lennie az új feladatok indításához.	Igen

Példa:

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

Savepoint listázása: A Rest API-val listázhatja az összes mentési pontot a SavePoint könyvtárból.

Lehetőség	Érték
Metódus	POST
URL-cím	`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}}`
Fejléc	Engedélyezés = "Tulajdonosi $token"

Kérelem törzse

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

JSON-törzs tulajdonságadatai:

Tulajdonság	Leírás	Kötelező
jobType	Feladat típusa. Ennek "FlinkJob" kell lennie	Igen
jobName	A feladat elindításához használt feladat neve	Igen
művelet	Ennek "LIST_SAVEPOINT" kell lennie.	Igen

Példa:

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

Mégse: Rest API a feladat megszakításához.

Lehetőség	Érték
Metódus	POST
URL-cím	`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}}`
Fejléc	Engedélyezés = "Tulajdonosi $token"

Kérelem törzse

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

JSON-törzs tulajdonságadatai:

Tulajdonság	Leírás	Kötelező
jobType	Feladat típusa. Ennek a `FlinkJob`	Igen
jobName	A feladat elindításához használt feladat neve.	Igen
művelet	A műveletnek MÉGSE-nek kell lennie.	Igen

Példa:

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

Törlés: Rest API a feladat törléséhez.

Lehetőség	Érték
Metódus	POST
URL-cím	`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}}`
Fejléc	Engedélyezés = "Tulajdonosi $token"

Kérelem törzse

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

JSON-törzs tulajdonságadatai:

Tulajdonság	Leírás	Kötelező
jobType	Feladat típusa. Ennek "FlinkJob" kell lennie	Igen
jobName	A feladat elindításához használt feladat neve.	Igen
művelet	Törlésnek kell lennie.	Igen

Példa:

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

Feladatok listázása: Rest API az aktuális művelet összes feladatának és állapotának listázásához.

Lehetőség	Érték
Metódus	KAP
URL-cím	`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}}`
Fejléc	Engedélyezés = "Tulajdonosi $token"

Kimeneti:

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

Feljegyzés

Ha bármilyen művelet folyamatban van, az actionResult a sikeres befejezéskor a "IN_PROGRESS" értékkel jelzi a sikeres befejezéskor a "SUCCESS" értéket, sikertelenség esetén pedig a "FAILED" értéket.

Referencia

Apache Flink-feladatütemezés
Az Apache, az Apache Flink, a Flink és a társított nyílt forráskód projektnevek az Apache Software Foundation (ASF) védjegyei.

Share via

Apache Flink-feladatkezelés® a HDInsightban AKS-fürtökön

Juttatások

Előfeltételek

Főbb funkciók és műveletek

Feladatok kezelésének lehetőségei a HDInsightban az AKS-en

Feladatkezelés az Azure Portalról

Feladatkezelés Rest API használatával

Alap URL-formátum a Rest API-hoz

Rest API-hitelesítés

API-k és paraméterek listája

Referencia

További források