We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
脚本管理中flink批处理 输入输出output参数有什么用?
在代码视图和 后台代码中都没看到这个作用
比如input output参数这样 flink run -m yarn-cluster -yjm 1024 -ytm 1024 -ys 1 -yqu root.users.root -ynm WordCountDemos -d -yD ypu=root /tmp/hdfs_pkg/2020101520/5509WordCount.jar --allocate.balancer.type=available \ -input hdfs://10.3.87.23:8020/data/flink/GoneWiththeWind.txt \ -output hdfs://10.3.87.23:8020/data/flink/wordcount-result-1.txt
flink run -m yarn-cluster -yjm 1024 -ytm 1024 -ys 1 -yqu root.users.root -ynm WordCountDemos -d -yD ypu=root /tmp/hdfs_pkg/2020101520/5509WordCount.jar --allocate.balancer.type=available \ -input hdfs://10.3.87.23:8020/data/flink/GoneWiththeWind.txt \ -output hdfs://10.3.87.23:8020/data/flink/wordcount-result-1.txt
The text was updated successfully, but these errors were encountered:
这两个参数主要是为了排查问题用的,方便管理员查看脚本的输入和输出,在程序运行方面目前是没有实际用途,后续会考虑该参数的扩展应用。
Sorry, something went wrong.
好的,谢谢
No branches or pull requests
脚本管理中flink批处理 输入输出output参数有什么用?
在代码视图和 后台代码中都没看到这个作用
比如input output参数这样
flink run -m yarn-cluster -yjm 1024 -ytm 1024 -ys 1 -yqu root.users.root -ynm WordCountDemos -d -yD ypu=root /tmp/hdfs_pkg/2020101520/5509WordCount.jar --allocate.balancer.type=available \ -input hdfs://10.3.87.23:8020/data/flink/GoneWiththeWind.txt \ -output hdfs://10.3.87.23:8020/data/flink/wordcount-result-1.txt
The text was updated successfully, but these errors were encountered: