中国城乡建设部证件查询网站,wordpress文章名加后缀,苏州做网站公,需要怎么办1、当hadoop集群中某一个节点挂了#xff0c;内部数据流程是如何进行的#xff1f;
每一个datanode都会定期向namenode发送heardbeat消息#xff0c;当一段时间namenode没有接收到某一个datanode的消息#xff0c;此时namenode就会将该datanode标记为死亡#xff0c;并不…1、当hadoop集群中某一个节点挂了内部数据流程是如何进行的
每一个datanode都会定期向namenode发送heardbeat消息当一段时间namenode没有接收到某一个datanode的消息此时namenode就会将该datanode标记为死亡并不会向他们发送任何的IO请求同时任何注册到失效的namenode上的数据不会提供给hdfs所使用当某些块的副本数小于指定的数量的时候namenode会不断的跟踪哪些副本是需要复制的并在必要的时候进行复制。
官网可以了解到将datanode标记成死亡节点一般默认的时间是10分钟但是也可以通过修改配置文件来修改下线的时间。
2、namenode和secondarynamenode分别存储了什么数据
namenode
1、负责接收客户端的读、写的请求
2、保存文件的时候会保存元数据例如文件的大小、文件的归属、文件的大小
3、也会收集block的信息
secondarynamenode
主要是用来存储日志文件fismage和edits定期的合并这两个日志文件。
3、集群中如何添加节点 4、mysql与orcal的区别
1、一个是收费的另一个是开源的
2、存储的数据量不同orcal存储的数据量可以很大但是mysql不可以
5、怎么检查数据有没有出现什么问题
1、查看建表语句看创建表时字段是否完整、语言格式是否一致
6、orcal是一个什么类型的数据库
1、是一个关系型数据库可以是因高吞吐量的数据库可移植性比较好
7、sql中常见的函数有
时间函数 时间转成时间戳unix_timestamp 时间戳转成时间from_timestamp 时间相减datadiff
窗口函数: rank、会跳跃 1224 descrank、1223 rownmber 1234
聚合函数:sum、avg
字符串函数substring、concat
8、orcal中的冷备份与热备份的区别与各自的优缺点
热备份针对归档模式的数据库在数据库继续工作的时候进行备份但是对于冷备份来说指的是数据库关闭后对数据进行备份是用于所有模式的数据库。
优缺点 热备份数据在备份的时候数据库可以继续进行工作还可以恢复到任意的时间点 冷备份操作比较简单性能比热备份较强。
9、sql中常见的操作
表操作
删除表数据truncate table 表名
修改表的名称alter table 表名 rename to 新的表名
新增列alter table 表名 add 列名
修改列名alter table 表名 change 原表名 新表名 列类型
删除列drop table 表名 drop 列名
插入数据
insert into 表名 列名1列名2列名3values值1值2值3
更型数据update 表名 set 列名列值
10、数据库中笛卡尔积
指的是在数据库中两张表在关联的时候不指定任何的关联的条件。
11、flnik中chekpoint的流程
1、由flink创建checkpointcoordinator检查点协调器
2、coordinator会向所有的sourceoperater发送barrier栅栏当sourceoperater接收到后就会暂停一切活动暂停的时间会比较短并执行state快照当一切都执行完
向coordinator进行汇报并将barrier发送到下游的operater
3、当下游的operater接收到barrier后也会向所有的sourceoperater就会执行第二步的操作。一直到将barrier发送到sinkoperater中
4、当sink接收到这个barreier后依旧执行步骤二当coordinator接收到所有的operater返回的ok本次快照拍摄结束。
12、开启checkpoint的方式
开启checkpoint默认情况下是禁止的可以通过调用 StreamExecutionEnvironment 的 enableCheckpointing(n) 来启用 checkpoint里面的 n 是进行 checkpoint 的间隔单位毫秒。
也可以在在flink-conf.yaml配置文件中开启checkpoint。
13、flink中的state与checkpoint的主要的区别
state指的是某一个task或者是莫一个operater
checkpoint指的是在某一个特定的时间的快照。
14、spark中如何解决重用
对重复使用的RDD进行持久化cache缓存、checkpoint持久化、广播变量
persistcache则是persist的简化方式cache底层是调用persist的无参构造器无参构造器调用的是persist(StorageLevel.MEMORY_ONLY)。
15、cache与checkpoint的区别
1、cache是基于内存的然而对于checkpoint来说是基于磁盘的也可以存储在hdfs等持久化存储。
16、 flink中的状态容错savepoint、checkpoint
区别
1、触发条件savepoint需要手动出发但是checkpoint是自动的触发
2、主要作用savepoint主要是用来有计划的恢复例如调剂并发啊等一些可能。checkpoint是当出异常的时候会自动的触发
3、特点savepoint持久可以手动触发恢复但是checkpoint轻量可以自动的触发回复。
17、怎么解决kafka数据量过大
1、可以增加topic的分区数可以提高并行处理更多的数据
kafka-topics.sh --zookeeper localhost:2181 --alter --topic my-topic --partitions 10
2、增加副本因子可以提高数据的冗余提高数据的可靠性
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic my-topic --replication-factor 3
3、调整消费者的并行度
4、优化生产者配置
batch.size:增加批处理提高吞吐量
5、配置清理策列根据数据保留策略配置日志保留时间和日志大小定期清理旧数据
6、扩大kafka集群的规模增加broker节点的数量
18、实时计算与实时查询的区别
实时计算指的是来一条数据就计算一条数据
实时查询指的是在海量的数据中查询数据
