Yao Zhang created ZEPPELIN-5795:
-----------------------------------
Summary: org.apache.flink.connectors.hive.HiveSource class not
found when querying data from Hive using Flink
Key: ZEPPELIN-5795
URL: https://issues.apache.org/jira/browse/ZEPPELIN-5795
Project: Zeppelin
Issue Type: Bug
Components: flink
Affects Versions: 0.10.1
Environment: Flink 1.13.2
Hive 3.1.0
Hadoop 3.1.1
Zeppelin 0.10.1
Reporter: Yao Zhang
Got java.lang.ClassNotFoundException:
org.apache.flink.connectors.hive.HiveSource when querying data from Hive table
using Flink. One of the Flink dependencies required by connecting Hive
'flink-sql-connector-hive-3.1.2_2.11-1.13.2.jar' has been added(In
$FLINK_HOME/lib). And I am sure that HiveSource is included in this jar:
{code:java}
oot@manager127 lib]# jar -tf flink-sql-connector-hive-3.1.2_2.11-1.13.2.jar |
grep HiveSource
org/apache/flink/connectors/hive/HiveSource$HiveSourceBuilder.class
org/apache/flink/connectors/hive/HiveSource.class
org/apache/flink/connectors/hive/HiveSourceSplitSerializer.class
org/apache/flink/connectors/hive/HiveSourceFileEnumerator$Provider.class
org/apache/flink/connectors/hive/HiveSourceFileEnumerator.class
org/apache/flink/connectors/hive/read/HiveSourceSplit.class {code}
Also I checked the classpath of Flink interpreter, it actually contains
'flink-sql-connector-hive-3.1.2_2.11-1.13.2.jar'. Hive data can be successfully
retrieved by running Flink sql-client with the same Flink installation, while
in Zeppelin I got this exception.
Here is my configuration about Flink interpreter(Hive related):
* HIVE_CONF_DIR
* zeppelin.flink.enableHive: true
* zeppelin.flink.hive.version: 3.1.0
* zeppelin.flink.module.enableHive: false
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
