检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
是，处理完毕。 否，执行1.e。 确认Flume Source是否是Kafka类型。 是，执行1.d。 否，执行1.e。 使用Kafka客户端，执行以下命令查看Kafka Source配置的topic数据是否已经消费完毕。 cd /opt/client/Kafka/kafka/bin
select_statement; 参数描述 表1 CREATE TABLE参数描述 参数 描述 db_name Database名称，由字母、数字和下划线（_）组成。 table_name Database中的表名，由字母、数字和下划线（_）组成。 STORED AS 使用CarbonData数据格式存储数据。
INTO [database_name.]table [(c1, c2, c3)] VALUES (v11, v12, v13), (v21, v22, v23), ... 方法二：使用INSERT SELECT方式进行数据写入。 UPSERT INTO [database_name
ite。 源表和目标表的数据类型应该相同，否则源表中的数据将被视为Bad Records。 INSERT INTO命令不支持部分成功（partial success），如果存在Bad Records，该命令会失败。 在从源表插入数据到目标表的过程中，无法在源表中加载或更新数据。
配置quota的目录Znode使用率超出阈值”左侧下拉菜单，在“定位信息”的“服务目录”中获取告警的Znode路径。 以集群用户登录ZooKeeper客户端，删除告警对应Znode下的无用数据。 登录FusionInsight Manager，选择“集群 > 待操作集群的名称 > 服务 > 告
ZooKeeper Znode数量使用率超出阈值”左侧下拉菜单，在“定位信息”的“服务目录”中获取告警的Znode路径。 以集群用户登录ZooKeeper客户端，删除告警对应Znode下的无用数据。 登录FusionInsight Manager，选择“集群 > 待操作集群的名称 > 服务 > ZooKeeper
2-byte value: 32970 at org.postgresql.core.PGStream.SendInteger2(PGStream.java:199) at org.postgresql.core.v3.QueryExecutorImpl.se
/11 10:58:00重启成功后对应的“Input Size”的值显示为“0 records”。 图1 Web UI界面部分batch time对应Input Size为0 records 回答 Kafka重启成功后应用会按照batch时间把2017/05/11 10:57:00~2017/05/11
stdout跳转到日志页面。 原因分析 配置项“spark.httpdProxy.enable”未开启。 修改配置项查看日志处理步骤 在客户端修改spark-defaults.conf的配置项：spark.httpdProxy.enable = true，该配置项取值默认为false。
Topic每秒输入的消息条数 Topic每秒的fetch请求数 Topic每秒的produce请求数 支持查询Broker ID与节点IP的对应关系。在Linux客户端下，使用kafka-broker-info.sh查询Broker ID与节点IP的对应关系。 父主题： Kafka
索引，否则会导致存储和处理的资源浪费。 索引不能添加到系统表中。 向索引列put数据时不支持append和increment操作。 如果客户端出现任何故障，除非发生DoNotRetryIOException，否则应该重试。 索引列族按以下优先级从数据表中已存在的列族选取，优先级从高到低依次为：
需要预先对字段name创建二级索引。 相关操作 基于二级索引表查询。 查询样例如下： 用户在hbase_sample_table的info列族的name列添加一个索引，在客户端执行， hbase org.apache.hadoop.hbase.hindex.mapreduce.TableIndexer -Dtablename
check) “Ownership” ALTER DATABASE “管理” CREATE DATABASE - SHOW DATABASES - EXPLAIN “查询” DROP DATABASE “Ownership” DESC DATABASE - CACHE TABLE “查询” UNCACHE
主表名。 注意事项 在执行此命令之前，使用REFRESH TABLE将主表和二级所索引表都注册到Hive元数据中。 示例 create database productdb; use productdb; CREATE TABLE productSalesTable(a int,b string
clusterName) throws Exception { String createDbSql = "create database if not exists " + databaseName + " on cluster " + clusterName;
bloom.num_entries 存储在布隆过滤器中的条目数。 假设maxParquetFileSize为128MB，averageRecordSize为1024B，因此，一个文件中的记录总数约为130K。 默认值（60000）大约是此近似值的一半。 注意： 将此值设置的太低，将产生
则可以使用MapPartitions，按每个分区计算结果，如： rdd.mapPartitions(records => conn.getDBConn;for(item <- records) write(item.toString); conn.close) 使用mapPartition
clusterName) throws Exception { String createDbSql = "create database if not exists " + databaseName + " on cluster " + clusterName;
的Bad Records管理，请参见表2。 表2 Bad Records Logger 配置项 默认值 描述 BAD_RECORDS_LOGGER_ENABLE false 若设置为true，则将创建Bad Records日志文件，其中包含Bad Records的详细信息。 BAD_RECORDS_ACTION
EXPLAIN SELECT (of table) CREATE TABLE CREATE (of database) CREATE TABLE As SELECT CREATE (on database), INSERT (on table), RW on data file, and SELECT
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
