[jira] [Closed] (FLINK-8103) Flink 1.4 not writing to standard out log file
[ https://issues.apache.org/jira/browse/FLINK-8103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Brideau closed FLINK-8103. --- Resolution: Fixed > 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)
[jira] [Closed] (FLINK-8103) Flink 1.4 not writing to standard out log file
[ https://issues.apache.org/jira/browse/FLINK-8103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8103. --- Resolution: Not A Problem > 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)