You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/04/08 12:00:00 UTC
[jira] [Closed] (FLINK-9307) Running flink program doesn't print
infos in console any more
[ https://issues.apache.org/jira/browse/FLINK-9307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek closed FLINK-9307.
-----------------------------------
Resolution: Won't Fix
This is a side effect of switching to the REST API quite a while ago.
> Running flink program doesn't print infos in console any more
> -------------------------------------------------------------
>
> Key: FLINK-9307
> URL: https://issues.apache.org/jira/browse/FLINK-9307
> Project: Flink
> Issue Type: Improvement
> Components: Command Line Client
> Affects Versions: 1.6.0
> Environment: Mac OS X 12.10.6
> Flink 1.6-SNAPSHOT commit c8fa8d025684c222582 .
> Reporter: Zili Chen
> Priority: Critical
>
> As shown in [this page|https://ci.apache.org/projects/flink/flink-docs-master/quickstart/setup_quickstart.html#run-the-example], when flink run program, it should have printed infos like
> {code:java}
> Cluster configuration: Standalone cluster with JobManager at /127.0.0.1:6123
> Using address 127.0.0.1:6123 to connect to JobManager.
> JobManager web interface address http://127.0.0.1:8081
> Starting execution of program
> Submitting job with JobID: 574a10c8debda3dccd0c78a3bde55e1b. Waiting for job completion.
> Connected to JobManager at Actor[akka.tcp://flink@127.0.0.1:6123/user/jobmanager#297388688]
> 11/04/2016 14:04:50 Job execution switched to status RUNNING.
> 11/04/2016 14:04:50 Source: Socket Stream -> Flat Map(1/1) switched to SCHEDULED
> 11/04/2016 14:04:50 Source: Socket Stream -> Flat Map(1/1) switched to DEPLOYING
> 11/04/2016 14:04:50 Fast TumblingProcessingTimeWindows(5000) of WindowedStream.main(SocketWindowWordCount.java:79) -> Sink: Unnamed(1/1) switched to SCHEDULED
> 11/04/2016 14:04:51 Fast TumblingProcessingTimeWindows(5000) of WindowedStream.main(SocketWindowWordCount.java:79) -> Sink: Unnamed(1/1) switched to DEPLOYING
> 11/04/2016 14:04:51 Fast TumblingProcessingTimeWindows(5000) of WindowedStream.main(SocketWindowWordCount.java:79) -> Sink: Unnamed(1/1) switched to RUNNING
> 11/04/2016 14:04:51 Source: Socket Stream -> Flat Map(1/1) switched to RUNNING
> {code}
> but when I follow the same command, it just printed
> {code:java}
> Starting execution of program
> {code}
> Those message are printed properly if I use flink 1.4, and also logged at `log/flink-<username>-taskexecutor-0-localhost.log` when running on 1.6-SNAPSHOT.
> Now it breaks [this pull request|https://github.com/apache/flink/pull/5957] and [~Zentol] suspects it's a regression.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)