Updated new screenshots

Author: Sreekanth Iyer (Ushta Te Consultancy Services)

articles/hdinsight-aks/flink/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2.md

@@ -171,18 +171,19 @@ public class KafkaSinkToGen2 {
 
 1. Upload the jar to ABFS.
 
-    :::image type="content" source="./media/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2/app-mode.png" alt-text="Screenshot showing Flink app mode screen.":::
+    :::image type="content" source="./media/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2/app-mode.png" alt-text="Screenshot showing Flink app mode screen." lightbox="./media/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2/app-mode.png":::
+
 
 1. Pass the job jar information in `AppMode` cluster creation.
 
-    :::image type="content" source="./media/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2/create-app-mode.png" alt-text="Screenshot showing create app mode.":::
+    :::image type="content" source="./media/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2/create-app-mode.png" alt-text="Screenshot showing create app mode." lightbox="./media/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2/-create-app-mode.png":::
 
     > [!NOTE]
     >  Make sure to add classloader.resolve-order as ‘parent-first’ and hadoop.classpath.enable as `true`
 
 1. You can see the job running.
 
-    :::image type="content" source="./media/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2/flink-ui.png" alt-text="Screenshot showing Flink UI.":::
+    :::image type="content" source="./media/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2/flink-ui.png" alt-text="Screenshot showing Flink UI." lightbox="./media/assign-kafka-topic-event-message-to-azure-data-lake-storage-gen2/flink-ui.png":::
 
 
 **Validate streaming data on ADLS Gen2**

articles/hdinsight-aks/flink/flink-configuration-management.md

@@ -1,28 +1,28 @@
 ---
 title: Apache Flink® Configuration Management in HDInsight on AKS
-description: Learn about Apache Flink Configuration Management in HDInsight on AKS
+description: Learn about Apache Flink Configuration Management in HDInsight on AKS.
 ms.service: hdinsight-aks
 ms.topic: tutorial
-ms.date: 08/29/2023
+ms.date: 04/25/2024
 ---
 
 # Apache Flink® Configuration management in HDInsight on AKS
 
 [!INCLUDE [feature-in-preview](../includes/feature-in-preview.md)]
 
-HDInsight on AKS provides a set of default configurations of Apache Flink for most properties and a few based on common application profiles. However, in case you're required to tweak Flink configuration properties to improve performance for certain applications with state usage, parallelism, or memory settings, you can change certain properties at cluster level using **Configuration management** section in HDInsight on AKS cluster.
+HDInsight on AKS provides a set of default configurations of Apache Flink for most properties and a few based on common application profiles. However, in case you're required to tweak Flink configuration properties to improve performance for certain applications with state usage, parallelism, or memory settings, you can change Flink job configuration using Flink Jobs Section in HDInsight on AKS cluster.
 
-1. Go to **Configuration Management** section on your Apache Flink cluster page 
+1. Go To Settings > Flink Jobs > Click on Update.
 
-    :::image type="content" source="./media/flink-configuration-management/configuration-page-revised.png" alt-text="Screenshot showing Apache Flink Configuration Management page." lightbox="./media/flink-configuration-management/configuration-page-revised.png":::
+    :::image type="content" source="./media/update-page.png" alt-text="Screenshot showing update page." lightbox="./media/flink-configuration-management/update-page.png":::
 
-2. Update **configurations** as required at *Cluster level*
+1. Click on **+ Add a row** to edit configuration.
 
-    :::image type="content" source="./media/flink-configuration-management/update-configuration-revised.png" alt-text="Screenshot showing Apache Flink Update configuration page." lightbox="./media/flink-configuration-management/update-configuration-revised.png":::
+    :::image type="content" source="./media/flink-configuration-management/update-job.png" alt-text="Screenshot update job." lightbox="./media/flink-configuration-management/update-job.png":::
 
 Here the checkpoint interval is changed at *Cluster level*.
 
-3. Update the changes by clicking **OK** and then **Save**.
+1. Update the changes by clicking **OK** and then **Save**.
 
 Once saved, the new configurations get updated in a few minutes (~5 minutes).
 
@@ -32,7 +32,7 @@ Configurations, which can be updated using Configuration Management Settings
 
 The default settings for the process memory size of or job manager and task manager would be the memory configured by the user during cluster creation. 
 
-This size can be configured by using the below configuration property. In-order to change task manager process memory, use this configuration
+This size can be configured by using the below configuration property. In-order to change task manager process memory, use this configuration.
 
 `taskmanager.memory.process.size : <value>`
 
@@ -48,28 +48,28 @@ For job manager,
 
 ## Checkpoint Interval
 
-The checkpoint interval determines how often Flink triggers a checkpoint. it's defined in milliseconds and can be set using the following configuration property:
+The checkpoint interval determines how often Flink triggers a checkpoint. Defined in milliseconds and can be set using the following configuration property
 
 `execution.checkpoint.interval: <value>`
 
 Default setting is 60,000 milliseconds (1 min), this value can be changed as desired.
 
 ## State Backend
 
-The state backend determines how Flink manages and persists the state of your application. It impacts how checkpoints are stored. You can configure the `state backend using the following property:
+The state backend determines how Flink manages and persists the state of your application. It impacts how checkpoints stored. You can configure the `state backend using the following property:
 
 `state.backend: <value>`
 
-By default Apache Flink clusters in HDInsight on AKS use Rocks db
+By default Apache Flink clusters in HDInsight on AKS use Rocks DB.
 
 ## Checkpoint Storage Path
 
 We allow persistent checkpoints by default by storing the checkpoints in `abfs` storage as configured by the user. Even if the job fails, since the checkpoints are persisted, it can be easily started with the latest checkpoint.
 
 `state.checkpoints.dir: <path>`
-Replace `<path>` with the desired path where the checkpoints are stored.
+Replace `<path>` with the desired path where the checkpoints stored.
 
-By default, it's stored in the storage account (ABFS), configured by the user. This value can be changed to any path desired as long as the Flink pods can access it.
+By default, stored in the storage account (ABFS), configured by the user. This value can be changed to any path desired as long as the Flink pods can access it.
 
 ## Maximum Concurrent Checkpoints
 
@@ -88,8 +88,8 @@ Replace `<value>` with desired maximum number. By default we retain maximum five
 
 We allow persistent savepoints by default by storing the savepoints in `abfs` storage (as configured by the user). If the user wants to stop and later start the job with a particular savepoint, they can configure this location.
 state.checkpoints.dir: `<path>`
-Replace` <path>` with the desired path where the savepoints are stored.
-By default, it's stored in the storage account, configured by the user. (We support ABFS). This value can be changed to any path desired as long as the Flink pods can access it.
+Replace` <path>` with the desired path where the savepoints stored.
+By default, stored in the storage account, configured by the user. (We support ABFS). This value can be changed to any path desired as long as the Flink pods can access it.
 
 ## Job manager high availability
 
@@ -103,25 +103,13 @@ Even if the jobs fail abruptly, if the checkpoints are happening continuously, t
 Change the job strategy in between?
 There are use cases, where the job needs to be modified while in production due to some job level bug. During that time, the user can stop the job, which would automatically take a savepoint and save it in savepoint location.
 
-`bin/flink stop <JOBID>`
+1. Click on `savepoint` and wait for `savepoint` to be completed.
 
-Example:
-
-```
-root [ ~ ]# ./bin/flink stop 60bdf21d9bc3bc65d63bc3d8fc6d5c54
-Suspending job "60bdf21d9bc3bc65d63bc3d8fc6d5c54" with a CANONICAL savepoint.
-Savepoint completed. Path: abfs://[email protected]/8255a11812144c28b4ddf1068460c96b/savepoints/savepoint-60bdf2-7717485d15e3
-```
-
-Later the user can start the job  with bug fix pointing to the savepoint.
+    :::image type="content" source="./media/flink-configuration-management/save-point.png" alt-text="Screenshot showing save point options." lightbox="./media/flink-configuration-management/save-point.png":::
 
-```
-./bin/flink run <JOB_JAR> -d <SAVEPOINT_LOC>
-root [ ~ ]# ./bin/flink run examples/streaming/StateMachineExample.jar -s abfs://[email protected]/8255a11812144c28b4ddf1068460c96b/savepoints/savepoint-60bdf2-7717485d15e3
-```
-Usage with built-in data generator: StateMachineExample [--error-rate `<probability-of-invalid-transition>] [--sleep <sleep-per-record-in-ms>]`
+1. After savepoint completion, click on start and Start Job Tab will appear. Select the savepoint name from the dropdown. Edit any configurations if necessary. And click **OK**.  
 
-Usage with Kafka: `StateMachineExample --kafka-topic <topic> [--brokers <brokers>]`
+    :::image type="content" source="./media/flink-configuration-management/start-job.png" alt-text="Screenshot showing how to start job." lightbox="./media/flink-configuration-management/start.job.png":::
 
 Since savepoint is provided in the job, the Flink knows from where to start processing the data.