“翼”展锋芒,天翼云高性能计算领域论文被IEEE HPCC 2025收录!
近日,由天翼云科技有限公司基础架构事业部(操作系统技术部)高性能网络研发团队撰写的论文《APSCC:AdaptiveCongestionControlforPacketSprayedRDMANetworksinAIClusters》被2025年第27届IE
Flink 与Flink可视化平台StreamPark教程(DataStreamApi基本使用)
本文分享自天翼云开发者社区《》,作者:lnDataStreamApidataStreamApi是一切的基础,处于调度flink程序处理任务的起点。Flink有非常灵活的分层API设计,其中的核心层就是DataStream/DataSetAPI。由于新版本已
Flink 与Flink可视化平台StreamPark教程(CDC功能)
本文分享自天翼云开发者社区《》,作者:ln基本概念flinkCDC功能是面向binlog进行同步、对数据的增删改进行同步的工具,能够实现对数据的动态监听。目前其实现原理主要为监听数据源的binlog对数据的变化有所感知。在这里,我们只需引入相关依赖即可进行
Flink 与Flink可视化平台StreamPark教程(时间相关 1)
本文分享自天翼云开发者社区《》,作者:ln水位线与窗口对于流式数据,时间是一个重要的标识。在flink的事件时间语义下,我们不依赖系统时间,而是基于数据自带的时间戳去定义了一个时钟,用来表示当前时间的进展。于是每个并行子任务都会有一个自己的逻辑时钟,它的前
flink on k8s的基本介绍
本文分享自天翼云开发者社区《》,作者:ln一、背景介绍ApacheFlink是一个流处理引擎,具有高效的流处理和批处理能力,以及良好的可伸缩性和容错性。Kubernetes(简称K8s)是一种容器编排系统,用于自动化容器部署、扩展和管理。将Flink部署在
重塑招聘战场:当80%的重复工作被AI吞噬,你的企业还在“人工挣扎”吗?
招聘,曾是一场耗时费力、沙里淘金且大海捞针式的寻觅。HR深陷简历筛选、初面沟通、基础评估的泥潭,耗时占其工作的80%——而顶尖人才,却往往在等待中悄然流失。企业付出人均成本高昂、周期长达数天的代价,换来的可能只是人与岗的又一次错配。但现在,这场战争的规则已
K8s Application模式下的flink任务执行精要
本文分享自天翼云开发者社区《》,作者:ln构键k8s集群1.在这里,我们需要搭建一个K8S环境用于提供flink任务的运行时环境。在这里推荐使用kubeadm或者一些脚本工具搭建,可参考本自动k8s脚本工具。具体过程在这里省略,可以参考上述链接中的文档进行
Rust 中的 Tokio 线程同步机制
本文分享自天翼云开发者社区《》,作者:lnRust中的Tokio线程同步机制在并发编程中,线程同步是一个重要的概念,用于确保多个线程在访问共享资源时能够正确地协调。Tokio是一个强大的异步运行时库,为Rust提供了多种线程同步机制。以下是一些常见的同步机
Rust多线程:Worker 结构体与线程池中任务的传递机制
本文分享自天翼云开发者社区《》,作者:lnRust多线程:Worker结构体与线程池中任务的传递机制在实现一个多线程的Web服务器时,我们会遇到一个问题:如何在创建线程之后让它们在没有任务时保持等待状态,并且在任务到来时可以立即执行。这是一个典型的线程池设
使用 Rust 实现的基础的List 和 Watch 机制
本文分享自天翼云开发者社区《》。作者:ln介绍在日常的开发过程中,有一个很重要的任务是能够通过Rust语言实现K8s中的各种生态组件,在这个过程中,既需要能过够了解K8S的工作原理也需要能够知道rust的语言特性。因此,在这个过程中有很多值得探讨的知识点。