Iterator对象在foreach循环的时候只能使用自己的remove/add方法,如果使用了集合的remove/add方法或者其他线程并发时修改了集合的内容,就属于fail-fast机制,即是一个错误,但是该错误会尽最大可能地抛出ConcurrentModificationException异常 ...
分类:
其他好文 时间:
2020-06-25 15:41:03
阅读次数:
60
主机1:ResourceManager 处理客户端请求 监控NodeManager 启动或监控ApplicationMaster(干的活儿,单个任务) 资源的分配与调度 主机2:NodeManager 管理单个节点上的资源 处理ResourceManager的命令 处理ApplicationMase ...
分类:
其他好文 时间:
2020-06-21 22:52:28
阅读次数:
43
CopyOnWriteArrayList(免锁容器)的好处之一是当多个迭代器同时遍历和修改这 个列表时,不会抛出 ConcurrentModificationException。在 CopyOnWriteArrayList 中,写入将导致创建整个底层数组的副本,而源数组将保 留在原地,使得复制的数组 ...
分类:
其他好文 时间:
2020-06-21 14:12:34
阅读次数:
47
CopyOnWriteArrayList(免锁容器)的好处之一是当多个迭代器同时遍历和修改这 个列表时,不会抛出 ConcurrentModificationException。在 CopyOnWriteArrayList 中,写入将导致创建整个底层数组的副本,而源数组将保 留在原地,使得复制的数组 ...
分类:
其他好文 时间:
2020-06-08 01:01:27
阅读次数:
99
这样写代码时,遇到了上面的异常 for(Question q:questionList) { if(!qIds.contains(q.getQuestionId())){ questionList.remove(q); } } 换成下面这种写法就正常了 for(int k=0;k<questionL ...
分类:
编程语言 时间:
2020-06-06 12:38:25
阅读次数:
55
(1)flink的任务提交流程(无Dispatcher提交) 1、client向yarn提交application后,同时向HDFS上传flink的Jar包和配置。ResourceManager为application分配Container资源并通知对应的NodeManager启动Applicati ...
分类:
其他好文 时间:
2020-05-27 18:53:08
阅读次数:
80
YARN调度架构 esourceScheduler是YARN的调度器,负责Container的分配。 AsyncDispatcher是单线程的事件分发器,负责向调度器发送调度事件。 ResourceTrackerService是资源跟踪服务,主要负责接收处理NodeManager的心跳信息。 App... ...
分类:
移动开发 时间:
2020-05-24 20:59:39
阅读次数:
118
一、集合 ` 二、Collection类 1、 Collection的常用方法 2、迭代器 三、List 迭代器 四、List的遍历方式 1、使用迭代器 2、普通for 3、增强for 五、ConcurrentModificationException异常 六、基本数据结构 1、栈 2、队列 3、数 ...
分类:
编程语言 时间:
2020-05-14 15:07:14
阅读次数:
58
问题 为防止因为虚拟机内存过少,进程被杀死,需要关闭yarn的内存检测 yarn-site.xml <!--是否启动一个线程检查每个任务正使用的物理内存量,如果任务超出分配值,则直接将其杀掉,默认是true --> <property> <name>yarn.nodemanager.pmem-che ...
分类:
其他好文 时间:
2020-05-04 21:34:02
阅读次数:
99
首先看下下面的各种删除list元素的例子 报异常IndexOutOfBoundsException我们很理解,是动态删除了元素导致数组下标越界了。 那ConcurrentModificationException呢? 其中,for(xx in xx)是增强的for循环,即迭代器Iterator的加强 ...
分类:
编程语言 时间:
2020-04-29 14:44:59
阅读次数:
69