这个不科学的，不能因为迟到的一点数据而让整体跟着延迟，就算是可以，中间值也会非常大，吃完了内存。

要求还蛮高，计算结果会在厂家的大屏上显示。
延迟一般都是硬件故障导致的，目前还想不到很好的办法。延迟的消息只能直接在 filter 过滤了，不会计算，所以影响不了当前的计算结果。

消息里面有 eventtime，但是有些消息相隔几个小时，甚至几天再上来。因为消息是从硬件开始上报 mqtt，再转 kafka 的。

文章写得很棒！特别是 checkpoint 的部分。
发现个小问题，wordCount 的例子缺少了 try catch，Flink 算子有个很坑的点，一旦没捕捉异常，就会一直重启。
流式计算依赖消息的顺序性，要是消息不能保证顺序，这个点就很蛋疼。
我们用 Flink 做实时计算，同时还把 Kafka 持久化到 Hbase，实时计算出现偏差时，再用 Spark 去离线重算一遍。

1.有，解决公司现存问题的工具就是好工具
2.亲自执行一遍测试工作流
3.肯定是 web，因为浏览器每个人都有，并且更新后所有人只需要刷新页面就能同步到最新功能。

这错别的地方有点多啊
2020.12 月？
收货？
下层？

试了各种方式传参，终于搞定了~~

# 方法签名
public PageModel<ShiftStopInfo> queryByPage(PageModel<ShiftStopInfo> pageModel, StopSearchParam searchParam);

想问一下泛型，还有实体参数的时候，应该怎么入参

queryByPage(Listl<Msg> listMsg, SearchParam sp)

可惜，现在上班不用打卡了

直接通过正则表达式来判断的，if else 很难覆盖

• 资本家的想法是快速搞钱。至于什么瑕疵，用户体验只是一些凤毛麟角的事情罢了。
• 另外，这不是打工人应该思考的问题。

吓得我赶紧弄多一个地方备份

是啊，人生是长跑，前面不打基础。后面还想要追的上，就必须要疯狂加速（加班）。

setattr 不行，直接赋值是可以的 obj.func=func

感觉可以参考简书，每天限制发两篇文章

我也很好奇 th 是什么的缩写？？？

瞎几把写的，招聘需求上面都是复制粘贴。至于为什么写 RF 而不是其他的，可能是因为这个历史比较悠久，知名度高。

发现一个错别字，性能优化下面的应该是 “压缩 “吧，写成了” 压测 “
想知道一下，gzip 压缩后能够提升多少性能

期待！

正常情况都会给，除非很机密的代码。我们研发还是很乐意我进行代码 review。甚至还一步步跟我讲解实现的思路，感觉很棒。

代码中是不是漏了导入 telnetlib 这个包
server_post 的命名应该是 server_port？

按照文档部署了，使用 Telnet 测试成功，但是使用平台测试不成功

楼主，想了解一下 post 请求两次发包的详细过程，用 Chrome 浏览器没有复现这个过程，有什么工具可以推荐吗

内置方法不会是冒泡排序的。
我想说的是，面试实现排序算法肯定就是想面试者自己实现算法，而不是直接调用内置函数