基于 Flink Scala 快速入门，我创建了一个使用 org.apache.flink.streaming.connectors.twitter.TwitterSource 的示例作业.
我正在使用本地流作业管理器 /start-local-streaming.sh ，然后使用 ~/flink-0.10.0/bin/flink run target/quickstart-0.1.jar 开始工作
在 TwitterSource 源代码中，我注意到有 INFO 级别的日志语句。我怎样才能将这些记录到控制台？
最佳答案
Flink 守护进程在后台启动，这就是 Flink 记录到 log/ 中的日志文件的原因。目录。
要监视这些文件，请使用 tail -f log/* 。这将在控制台上打印日志条目。
另一种方法是更改 Flink 的启动脚本以在前台启动它+更改 conf/log4j.properties文件以使用 ConsoleAppender .
关于scala - 如何打开 TwitterSource 的控制台日志记录，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/34087246/