魔琴编程网
  • apache-spark/
  • Apache spark JavaDStream print（）函数未打印

Apache spark JavaDStream print（）函数未打印

apache-spark

Apache spark JavaDStream print（）函数未打印,apache-spark,spark-streaming,Apache Spark,Spark Streaming,我是个新手。 我通过以下链接阅读了教程： 当我运行代码时，我可以看到行正在被处理，但是我看不到带有时间戳的输出 我只能看到这个日志： 14/10/22 15:24:17 INFO scheduler.ReceiverTracker: Stream 0 received 0 blocks 14/10/22 15:24:17 INFO scheduler.JobScheduler: Added jobs for time 1414005857000 ms ..... 我还试图用forEachRDD

我是个新手。 我通过以下链接阅读了教程：

当我运行代码时，我可以看到行正在被处理，但是我看不到带有时间戳的输出

我只能看到这个日志：

14/10/22 15:24:17 INFO scheduler.ReceiverTracker: Stream 0 received 0 blocks
14/10/22 15:24:17 INFO scheduler.JobScheduler: Added jobs for time 1414005857000 ms
.....
我还试图用forEachRDD函数调用保存最后一个数据流，数据没有被存储。
如果有人能帮我做这件事，那将是一个很大的帮助。

打印正在工作，如
分隔符所示。
只是没有什么可打印的：数据流是空的。提供的日志实际上显示：
流0接收到0个块

确保正确地将数据发送到接收器。

打印工作正常，可用
..
分隔符来证明，只是没有要打印的内容：数据流为空。提供的日志实际上显示：
流0接收到0个块

确保正确地将数据发送到接收器。

打印工作正常，可用
..
分隔符来证明，只是没有要打印的内容：数据流为空。提供的日志实际上显示：
流0接收到0个块

确保正确地将数据发送到接收器。

打印工作正常，可用
..
分隔符来证明，只是没有要打印的内容：数据流为空。提供的日志实际上显示：
流0接收到0个块

确保将数据正确发送到接收器。

我遇到了同样的问题，以下是我的解决方法：

改变

val conf = new SparkConf().setMaster("local")
到

setMaster（“本地”）
是一个错误，它实际上不会计算

希望这就是你遇到的问题。

我遇到了同样的问题，下面是我如何解决的：

val conf = new SparkConf().setMaster("local[*]") works
改变

val conf = new SparkConf().setMaster("local")
到

setMaster（“本地”）
是一个错误，它实际上不会计算

希望这就是你遇到的问题。

我遇到了同样的问题，下面是我如何解决的：

val conf = new SparkConf().setMaster("local[*]") works
改变

val conf = new SparkConf().setMaster("local")
到

setMaster（“本地”）
是一个错误，它实际上不会计算

希望这就是你遇到的问题。

我遇到了同样的问题，下面是我如何解决的：

val conf = new SparkConf().setMaster("local[*]") works
改变

val conf = new SparkConf().setMaster("local")
到

setMaster（“本地”）
是一个错误，它实际上不会计算

希望这就是你遇到的问题

val conf = new SparkConf().setMaster("local[*]") works

local[*]
：“
*
”表示创建与CPU内核号相同的工作线程
如果使用“local”，则不会创建worker，为什么默认值不是1，这不是一个问题吗？ 提到 

local[*]
：“
*
”表示创建与CPU内核号相同的工作线程
如果使用“local”，则不会创建worker，为什么默认值不是1，这不是一个问题吗？ 提到 

local[*]
：“
*
”表示创建与CPU内核号相同的工作线程
如果使用“local”，则不会创建worker，为什么默认值不是1，这不是一个问题吗？ 提到 

local[*]
：“
*
”表示创建与CPU内核号相同的工作线程
如果使用“local”，则不会创建worker，为什么默认值不是1，这不是一个问题吗？ 提到

我正在获取数据，但20秒后。你知道如何用卡夫卡做流媒体吗。现在我坚持卡夫卡。我得到了数据，但要等到RDD的print（）函数才能得到。很难说。我想你需要用你正在使用的代码发布一个新问题。我正在获取数据，但20秒后。你知道如何用卡夫卡做流媒体吗。现在我坚持卡夫卡。我得到了数据，但要等到RDD的print（）函数才能得到。很难说。我想你需要用你正在使用的代码发布一个新问题。我正在获取数据，但20秒后。你知道如何用卡夫卡做流媒体吗。现在我坚持卡夫卡。我得到了数据，但要等到RDD的print（）函数才能得到。很难说。我想你需要用你正在使用的代码发布一个新问题。我正在获取数据，但20秒后。你知道如何用卡夫卡做流媒体吗。现在我坚持卡夫卡。我得到了数据，但要等到RDD的print（）函数才能得到。很难说。我想你需要用你正在使用的代码发布一个新问题。这是对该问题的回答还是对另一个答案的评论？这是对该问题的回答还是对另一个答案的评论？这是对该问题的回答还是对另一个答案的评论？这是对该问题的回答还是对另一个答案的评论？