apache-flink - Flink Operator 字数统计教程:控制台输出在哪里?
问题描述
遵循用户指南: https ://github.com/GoogleCloudPlatform/flink-on-k8s-operator/blob/master/docs/user_guide.md
安装操作员后,我尝试创建此处提供的相同作业集群:
和:
kubectl apply -f config/samples/flinkoperator_v1beta1_flinkjobcluster.yaml
几分钟后完成。我检查日志:
kubectl logs job/flinkjobcluster-sample-job
我看到以下内容。字数统计作业的控制台输出在哪里?
Checking existing jobs...
Waiting for response...
No running jobs.
No scheduled jobs.
Submitting job...
/opt/flink/bin/flink run --jobmanager flinkjobcluster-sample-jobmanager:8081 --class org.apache.flink.streaming.examples.wordcount.WordCount --parallelism 2 --detached ./examples/streaming/WordCount.jar --input ./README.txt
Starting execution of program
Printing result to stdout. Use --output to specify output path.
Job has been submitted with JobID 15a5caed4cdd3e0de0686dd9994e03c1
Waiting for job to finish...
Waiting for response...
------------------ Running/Restarting Jobs -------------------
07.04.2021 16:48:56 : 15a5caed4cdd3e0de0686dd9994e03c1 : Streaming WordCount (RUNNING)
--------------------------------------------------------------
No scheduled jobs.
07.04.2021 16:48:56 : 15a5caed4cdd3e0de0686dd9994e03c1 : Streaming WordCount (RUNNING)
Found an active job.
Waiting for job to finish...
Waiting for response...
No running jobs.
No scheduled jobs.
---------------------- Terminated Jobs -----------------------
07.04.2021 16:48:56 : 15a5caed4cdd3e0de0686dd9994e03c1 : Streaming WordCount (FINISHED)
--------------------------------------------------------------
07.04.2021 16:48:56 : 15a5caed4cdd3e0de0686dd9994e03c1 : Streaming WordCount (FINISHED)
Job has completed successfully, exiting 0
解决方案
推荐阅读
- java - How can I read into a webpage non-linked text with jsoup?
- hyperledger-fabric - 为什么 indy/sovrin 将声明/可验证凭证/证明存储在分类帐中
- javascript - 如何使用 json 服务器更新嵌套数组中对象中的值?
- r - 如何使用 R 找到这个问题的输出
- java - 当我单击任何 RecyclerView 列表项时,如何在 MainActivity 的 EditText 中显示该特定单击项?
- javascript - 使用 React + Redux 获取所有选中的复选框及其相关数据
- docker - 错误:对于 redis 无法为服务 redis 创建容器:源不是目录
- mysql - AWS,将 Sql Server 迁移到 MySql,从一个区域到另一个区域
- ios - 需要 Xcode 管理员角色吗?
- mongodb - mongodb聚合:如果两个字段的值匹配,则将对应字典的另一个字段的值添加到新字段中