Skip to content

Commit 719d038

Browse files
authored
Corrected the format
Corrected the format
1 parent 15fb519 commit 719d038

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

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

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
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
66
ms.date: 04/17/2024
@@ -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

@@ -34,21 +34,21 @@ The reason for this issue arises due to an open [Hive Jira](https://issues.apach
3434
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

37-
1. ```
38-
mv /opt/flink-webssh/lib/flink-table-planner-loader-1.17.0-*.*.*.*.jar /opt/flink-webssh/opt/
39-
```
40-
37+
1. ```
38+
mv /opt/flink-webssh/lib/flink-table-planner-loader-1.17.0-*.*.*.*.jar /opt/flink-webssh/opt/
39+
```
40+
4141
1. ```
4242
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)