Skip to content

Commit 0bce58b

Browse files
Merge pull request #270596 from sreekzz/patch-23
Updated moving the planner jar code block
2 parents 51ea79d + b51c109 commit 0bce58b

File tree

4 files changed

+10
-10
lines changed

4 files changed

+10
-10
lines changed

articles/hdinsight-aks/flink/flink-catalog-delta-hive.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ title: Table API and SQL - Use Delta Catalog type with Hive with Apache Flink®
33
description: Learn about how to create Delta Catalog with Apache Flink® on Azure HDInsight on AKS
44
ms.service: hdinsight-aks
55
ms.topic: how-to
6-
ms.date: 03/14/2024
6+
ms.date: 03/29/2024
77
---
88

99
# Create Delta Catalog with Apache Flink® on Azure HDInsight on AKS
@@ -64,7 +64,7 @@ Using the delta catalog
6464
We use arrival data of flights from a sample data, you can choose a table of your choice.
6565

6666
```sql
67-
CREATE TABLE flightsintervaldata1 (arrivalAirportCandidatesCount INT, estArrivalHour INT) PARTITIONED BY (estArrivalHour) WITH ('connector' = 'delta', 'table-path' = 'abfs://container@storage_account.dfs.core.windows.net'/delta-output);
67+
CREATE TABLE flightsintervaldata1 (arrivalAirportCandidatesCount INT, estArrivalHour INT) PARTITIONED BY (estArrivalHour) WITH ('connector' = 'delta', 'table-path' = 'abfs://container@storage_account.dfs.core.windows.net/delta-output');
6868
```
6969
> [!NOTE]
7070
> In the above step, the container and storage account *need not be same* as specified during the cluster creation. In case you want to specify another storage account, you can update `core-site.xml` with `fs.azure.account.key.<account_name>.dfs.core.windows.net: <azure_storage_key>` using configuration management.

articles/hdinsight-aks/flink/monitor-changes-postgres-table-flink.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ title: Change Data Capture (CDC) of PostgreSQL table using Apache Flink®
33
description: Learn how to perform CDC on PostgreSQL table using Apache Flink®
44
ms.service: hdinsight-aks
55
ms.topic: how-to
6-
ms.date: 03/28/2024
6+
ms.date: 03/29/2024
77
---
88

99
# Change Data Capture (CDC) of PostgreSQL table using Apache Flink®
@@ -187,7 +187,7 @@ Now, let's learn how to monitor changes on PostgreSQL table using Flink-SQL CDC.
187187
'hostname' = 'flinkpostgres.postgres.database.azure.com',
188188
'port' = '5432',
189189
'username' = 'username',
190-
....
190+
'password' = 'password',
191191
'database-name' = 'postgres',
192192
'schema-name' = 'public',
193193
'table-name' = 'shipments',

articles/hdinsight-aks/flink/use-hive-catalog.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ title: Use Hive Catalog, Hive Read & Write demo on Apache Flink®
33
description: Learn how to use Hive Catalog, Hive Read & Write demo on Apache Flink® on HDInsight on AKS
44
ms.service: hdinsight-aks
55
ms.topic: how-to
6-
ms.date: 03/18/2023
6+
ms.date: 03/29/2024
77
---
88

99
# How to use Hive Catalog with Apache Flink® on HDInsight on AKS
@@ -151,11 +151,11 @@ wget https://repo1.maven.org/maven2/org/apache/flink/flink-connector-kafka/1.17.
151151

152152
**Moving the planner jar**
153153

154-
Move the jar flink-table-planner_2.12-1.16.0-0.0.18.jar located in webssh pod's /opt to /lib and move out the jar flink-table-planner-loader-1.16.0-0.0.18.jar from /lib. Refer to [issue](https://issues.apache.org/jira/browse/FLINK-25128) for more details. Perform the following steps to move the planner jar.
154+
Move the jar flink-table-planner_2.12-1.17.0-*.*.*.*.jar located in webssh pod's /opt to /lib and move out the jar flink-table-planner-loader1.17.0-*.*.*.*.jar /opt/flink-webssh/opt/ from /lib. Refer to [issue](https://issues.apache.org/jira/browse/FLINK-25128) for more details. Perform the following steps to move the planner jar.
155155

156156
```
157-
mv /opt/flink-webssh/lib/flink-table-planner-loader-1.17.0-1.1.1.3.jar /opt/flink-webssh/opt/
158-
mv /opt/flink-webssh/opt/flink-table-planner_2.12-1.17.0-1.1.1.3.jar /opt/flink-webssh/lib/
157+
mv /opt/flink-webssh/lib/flink-table-planner-loader-1.17.0-*.*.*.*.jar /opt/flink-webssh/opt/
158+
mv /opt/flink-webssh/opt/flink-table-planner_2.12-1.17.0-*.*.*.*.jar /opt/flink-webssh/lib/
159159
```
160160

161161
> [!NOTE]

articles/hdinsight-aks/flink/use-hive-metastore-datastream.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ title: Use Hive Metastore with Apache Flink® DataStream API
33
description: Use Hive Metastore with Apache Flink® DataStream API
44
ms.service: hdinsight-aks
55
ms.topic: how-to
6-
ms.date: 03/22/2024
6+
ms.date: 03/29/2024
77
---
88

99
# Use Hive Metastore with Apache Flink® DataStream API
@@ -89,7 +89,7 @@ public class hiveDemo {
8989
```
9090
On Webssh pod, move the planner jar
9191

92-
Move the jar `flink-table-planner_2.12-1.16.0-0.0.18.jar` located in webssh pod's `/opt to /lib` and move out the jar `flink-table-planner-loader-1.16.0-0.0.18.jar` from `lib`. Refer to issue for more details. Perform the following steps to move the planner jar.
92+
Move the jar `flink-table-planner-loader-1.17.0-*.*.*.jar` located in webssh pod's `/opt to /lib` and move out the jar `flink-table-planner-loader-1.17.0-*.*.*.jar` from `lib`. Refer to issue for more details. Perform the following steps to move the planner jar.
9393

9494
```
9595
mv /opt/flink-webssh/lib/flink-table-planner-loader-1.17.0-1.1.8.jar /opt/flink-webssh/opt/

0 commit comments

Comments
 (0)