问题描述
我正在尝试运行 Spark 流文档中提到的简单字数统计示例。当我放置 conf.setMaster("local[*]") 时，java 应用程序运行并给出输出 使用独立模式时 - conf.setMaster("spark://localhost:7077") - 作业卡在长时间运行/永无止境的阶段。
我可以在我的 Java 应用程序中看到的日志：
使用 Spark 的默认 log4j 配置文件：org/apache/spark/log4j-defaults.properties 21/04/20 19:37:36 警告 NativeCodeLoader：无法为您的平台加载本机 Hadoop 库...在适用的情况下使用内置 Java 类 21/04/20 19:37:39 警告 KafkaUtils：将执行程序的 enable.auto.commit 覆盖为 false 21/04/20 19:37:39 警告 KafkaUtils：将执行程序的 auto.offset.reset 覆盖为 none 21/04/20 19:37:39 警告 KafkaUtils：覆盖执行程序 group.id 到 spark-executor-spark-stream 21/04/20 19:37:39 警告 KafkaUtils：将 receive.buffer.bytes 覆盖为 65536，参见 KAFKA-3135 21/04/20 19:37:40 警告 SizeEstimator：无法检查是否设置了 UseCompressedOops；假设是 21/04/20 19:37:49 警告 ProcfsMetricsGetter：尝试计算页面大小时出现异常，因此停止报告 Processtree 指标 21/04/20 19:37:55 WARN TaskSchedulerImpl：初始作业未接受任何资源；检查您的集群 UI 以确保工作人员已注册并拥有足够的资源 21/04/20 19:38:10 WARN TaskSchedulerImpl：初始作业未接受任何资源；检查您的集群 UI 以确保工作人员已注册并拥有足够的资源
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）