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

如何解决spark-shell中的错误“org.apache.spark.sparkException:请求的分区不匹配tablename表”

闻枫
2023-03-14

请求的分区:

表分区:类别、状态

hive>描述格式化的sparkhive6;

共有1个答案

仲君昊
2023-03-14

尝试使用insertinto()函数代替saveastable()

scala> data1.write.format("hive")
.partitionBy("category", "state")
.mode("append")
.insertInto("sampleb.sparkhive6")

(或)

在dataframe的顶部注册一个临时视图,然后write with sql语句将数据插入到配置单元表中。

scala> data1.createOrReplaceTempView("temp_vw")
scala> spark.sql("insert into sampleb.sparkhive6 partition(category,state) select txnno,txndate,custno,amount,product,city,spendby,category,state from temp_vw")
 类似资料:
  • 问题内容: 我已经在Fxml中使用onEditCommit事件在用户编辑数据后检索数据。 FXML代码-: 实现了onEditCommit事件-: 错误-: 完整代码-: Record.java(获取设置程序) 请帮助我解决此错误,应在onEditCommit事件实现中放置哪种类型。我已经打印了列单元格值工厂 并得到 EditingCell.java-: 问题答案: 您的事件处理程序类型对我来说不

  • 我是Spring开机Rest服务的新手。我已经使用maven项目在spring boot中开发了一些rest api。 我已经成功地开发了Get和Post API。我的GET方法在邮递员和移动中工作正常。当我试图从邮递员击中邮政方法,它工作正常,但从移动,它给出403禁止错误。 这是我的配置: 请建议我如何解决错误。

  • 问题内容: 我已经开发了一个PHP网络应用程序。我给用户一个选项,可以一次更新多个问题。这样做时,有时用户会遇到此错误。有什么办法可以增加Apache中URL的长度? 问题答案: 在Apache下,该限制是可配置的值 。如果要支持更长的请求URI,请将此值更改为大于其默认值8190的值。该值在 /etc/apache2/apache2.conf中 。如果不是,请在下添加新行()。 但是,请注意,如

  • 我是反应性编程的新手,我正在使用Spring WebFlux的WebClient向下面的URL发出POST请求,作为Spring Boot应用程序的一部分,将现有的测验分配给候选人。我很难理解我在构造WebClient请求时做错了什么。 终点 quizrequest.java java FlexiQuizClient.java 在我的资源类(控制器)中,我调用web客户端方法,如下所示: 示例响应

  • 我正在使用Spring云合同创建集成测试。从配置到将存根jar添加到项目,一切都正常工作。因此,我发现尽管所有参数和标头都相同,但请求不匹配。 这是API测试 这是API调用的合约 即使我从合同请求中删除用户名,仍然收到相同的错误。 我需要为X-B3-ParentSpanId等创建标题来使其匹配吗?

  • 我正在尝试解析我的json数据 我解析数据的代码是 我得到了错误