背景计划将之前部署好的flink1.10升级到1.11.2。主要流程及踩坑1.从官方下载flink1.11.2的压缩包，选择与业务程序中导入的maven依赖scala版本一致即可（本人选用的是2.11）。flink压缩包官方下载链接2.修改对应的配置文件（yarn模式下只需配置flink-conf.yaml， 如果是使用flink自己的资源调度则简单配置masters、workers文件即可）。f

背景最近公司要搭建大数据系统，架构师推荐使用flink来搭建这套系统。所以我这边这天在自己的虚拟机环境（Ubuntu16.4）下调研玩一下Flink。从ververica上学习了一下flink的基础知识，因为之前是做python数据处理分析的工作，最近才学习Java，还没有专门学习maven的相关知识。所以从FLINK官方教程拉了一份JAVA的项目模板，并从ververica里找了一份大佬...

环境flink1.11.2JAVAstream APItimewindow背景公司之前的指标是以分钟为单位的滚动窗口进行检查，然后在查询系统里查询的时候，对该天所有的分钟数据进行聚合统计。当前需要在flink中添加以天为单位的Job进行额外指标检查。指标出来之后和发现数据口径不一致，flink中默认是timeWindow按天进行滚动统计的数据是每天八点到第二天八点的数据。导致统计指标的含义对不上，

错误描述Exception in thread "main" com.alibaba.fastjson.JSONException: syntax error, expect {, actual string, pos 40, line 1, column 41"{\"hh\":\"159\",\"test\":\"aa\",59:16}"背景公司的后台服务是基于Springboot+...