Apache Flink 1.11.1 发布
Apache Flink 1.11.1已发布,Apache Flink 是一个框架和分布式处理引擎,用于在无边界和有边界数据流上进行有状态的计算。Flink 能在所有常见集群环境中运行,并能以内存速度和任意规模进行计算。 此版本是 Apache Flink 1.11系列的首个 Bugfix 版本,总共包含 44个针对 Flink 1.11.0 的修复程序以及改进。官方强烈建议所有用户升级到 Flink 1.11.1。 部分更新内容 Bugfix [FLINK-15414] - 修复 KafkaITCase#prepare 在 travis 中出现崩溃的问题 [FLINK-16181] - 修复 IfCallGen 会对 blink 中的基元类型(primitive types)抛出 NPE 的问题 [FLINK-17543] - 修复上传日志时,重新运行失败的 azure 作业会再次失败的问题 [FLINK-18097] - 修复 History 服务器没有清理所有 job json 文件的问题 [FLINK-18419] - 修复无法从用户的 jar 包中创建目录的问题 [FLINK...