Hi,
你安装 hive 的 metastore 后,在你 hivehome/conf/hive-site.xml 文件中添加这样一个配置:
<property>
<name>hive.metastore.uris</name>
<value>thrift://xxxx:9083</value>
<description>Thrift URI for the remote metastore. Used by metastore client
to connect to remote metastore.</description>
</property>
一般生产环境应该也是这样配置,
然后 Flink 对接到hive配置参考[1],应该和你之前用的没啥变化,就是不支持 embedded 的 metastore
祝好,
Leonard Xu
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/hive/#connecting-to-hive
<https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/hive/#connecting-to-hive>
> 在 2020年7月14日,20:29,Zhou Zach <[email protected]> 写道:
>
> Hi,
>
>
> 是在flink的conf文件配置hive.metastore.uris吗
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2020-07-14 20:03:11,"Leonard Xu" <[email protected]> 写道:
>> Hello
>>
>>
>>> 在 2020年7月14日,19:52,Zhou Zach <[email protected]> 写道:
>>>
>>> : Embedded metastore is not allowed.
>>
>> Flink 集成 Hive 时,不支持 embedded metastore 的, 你需要起一个hive metastore 并在conf文件配置
>> hive.metastore.uris, 支持的 metastore 版本 参考[1]
>>
>> Best,
>> Leonard Xu
>> [1]
>> https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/hive/#using-bundled-hive-jar
>>
>> <https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/hive/#using-bundled-hive-jar>