- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
在 impala 的官方文档中 here , statestore 组件有一条语句:
If you issue a DDL statement while the statestore is down, the queries that access the new object the DDL created will fail.
如果我错了请纠正我,但通过 Impala SQL 进行的元数据更改会从 Impala 目录服务传播到 Impala 守护进程。那为什么statestore挂了,通过DDL生成的新对象查询会失败呢?
最佳答案
只是您理解中的一个小修正,文档如下所示
The Impala component known as the catalog service relays the metadata changes from Impala SQL statements to all the Impala daemons in a cluster.
所以基本上它通过 StateStore 将元数据更改中继到 Impala 守护程序。您还将在文档中看到以下内容,
Because the statestore's purpose is to help when things go wrong and to broadcast metadata to coordinators
因此,任何元数据更改都由目录服务通过 Statestore 服务中继到 Impala 守护进程。
简而言之,当 Statestore 启动并运行时,Impala 守护进程和 Statestore 始终处于连接状态。 Statestore 负责
监控所有 Impala 守护进程并让其他 Impala 守护进程知道是否在其中一个守护程序上发现任何健康问题(例如守护程序关闭)。
它在查询时将元数据更改广播到 Impala 守护进程在 Invalidate Metadata 期间执行。
希望对您有所帮助!
关于hadoop - 如果在 impala statestore 关闭时执行 DDL,为什么 Impala 查询会失败?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57051999/
我正在构建拓扑并想使用 KStream.process()将一些中间值写入数据库。此步骤不会改变数据的性质,并且是完全无状态的。 添加 Processor需要创建一个 ProcessorSupplie
我有两个 Java 应用程序(App1、App2)来测试如何访问 KTable来自 docker 中单实例环境中的不同应用程序。 第一个应用程序 (App1) 写入 KTable使用以下代码。 pub
我有一个紧凑的主题,大约有 30 个 Mio 键。 我的 App将此主题具体化为 KeyValueStore . 我如何检查 KeyValueStore是完全人口?如果我通过 InteractiveQ
在 Kafka 流中 WordCount例如,它使用 StateStore存储字数。如果同一个消费者组中有多个实例,StateStore对组来说是全局的,还是只对消费者实例来说是局部的? 纳克斯 最佳
我在尝试通过 Kafka Streams 实现以下目标时遇到了一些麻烦: 在应用程序启动时,(压缩的)主题 alpha 被加载到键值 StateStore 映射中 Kafka Stream 从另一个主
我们的目标是实现以下架构。最重要的是能够读取主题 T1 的所有数据(来自所有分区)。 我们面临的问题是我们无法在从不同构建器创建的两个节点之间进行连接(每个实例中有两个不同的构建器)。在每个实例中,我
我们目前正在实现一个流程(使用 Kafka Processor API),我们需要将来自 2 个相关事件(消息)的信息组合到一个主题上,然后转发这些组合信息。事件源自 IoT 设备,并且由于我们希望将
尝试访问定义的状态存储中的所有键值,但是在 .transform() 方法中我只能使用一个键(即源键)访问 KeyValueStore SS=context.getStateStore("macs")
我正在尝试实现一个 Transformer 类 public class StreamSorterByTimeStampWithDelayTransformer implements Tra
我的代码中有一个具体化的内存状态存储。我有另一个单独的流,应该根据某些条件查找和删除记录。 我需要允许我的流访问和删除先前构建的状态存储中的记录。我下面有以下代码 @bean public Strea
在 impala 的官方文档中 here , statestore 组件有一条语句: If you issue a DDL statement while the statestore is down
我是一名优秀的程序员,十分优秀!