flink1.9.1升级到flink1.12.1有什么改变

这篇文章给大家分享的是有关flink1.9.1升级到flink1.12.1有什么改变的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。在1.10和_1.11_版本中，Flink 分别对TaskManager和JobManager的内存配置方法做出了较大的改变。 部分配置参数被移除了，或是语义上发生了变化。jobmanager.heap.sizejobmanager.heap.mb尽管这两个参数以“堆（Heap）”命名，在此之前它们实际上只有在独立部署模式才完全对应于JVM 堆内存。 在容器化部署模式下（Kubernetes和Yarn），它们指定的内存还包含了其他堆外内存部分。JVM 堆空间的实际大小，是开发云主机域名参数指定的大小减去容器切除（Cut-Off）内存后剩余的部分。 容器切除内存在1.11及以上版本中已被彻底移除。上述两个参数此前对Mesos部署模式并不生效。 Flink 在 Mesos 上启动 JobManager 进程时并未设置任何 JVM 内存参数。 从1.11版本开始，Flink 将采用与独立部署模式相同的方式设置这些参数。这两个配置参数目前已被弃用。 如果配置了上述弃用的参数，同时又没有配置与之对应的新配置参数，那它们将按如下规则对应到新的配置参数。独立部署模式（Standalone Deployment）、Mesos 部署模式下：JVM 堆内存（jobmanager.memory.heap.size）容器化部署模式（Containerized Deployement）下（Kubernetes、Yarn）：进程总内存（jobmanager.memory.process.size）建议您尽早使用新的配置参数取代启用的配置参数，它们在今后的版本中可能会被彻底移除。如果仅配置了Flink 总内存或进程总内存，那么JVM 堆内存将是总内存减去其他内存部分后剩余的部分。 请参考如何配置总内存。 此外，也可以通过配置jobmanager.memory.heap.size的方式直接指定JVM 堆内存。新的内存配置要求用户至少指定下列配置参数（或参数组合）的其中之一，否则 Flink 将无法启动。在原本的内存配置方法中，用于指定JVM 堆内存的配置参数是:修改配置jobmanager.heap.size: 1024m –>jobmanager.memory.process.size: 1024mtaskmanager.heap.size: 2048m –>taskmanager.memory.flink.size: 2048mflink的版本升级：1.9.1 –>1.12.1kafka connector版本升级：flink-connector-kafka-0.11_${scala.binary.version} –> flink-connector-kafka_2.11废弃方法去除：env.getConfig().disableSysoutLogging(); –> //env.getConfig().disableSysoutLogging();消费者：FlinkKafkaConsumer011 consumer = new FlinkKafkaConsumer011( –> FlinkKafkaConsumer consumer = new FlinkKafkaConsumer(感谢各位的阅读！关于“flink1.9.1升级到flink1.12.1有什么改变”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！

相关推荐: 大数据中创建云硬盘失败的解决过程是怎样的

本篇文章为大家展示了大数据中创建云硬盘失败的解决过程是怎样的，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。登录dashboard，点击创建云硬盘失败，而且是点击完就直接报error错误。思路一：新上传的image镜像，…