我试图为HA设置配置Flink 1.2.0,在那里我必须设置一个名为状态后端的参数。我之前已经将此参数设置为rocksdb,但随后阅读了留档,其中说HA只有文件系统可用。这是真的吗?(HA设置只支持文件系统状态后端,没有rocksdb可用?)或者这是指一个不同的(特定于动物园管理员的)状态后端?
谢谢!
文件在这一点上有误导性。RocksDB和FSStateBend检查点都使用相同的机制指向文件系统,并且在ZooKeeper中保留一个引用。因此,它实际上独立于正在使用的后端。
临时来的电话,总共面了49分钟,只能凭记忆想一下问题了。 刚开始问在哪里,能不能来杭州,然后自我介绍。 JAVA 1.用的什么语言,用的JDK几,JDK8有什么新特性 2.函数式接口给java带来了什么 3.haspmap不同版本底层结构,CurrentHashMap底层结构,CurrentHashMap 1.8版本put的过程 4.线程池参数,抛弃策略,阻塞队列与非阻塞队列对比 5.几种单例模式
我有一个Flink v1.2设置,在它自己的VM中有1个JobManager、2个TaskManager。我将状态后端配置为文件系统,并在上述每个主机的情况下将其指向本地位置(state.backend.fs.checkpointdir:file:///home/ubuntu/Prototype/flink/flink-checkpoints)。我已将parallelism设置为1,每个TaskM
1、8.23 一面 基本常规八股 + 算法 + 项目 感觉还行 总时长一个小时 过一段时间约了二面 2、9.13 二面 第一次预约的时间,因为有事情冲突修改了时间 比正常的节奏推迟了一个星期 面试简单问了下实习的项目 然后就是两个场景题 第一个是海量数据类型的题 第二个是给一个场景,思路就是模拟tcp实现可靠传输的方式 有一些考虑得不太周全 面试官也会引导 感觉回答得一般般 然后给了一道算法题
面试一小时,我叒忘了录音了,服了自己了,基本都是在问项目,稍微穿插一点八股 都问了啥我有点想不起来了,没答出来的记录下: Http和Https的区别,然后问SSL(这个不会了,没背这个),然后问对称加密和非对称加密(不会) xxl-job的原理,集群等(不会) 写一下项目中线程池怎么创建的(磕磕绊绊,不知道写没写对,他就让解释线程池的参数了) 然后问是一个任务一个线程池还是多个任务共用线程池,我说
红绿色盲,用了两次dfs,没来得及封装方法,过了 2 删除或添加'mhy'任意次,使得字符串s转为t,mhy是子序列,所以可以在不同地方删除或增加,比如 mabshy -> abs 将两个字符串中的字符非为mhy和非mhy两类,要想转换成功,二者的非mhy类字符一定要相同且出现次数相等,而mhy三个字符出现的次数之差要相等 #米哈游笔试#
10分单选,30分多选 3道编程题(15+20+25),结果:1+1+0.92 给定字符串,求包含k个“mihoyo”的最短子串的左右边界 解法:利用split进行分割,注意在字符串后面手动加个符号防止漏掉结尾出现的“mihoyo” 2. 假设有个正整数,给定一个数组,已知数组里面有x个元素>=这个正整数,y个元素<这个正整数。求这个正整数有多少个可能的值? 解法:排序 3. 已知