Hi,
我刚才把flink sink的hive table，hive hdfs目录都删了，hbase表数据也清空了（hbase 通过hue hive table方式查询），然后重启程序，就可以了， 等再出问题，我试下你这种方法，感谢答疑！ 在 2020-07-14 20:42:16，"Leonard Xu" <[email protected]> 写道： >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> >
