首页 > 解决方案 > Flink Operator 字数统计教程:控制台输出在哪里?

问题描述

遵循用户指南: https ://github.com/GoogleCloudPlatform/flink-on-k8s-operator/blob/master/docs/user_guide.md

安装操作员后,我尝试创建此处提供的相同作业集群:

https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/blob/master/config/samples/flinkoperator_v1beta1_flinkjobcluster.yaml

和:

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

标签: apache-flink

解决方案


推荐阅读