[
https://issues.apache.org/jira/browse/FLINK-8103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16265321#comment-16265321
]
Aljoscha Krettek commented on FLINK-8103:
-----------------------------------------
I just ran an example like this on the (just-released) RC1 for Flink 1.4.0. The
output was in fact in the .out file of the TaskManager. Could you try it with
that as well?
RC1: http://people.apache.org/~aljoscha/flink-1.4.0-rc1/
> Flink 1.4 not writing to standard out log file
> ----------------------------------------------
>
> Key: FLINK-8103
> URL: https://issues.apache.org/jira/browse/FLINK-8103
> Project: Flink
> Issue Type: Bug
> Components: Core
> Affects Versions: 1.4.0
> Environment: macOS 10.13 (High Sierra)
> Reporter: Ryan Brideau
>
> I built the latest snapshot of 1.4 yesterday and tried testing it with a
> simple word count example, where StreamUtil is just a helper that checks
> input parameters:
> {code:java}
> import org.apache.flink.api.java.utils.ParameterTool
> import org.apache.flink.streaming.api.scala._
> object Words {
> def main(args: Array[String]) {
> // set up the execution environment
> val env = StreamExecutionEnvironment.getExecutionEnvironment
> val params = ParameterTool.fromArgs(args)
> env.getConfig.setGlobalJobParameters(params)
> val dataStream = StreamUtil.getDataStream(env, params)
> val wordDataStream = dataStream
> .flatMap{ _.split(" ") }
> wordDataStream.println
> // execute program
> env.execute("Words Scala")
> }
> }
> {code}
> This runs without an issue on the latest stable version of 1.3 and writes its
> results to the _out_ file, which I can tail to see the results. This doesn't
> happen in 1.4, however. I can modify it to write out to a file, however:
> {code:java}
> import org.apache.flink.api.java.utils.ParameterTool
> import org.apache.flink.core.fs.FileSystem.WriteMode
> import org.apache.flink.streaming.api.scala._
> object Words {
> def main(args: Array[String]) {
> // set up the execution environment
> val env = StreamExecutionEnvironment.getExecutionEnvironment
> val params = ParameterTool.fromArgs(args)
> env.getConfig.setGlobalJobParameters(params)
> val dataStream = StreamUtil.getDataStream(env, params)
> val wordDataStream = dataStream
> .flatMap{ _.split(" ") }
> wordDataStream
> .writeAsText("file:///somepath/output", WriteMode.OVERWRITE)
> .setParallelism(1)
> // execute program
> env.execute("Words Scala")
> }
> }
> {code}
> Any clues as to what might be causing this?
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
