|
|
最近对flink（1.7）提交任务问题有些疑问，从官方文档看 一般采用getExecutionEvironment或者createRemoteEvironment可以实现代码在本地或者远程的提交，但这种模式感觉代码和生成的jar关系比较紧密，提交过程与代码逻辑也在一起，在生成环境中可以用变量的方式，通过remoteEvironment来向目的flink集群提交任务吗？其他程序启动这个任务时执行java -jar的方式？
Flink有没有提供客户端代码直接将jar提交到远程集群中，看官方文档提供的 PackageProgram,然后通过client提交，不知道那个client是哪个client,找不到对应的类。
请问一下在生产环境中，一个flink批处理可能是整个业务流程的一个环节，一般是怎么通过代码提交批处理任务和启动流处理任务比较合适？
发自我的iPhone
|
Locked
