Apache Flink 1.14 新特性预览 - OSCHINA
Java 最长代码限制,新的代码生成器会对代码进行拆解,彻底解决代码超长的问题。 ■ 1.3 移除 Flink Planner 新版本中,Blink Planner 将成为 Flink Planner 的唯一实现。 2. Python API 在之前的版本中,如果有先后执行的两个 UDF,它的执行过程如下图左方。在 JVM 上面有 Java 的 Operator,先把数据发给 Python 下面的 UDF 去执行,执行后又发回给 Java,然后传送给下游的 Operator,最后再进行一次 Python 的这种跨进程的传输去处理,会导致存在很多次冗余的数据传输。 在 1.14 版本中,改进如右图,可以把它们连接在一起,只需要一个来回的 Java 和 Python 进行数据通信,通过减少传输数据次数...阅读全文