【摘 要】
：
新一代大数据间引擎Flink在面临远程传输问题时,主要通过Netty完成数据传输,并依靠Netty水位值机制来保证其反压机制的运行。Netty水位值机制是一种相对静态的机制,这使得Fli
【机 构】
：
大连大学信息工程学院,大数据应用技术国家民委重点实验室,大连民族大学计算机科学与工程学院,大连市民族文化数字技术重点实验室
论文部分内容阅读
新一代大数据间引擎Flink在面临远程传输问题时,主要通过Netty完成数据传输,并依靠Netty水位值机制来保证其反压机制的运行。Netty水位值机制是一种相对静态的机制,这使得Flink在面临突变性特别大的数据流时会反复进行反压,进而影响整个Flink集群的计算效率。针对此问题,本文提出一种基于动态水位值的Flink调度优化算法Flink-N,经实验验证,与Flink默认的反压机制相比,Flink-N在吐吞量、CPU利用率及时延均有很大提升,时延整体优化达18%,最高优化23%。
其他文献
为了去除复杂的音频切分和强制对齐过程,并在噪音环境下充分发挥说话人发音过程中发音器官的视觉作用,本文提出了一种融合唇部特征的端到端的多模态语音识别算法。本文首先对
主效应因素分析是故障定位、道路交通事故分析、航空事故分析、风险分析、致因分析等领域关注和研究的重要课题,对于分析事故原因以及采取有效预防措施、降低事故发生率具有
松材线虫病对我国松树类物种具有极大的伤害,需要对病虫区域进行准确高效的确定以提早防治。这种病在传播方式上具有跳跃特性。它具有传播途径多种多样、发病部位较隐蔽难以
根据弱信号环境中传统捕获算法无法直接捕获到信号的问题,分析了部分算法在捕获灵敏度和捕获效率上的不足。而后根据DBZP (双块补零)算法的分块思想,以及在块内添加FFT模块的
为了提高认知无线电网络的性能,在认知无线电网络下提出了一种频谱共享策略,在这种策略下次级用户可以在基于自动重发请求(ARQ)反馈信息的情况下与主用户共存,提出了协同与接
河北省档案馆组织开展“庆祝五四青年节”主题党日活动为推进党史学习教育走深走实,4月27日,在五四青年节即将到来之际,河北省档案馆组织青年党员赴平山战备后库开展主题党日
历史无声,档案有痕。珍存于河北省档案馆的长芦盐务档案,记录了长芦盐业生产、运输、销售、税收、缉私、出口等多方面的活动。2018年,河北省档案局携手中央电视台《揽胜神州
传统的基于“用户–项目”二维推荐系统不考虑用户或项目相关的情景信息,使得推荐系统在项目与用户需求匹配过程中自适应性不够,进而导致个性化推荐质量不高。本文在分析态势
针对普通测温仪以检测整个面部的温度为主,继而引起测温准确度受限的问题,提出通过改进的Dlib人脸检测算法对面部穴位进行测温。本文采用KTVC3100SY红外无感快速人体测温筛查
随着手机的发展,开源的安卓系统也慢慢填补了自己的劣势,在市场占有上大大超越了苹果手机。同样因为安卓的开源性,各种鱼龙混杂的安卓应用都进入了安卓市场,所以安卓应用安全