Skip to content

Commit a0bc7d0

Browse files
Merge pull request #272431 from sreekzz/patch-32
Made changes in Jar File code block
2 parents ef37ef2 + 719d038 commit a0bc7d0

File tree

1 file changed

+12
-12
lines changed

1 file changed

+12
-12
lines changed

articles/hdinsight-aks/flink/hive-dialect-flink.md

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
---
22
title: Hive dialect in Apache Flink® clusters on HDInsight on AKS
3-
description: how to use Hive dialect in Apache Flink® clusters on HDInsight on AKS
3+
description: How to use Hive dialect in Apache Flink® clusters on HDInsight on AKS.
44
ms.service: hdinsight-aks
55
ms.topic: how-to
6-
ms.date: 10/27/2023
6+
ms.date: 04/17/2024
77
---
88

99
# Hive dialect in Apache Flink® clusters on HDInsight on AKS
@@ -14,14 +14,14 @@ In this article, learn how to use Hive dialect in Apache Flink clusters on HDIns
1414

1515
## Introduction
1616

17-
The user cannot change the default `flink` dialect to hive dialect for their usage on HDInsight on AKS clusters. All the SQL operations fail once changed to hive dialect with the following error.
17+
The user can't change the default `flink` dialect to hive dialect for their usage on HDInsight on AKS clusters. All the SQL operations fail once changed to hive dialect with the following error.
1818

1919
```Caused by:
2020
21-
*java.lang.ClassCastException: class jdk.internal.loader.ClassLoaders$AppClassLoader cannot be cast to class java.net.URLClassLoader*
21+
*java.lang.ClassCastException: class jdk.internal.loader.ClassLoaders$AppClassLoader can't be cast to class java.net.URLClassLoader*
2222
```
2323

24-
The reason for this issue arises due to an open [Hive Jira](https://issues.apache.org/jira/browse/HIVE-21584). Currently, Hive assumes that the system class loader is an instance of URLClassLoader. In `Java 11`, this assumption is not the case.
24+
The reason for this issue arises due to an open [Hive Jira](https://issues.apache.org/jira/browse/HIVE-21584). Currently, Hive assumes that the system class loader is an instance of URLClassLoader. In `Java 11`, this assumption isn't the case.
2525

2626
## How to use Hive dialect in Flink
2727

@@ -31,24 +31,24 @@ The reason for this issue arises due to an open [Hive Jira](https://issues.apach
3131
```command
3232
rm /opt/flink-webssh/lib/flink-sql-connector-hive*jar
3333
```
34-
1. Download the below jar in `webssh` pod and add it under the /opt/flink-webssh/lib wget https://aka.ms/hdiflinkhivejdk11jar.
34+
1. Download the following jar in `webssh` pod and add it under the /opt/flink-webssh/lib wget https://aka.ms/hdiflinkhivejdk11jar.
3535
(The above hive jar has the fix [https://issues.apache.org/jira/browse/HIVE-27508](https://issues.apache.org/jira/browse/HIVE-27508))
3636

3737
1. ```
38-
mv $FLINK_HOME/opt/flink-table-planner_2.12-1.16.0-0.0.18.jar $FLINK_HOME/lib/flink-table-planner_2.12-1.16.0-0.0.18.jar
39-
```
40-
38+
mv /opt/flink-webssh/lib/flink-table-planner-loader-1.17.0-*.*.*.*.jar /opt/flink-webssh/opt/
39+
```
40+
4141
1. ```
42-
mv $FLINK_HOME/lib/flink-table-planner-loader-1.16.0-0.0.18.jar $FLINK_HOME/opt/flink-table-planner-loader-1.16.0-0.0.18.jar
42+
mv /opt/flink-webssh/opt/flink-table-planner_2.12-1.17.0-*.*.*.*.jar /opt/flink-webssh/lib/
4343
```
44-
44+
4545
1. Add the following keys in the `flink` configuration management under core-site.xml section:
4646
```
4747
fs.azure.account.key.<STORAGE>.dfs.core.windows.net: <KEY>
4848
flink.hadoop.fs.azure.account.key.<STORAGE>.dfs.core.windows.net: <KEY>
4949
```
5050

51-
- Here is an overview of [hive-dialect queries](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/hive-compatibility/hive-dialect/queries/overview/)
51+
- Here's an overview of [hive-dialect queries](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/hive-compatibility/hive-dialect/queries/overview/)
5252
5353
- Executing Hive dialect in Flink without partitioning
5454

0 commit comments

Comments
 (0)