当前位置: 首页 > 知识库问答 >
问题:

Spark on Google Cloud Kubernetes Cluster--持续驱逐执行者:工人注册并拥有充足的资源

贺博厚
2023-03-14

当我提交spark作业时:

./bin/spark-submit \
  --class org.apache.spark.examples.SparkPi \
  --master spark://spark-master:7077 \
  --executor-memory 471859200 \
  --total-executor-cores 20 \
  --deploy-mode cluster \
  /opt/spark/examples/jars/spark-examples_2.11-2.3.2.jar \
  10
/opt/spark/bin/spark-shell --master spark://spark-master:7077
sc.makeRDD(List(1,2,4,4)).count

我不断收到以下警告信息:

2020-04-18 21:14:38 WARN  TaskSchedulerImpl:66 - Initial job has not accepted any resources; check your cluster UI to ensure that workers are registered and have sufficient resources
2020-04-18 21:14:53 WARN  TaskSchedulerImpl:66 - Initial job has not accepted any resources; check your cluster UI to ensure that workers are registered and have sufficient resources
kubectl scale deployment spark-worker --replicas 2 (or any other number, works fine)

本地模式运行成功:

/opt/spark/bin/spark-submit --class org.apache.spark.examples.SparkPi --master local[2] /opt/spark/examples/jars/spark-examples_2.11-2.3.2.jar 10
kubectl exec -it spark-master-dc7d76bf5-dthvn bash

暂时还没有答案

 类似资料:
  • 我在Cassandra上创建了一个文本数据选择程序。这是我的代码。这只是一个简单的选择所有数据并显示在控制台。 这是什么意思?难道师傅和工人之间没有减刑?多谢

  • 问题内容: 我正在尝试从运行火花示例,并得到以下一般性错误: 我使用的版本是我使用Shell中的命令启动spark ,然后将我设置为: 我没有在这里添加任何其他代码,因为此错误在我正在运行的任何示例中都会弹出。这台机器是Mac OSX,我很确定它有足够的资源来运行最简单的示例。 我想念什么? 问题答案: 该错误表明您的集群没有足够的资源用于当前作业。由于尚未启动从属服务器,即worker。集群将没

  • 10.7. 资源所有者密码凭据 资源所有者密码凭据许可类型通常用于遗留或迁移原因。它降低了由客户端存储用户名和密码的整体风险,但并没有消除泄露高度特权的凭证给客户端的需求。 这种许可类型比其他许可类型承载了更高的风险,因为它保留了本协议寻求避免的密码反模式。客户端可能滥用密码或密码可能会无意中被泄露给攻击者(例如,通过客户端保存的日志文件或其他记录)。 此外,由于资源拥有者对授权过程没有控制权(在

  • 我一直在寻找这样一种情况的解决方案:我有一个调用项的哈希集,并且我要将这个集提交给执行器进行并行执行。现在我想只要任何提交的任务完成,我应该能够分配一个新的Callable到Executor。 我尝试了这段代码,但是如果我使用Executor.Invoke,那么Executor将等待直到所有任务完成,如果我使用Executor.Submit,那么任务将按顺序完成。如有任何帮助,我们将不胜感激。

  • void register_resource(string name, array resource_funcs) Use this to dynamically register a resource plugin with Smarty. Pass in the name of the resource and the array of PHP functions implementing i

  • 嗨,我想写注册机器人。 我在python中使用selenium,一开始我遇到了以下问题。 有了它,我可以找到注册链接,但当我试图点击它时,它会给我: 我是不是很难适应这种环境?如何在由find_elements_by_something创建的列表中的元素上执行单击功能?