Flink：如何将额外的JVM选项传递给TaskManager和JobManager
我正在尝试使用以下命令提交flink关于纱线的作业：
/usr/flink-1.3.2/bin/flink run -yd -yn 1 -ynm MyApp -ys 1 -yqu default -m yarn-cluster -c com.mycompany.Driver -j /usr/myapp.jar -Denv.java.opts="-Dzkconfig.parent /app-config_127.0.0.1 -Dzk.hosts localhost:2181 -Dsax.zookeeper.root /app"
我拿到了env。Java语言选择flink客户端日志，但当应用程序提交到Thread时，这些Java选项将不可用。由于额外的JVM选项不可用，应用程序在连接zookeeper时引发异常。
请建议如何将动态属性传递给JM
注意：我试图设置env。Java语言将选项选择到conf/flink-conf.yaml及其工作状态。我需要一种通过flink run命令设置此选项的方法。
共有2个答案
抱歉回复较晚，但我相信您在YARN上启动了一个长时间运行的Flink会话，然后您通过-Dxxx=yyy设置的参数将被转发到这在YARN中创建的JM/TM。你试过这种方法吗？
我认为你应该更换Denv。Java语言由yD env选择。Java语言选择使您的命令变为：
/usr/flink-1.3.2/bin/flink run -yd -yn 1 -ynm MyApp -ys 1 -yqu default -m yarn-cluster -c com.mycompany.Driver -j /usr/myapp.jar -yD env.java.opts="-Dzkconfig.parent /app-config_127.0.0.1 -Dzk.hosts localhost:2181 -Dsax.zookeeper.root /app"
-
问题内容： 我正在开发与远程主机进行通信的简单Spring Web应用程序，我想在公司代理之后在本地对其进行测试。我使用“ Spring Boot” gradle插件，问题是 如何为JVM指定代理设置？ 我尝试了几种方法来做到这一点： 但是似乎它们都不起作用-“ NoRouteToHostException”抛出“网络”代码。另外，我添加了一些额外的代码来调试JVM启动参数： 并且仅打印一个参数：
-
问题内容： 我有以下功能。WordPress功能，但这实际上是一个PHP问题。它们根据每个对象的元数据中的属性对我的对象进行排序。 我想在第一个函数中传递一个字符串。这将使我可以重复使用此代码，因为我可以将其应用于各种元数据属性。 但是我不明白如何将 额外的 参数传递给usort回调。我试图制作一个JS风格的匿名函数，但是服务器上的PHP版本太旧，并引发了语法错误。 非常感谢您提供的任何帮助-或将
-
根据文档，sbt 分叉进程应接收当前进程的 jvm 设置： 默认情况下，分叉的进程使用与当前进程的构建、工作目录和JVM选项相同的Java和Scala版本。参见:http://www.scala-sbt.org/0.13/docs/Forking.html 然而，对我来说似乎不是这样。参加以下测试： 如果我使用sbt-Dconfig.resource=test来运行它。然后打印“conf:test
-
问题内容： 在我的 JSF 2.0 （在 JBoss AS 7上 ）项目中，我希望在我的Ajax提交的表单上显示一个在开始和完成阶段触发的小图标状态，以使最终用户知道仍有事情发生。 该primefaces是没有用在这里，因为我想有在我的网页不同的地方很多不同的图标。 我在此问题中找到了一些解决方案：“如何在同一输入中显示不同的ajax状态？”，但是我仍然有一个问题：为了使我的javascript函
-
我正在开发与远程主机通信的简单Spring web应用程序，我想在公司代理后对其进行本地测试。我使用“Spring Boot”gradle插件，问题是如何为JVM指定代理设置？ 我试过几种方法： 如果在代码中设置系统属性： 一切正常！
-
问题内容： 我有一个函数，将回调函数作为参数，并用一个参数调用它。 我还有一个带有两个参数的函数：和。 我想将函数作为参数传递给，但我也想作为第二个参数（）传递给。我怎样才能做到这一点？ 问题答案： 只需创建一个包装回调： 或使用ECMAScript 6箭头功能：