Jiayi Liao

Reproduce exception with PriorityQueue with lambda expression

2

The pull request is to reproduce the exception described in https://github.com/twitter/chill/issues/421 Set the java version to 1.8 because the problem is about java 1.8 lambda expression.

Java8 lambda expression in PriorityQueue cannot be serialized

4

When I'm using `PriorityQueueSerializer` from chill-java package, I got NPE when serializing `PriorityQueue` instance like this: ``` PriorityQueue pq = new PriorityQueue((o1, o2) -> o1.length() - o2.length() - 1); pq.add("1234135");...

[社招/实习][字节跳动]推荐中台-大数据计算方向

3

**薪资范围**：[30k-80k] **薪资月份**：16薪 **工作地点**：深圳 **年限要求**：3-5/5-10 年 ## 职位描述 团队介绍：字节跳动推荐架构团队大数据计算方向，负责字节跳动旗下海量用户推荐系统架构实时计算系统的设计和研发，抽象通用实时计算系统，构建统一的特征中台，实现灵活可扩展的高性能存储和计算模型，为推荐业务实现先进的消重、计数、特征等实时数据系统。 1、为大规模推荐系统设计和实现合理的流式计算系统； 2、设计和实现灵活可扩展、稳定、高性能存储系统和计算模型； 3、生产系统的trouble-shooting，设计和实现必要的机制和工具保障生产系统稳定运行； 4、打造业界领先的流式计算框架等分布式系统，为海量数据和大规模业务系统提供可靠的基础设施。 ## 职位要求 1、对流式计算系统有深入的了解，有大规模实时计算系统开发经验，有Flink源码阅读经验优先； 2、熟悉常见消息队列原理和应用调优，有Kafka、Plusar、RocketMQ等项目源码阅读经验优先； 3、熟悉Java、C++、Scala、Python等编程语言，有扎实的编码和trouble-shooting能力； 4、有以下经验者优先：数据湖技术、Yarn、K8S、Spark、SparkSQL等。 ## 职位亮点 部门直招、核心部门、核心岗位新 base ## 联系方式 微信：bupt_ljy（组内同学，部门直招）

I'll translate it very soon. Please mark it as claimed. Thanks.

[FLINK-5601][Checkpointing] Watermark checkpointing

5

## What is the purpose of the change This pull request uses ListState in TimestampsAndPeriodicWatermarksOperator.java and TimestampsAndPunctuatedWatermarksOperator.java to checkpoint watermark. During recovering process, it uses union state to find the...