Hi, 我觉得是时候考虑把hive文档移到connector里了，我们没必要割裂它们
Best, Jingsong On Tue, Aug 11, 2020 at 10:39 AM Zhao,Yi(SEC) <zhaoy...@baidu.com> wrote: > 是的。我更多是纠结文档结构容易造成混淆。我认为catalog和connector是相对独立的概念。最对算是有点关系。 > 但是根据其他人的回答，目前来看，这2者还真没办法完全独立。比如jdbc connector就是不支持hive表。读写hive表还就是需要hive > catalog。于是我刚刚回了另一封邮件写到，这种case下，我认为实践中，可以单独搞一个hive > metastore仅仅服务于flink，hive和spark-sql则使用另一个hive > metastore。这样去独立出来，避免出现流表被spark，hive可见。 > __________________ > > 在 2020/8/11 上午10:35，“Rui Li”<lirui.fu...@gmail.com> 写入: > > > 你是想问Flink通过HiveCatalog创建的流式表在SparkSQL中是不是可见么？Flink通过HiveCatalog创建的流式表在HMS中也是作为一张普通的表存在的，所以我理解SparkSQL如果对接同一个HMS的话也是可以看到这张表的。但不管是Hive还是SparkSQL，尝试查询这个流式表应该都会出错，目前这一点是需要用户自己保证的，比如可以通过不同的DB来做划分。 > > On Mon, Aug 10, 2020 at 8:43 PM Zhao,Yi(SEC) <zhaoy...@baidu.com> > wrote: > > > 如果使用了Hive > > > catalog，我创建一个流式表，然后返回基于同一个HiveCatalog的spark-sql中，那个表能看到吗？如果尝试查询是不是会出错？ > > 无法实验：我现在还没搞定，因为简单的配置ok，连接到了hive metastore，也通过 show > > > tables看到了表，但select会出错（这个问题后续再说，现在就是想知道这种基于已有catalog的情况时是不是不太好，比较flink-sql特有流表）。 > > > > 在 2020/8/10 下午8:24，“Danny Chan”<yuzhao....@gmail.com> 写入: > > > > 你好 ~ > > > > 1. 你是只文档结构吗 ？catalog 是 flink SQL 管理表元数据信息的组件，通过注册 catalog > 用户可以直接访问 > > catalog 中的已存表，当然用户也可以通过 CREATE TABLE DDL 来创建对应的 connector 表 > > 2. 访问 hive metastore 中的表示一定要用 hive catalog > 的，如果是新建临时表（不持久化），也可以使用内置的 > > catalog > > > > Best, > > Danny Chan > > 在 2020年8月10日 +0800 PM8:14，Zhao,Yi(SEC) <zhaoy...@baidu.com>，写道： > > > 1 为什么flinksql 1.11中，JDBC > > Catalog通过简单的链接转给了connector，catalog和connector并不是同一个概念。我认为应该将jdbc > > connectior和jdbc catalog分开放入各自目录。 > > > > > > 2 为什么flinksql1.11中，connector部分没有hive connector。而是在hive > > integration部分，以及catalogs中介绍。而且在 Table API & SQL/Hive > Integration/Hive Read > > & Write 部分，第一句是“Using the HiveCatalog and Flink’s connector to Hive, > Flink > > can read and write from Hive data as an alternative to Hive’s batch > > > engine.”。难道不使用hivecatalog就不能读取hive数据？是这个意思嘛。感觉好像意思是hive读取特别，这种情况必须使用hive > > catalog。不可以使用jdbc catalog，但使用hive connector嘛？ > > > > > > > > -- > Best regards! > Rui Li > > > -- Best, Jingsong Lee
