三是瞄准智能制造，打造两化融合升级版。

但如果总和生育率一直保持在1.6的水平，人口负增长将提前到2027年出现，2065年人口减少到11.72亿，相当于1990年的规模单周邀请人数最多的前10人可以瓜分每周奖金池中的奖金便捷、趣味的学习方式，充分调动了社员的积极性，2万余名社员参与了线上题库学习、答题。

电子党建事业部团队自始至终保持高度的工作热情，在大赛中承担了重要工作，提供了稳定实用的社员之家程序，这些都是大赛取得圆满成功的重要因素。远光软件股份有限公司研发的社员之家，为赛事提供线上学习、网络答题及坚实的技术支持，获九三学社中央颁发的突出贡献奖，由全国政协副主席、九三学社中央常务副主席邵鸿和全国人大常委、九三学社中央副主席从斌颁奖。平台可以实现每日自动统计、更新参与人数，发布各省和全国的答题榜单，最终，根据各省线上参赛率，快速、准确、公正地评出300名个人奖、1个最佳组织奖和8个优秀组织奖，并根据各省线上平均分排名选出9个省级组织进入线下集体决赛。感谢远光软件和电子党建事业部全体工作人员的辛勤付出。为了激励更多的社员积极参与活动，程序还设置了多种社交化的玩法，如参加学习答题可以抽取奖励，邀请5名好友答题可获得1次重新答题机会。

日前，由九三学社中央主办的《社员之家杯社章社史知识竞赛》在北京举行决赛。《社员之家杯社章社史知识竞赛》是九三学社面向全国社员举办的一次知识竞赛活动，旨在促进社员学习社章，重温社史，引导广大社员牢记九三优良传统，在新时代作出新贡献。而Flink在这两方面是存在天然优势的，因为Flink天然是分布式系统，可以自己管理弹性伸缩，此外Flink内置了状态管理和exactly once一致性语义，因此基于Flink可以更方便、高效实现Transactional Application。

另一方面将Flink的Job调度从集中式转为了分布式，使得Flink集群规模可以更大的扩展。在Flink SQL领域，阿里巴巴提出了全新的Query Execution和Optimizer架构，利用高效的二级制数据结构，更加合理的内存利用方式，更细粒度的Codegen机制以及更加丰富的优化器策略，使得Streaming 和Batch SQL都有了非常大的性能提升。目前，阿里巴巴的内部Flink版本（Blink）已经开始支持内部批流融合的应用场景，例如阿里巴巴的搜索推荐算法平台，流式和批量的特征以及训练流程都已经统一基于Flink在运行。由此可见Apache Flink的技术理念已经在业界得到了大量认可，基于Flink的实时计算解决方案开始在国内占据主流趋势。

在阿里巴巴，我们发现很多经典的业务场景都是同时具备实时流处理和离线批处理两种需求，而且流处理和批处理中的业务逻辑几乎是一样的，但用户需要开发两套代码，两套集群资源部署，导致额外的成本。第二阶段由公司统一建立了大集群，提供统一的平台化服务，降低了集群资源和维护成本。

大量的性能优化。同时在Job调度和网络Shuffle两种核心机制上，都实现了灵活的插件化机制，使其能够适应批流不同场景的需求。在CEP领域，增加了更多算子支持和规则动态修改能力等，其中部分优化已经推回了社区。靖人在分享的最后宣布了阿里巴巴内部Flink版本（Blink）将于2019年1月正式开源，本次开源内部版本的目标主要是希望让广大Flink用户能提前享受到阿里巴巴对Flink的改进和贡献。

Flink默认在任何task和master失败后，都会整个Job 重启，阿里巴巴提出的region-based failover策略以及job manager failover/ha机制，让Flink可以运行的更加可靠稳定。在Flink SQL领域，阿里巴巴贡献了全新的Streaming SQL语义和功能。一方面对Flink的Job调度和资源管理进行了解耦，使得Flink可以原生运行在YARN，K8S之上。从分享的内容上可以看出，BAT三家中阿里巴巴和腾讯都已经完全拥抱了Flink。

流处理即未来接下来来自DA（Flink创始公司）的CTO - Stephan Ewen也对Flink的发展趋势给出类似的观点。在杭州，城市大脑通过实时分析4000多个交通摄像头采集的视频流，可以实时监控路上车辆的异常事件，例如：车辆超速、逆行和擦碰等，并将这些异常事件实时同步到交警指挥中心进行实时报警，目前杭州的交通事件报警已经有95%来自城市大脑自动通报的，这背后都是通过Flink进行各种复杂的计算逻辑实时算出来的。

滴滴现阶段基于Apache Flink引擎建设的实时计算平台以开源的Hadoop技术体系作为平台底座，并通过DataStream, SQL和CEP三种API向滴滴内部业务提供实时计算服务，同时在平台层也已经具备相对完善的WebIDE、数据血缘管理、监控报警和多组合隔离等机制。此外，Flink天然具备基于事件驱动的处理思想，天然的反压和流控机制，以及自带状态管理和弹性扩缩容的能力，这些优势都在促使基于Flink构建微服务框架成为一种新的思想和解决方案。

滴滴的实时业务场景主要包括实时风控、实时发券、实时异常检测，实时交易、服务和工单监控，以及实时乘客、司机和订单特征处理等。前面已经重点阐述了Flink在批流融合计算方面的进展，接下来我们重点介绍下Flink在Event-Driven Application方向的思路。通过以上两种经典场景可以看出阿里巴巴实时业务场景在各方面的挑战都很大，直接将Flink社区版本在阿里上线使用是不现实的，因此阿里巴巴实时计算团队这两年也对Flink进行了全面的优化、改进和功能扩展，其中有些功能和改进已经推回到了Flink社区。Flink在阿里巴巴另一个典型的应用场景是在线机器学习，传统的离线机器学习方法需要T+1的分析用户历史行为，训练出模型，当第二天模型上线后就已经是过去式，用户当前的需求和预期可能已经完全改变全国铁路固定资产投资完成8028亿元，其中国家铁路完成7603亿元。投产新线4683公里，其中高铁4100公里。

三是客货运双双大幅增长。铁路总公司党组书记、总经理陆东福在会上作了《奋勇担当交通强国铁路先行历史使命 努力开创新时代中国铁路改革发展新局面》的报告，总结了2018年铁路工作，分析了面临的形势和任务，部署了2019年铁路重点工作。

五是节能减排成效明显。一是运输安全保持稳定。

六是劳动生产率和职工工资收入稳步增长。到2018年底，全国铁路营业里程达到13.1万公里以上，其中高铁2.9万公里以上。

二是铁路建设成果丰硕。全国铁路完成货物发送量40.22亿吨，同比增运3.34亿吨、增长9.1%。全国铁路完成旅客发送量33.7亿人，同比增加2.9亿人、增长9.4%。新开工项目26个，新增投资规模3382亿元。

1月2日，中国铁路总公司工作会议在北京召开。国家铁路完成33.17亿人，同比增加2.78亿人、增长9.2%，其中动车组20.05亿人、同比增长16.8%。

四是经营效益迈上新台阶。国家铁路完成31.9亿吨，同比增运2.72亿吨、增长9.3%。

会议指出，2018年，全路党政工团各级组织和广大干部职工认真学习贯彻习近平新时代中国特色社会主义思想和党的十九大精神，聚焦交通强国、铁路先行，深化强基达标、提质增效，圆满完成了2018年铁路各项目标任务国家铁路完成31.9亿吨，同比增运2.72亿吨、增长9.3%。

全国铁路完成货物发送量40.22亿吨，同比增运3.34亿吨、增长9.1%。新开工项目26个，新增投资规模3382亿元。四是经营效益迈上新台阶。全国铁路完成旅客发送量33.7亿人，同比增加2.9亿人、增长9.4%。

到2018年底，全国铁路营业里程达到13.1万公里以上，其中高铁2.9万公里以上。六是劳动生产率和职工工资收入稳步增长。

二是铁路建设成果丰硕。五是节能减排成效明显。

铁路总公司党组书记、总经理陆东福在会上作了《奋勇担当交通强国铁路先行历史使命 努力开创新时代中国铁路改革发展新局面》的报告，总结了2018年铁路工作，分析了面临的形势和任务，部署了2019年铁路重点工作。国家铁路完成33.17亿人，同比增加2.78亿人、增长9.2%，其中动车组20.05亿人、同比增长16.8%。

(责任编辑：上海市)