运行SQL子查询"AnalysisException: U“时出现Pyspark错误，不允许在非等式谓词中使用相关列：\n聚合”
运行SQL子查询"AnalysisException: U"时出现Pyspark错误，不允许在非等式谓词中使用相关列：聚合
这个错误是由于在SQL子查询中使用了非等式谓词，并且相关列被用于聚合操作。非等式谓词是指不使用等号进行比较的谓词，例如大于、小于等。在Pyspark中，当使用非等式谓词时，相关列不能用于聚合操作。
解决这个问题的方法是修改SQL子查询，确保在非等式谓词中不使用相关列进行聚合操作。可以考虑使用其他列进行聚合，或者重新设计查询逻辑以避免使用非等式谓词。
以下是一些相关的概念和推荐的腾讯云产品：
- SQL子查询：SQL子查询是指在一个SQL语句中嵌套另一个SQL语句的查询。它可以用于获取更复杂的查询结果或者进行数据筛选和过滤。
- Pyspark：Pyspark是一种基于Python的Spark编程接口，用于进行大规模数据处理和分析。它提供了丰富的API和工具，支持分布式计算和并行处理。
- 腾讯云产品推荐：腾讯云提供了多种云计算产品和服务，可以满足不同场景的需求。对于数据处理和分析，推荐使用腾讯云的云数据库 TencentDB、云数据仓库 TencentDB for TDSQL、云数据湖 Tencent Cloud Data Lake 等产品。
- 腾讯云数据库 TencentDB：https://cloud.tencent.com/product/cdb
- 云数据仓库 TencentDB for TDSQL：https://cloud.tencent.com/product/tdsql
- 云数据湖 Tencent Cloud Data Lake：https://cloud.tencent.com/product/datalake
希望以上信息对您有帮助！
相关·内容
我已经编写了一个SQL查询，其中包含一个子查询。这是一个正确的mySQL查询，但没有在Pyspark上实现 from pyspark import SparkContext, SparkConffrom pyspark.
浏览 168提问于2020-12-18得票数 0
回答已采纳
1回答
在蜂箱(直线)中执行下面的查询时，我没有错误。但是，当使用pyspark从Python执行时，同样的查询会失败，出现下面的错误消息。我如何调优python代码来使用本机单元引擎，而不是pyspark来执行下面的查询？ABC' ) then 1 else 0 end as com_dq from hive_Schema_name_2.table_name_
浏览 1提问于2022-10-05得票数 0
我正在尝试-在s3桶中编写查询结果。为此，我使用了sparkSql。此作业在由调度程序触发时失败，但在手动运行时成功。它正在抛出一个列(eventdate)的错误，该列在spark中可用。call last):error_repor
浏览 0提问于2018-06-22得票数 3
回答已采纳
我在AWS Glue脚本中使用Spark SQL来转换S3中的一些数据。<some_newcol> 我收到以下错误 pyspark.sql.utils.AnalysisException: u"cannot resolve '(sales.#1, customer_loc#2, demand_amt#3L,pyspark.<em
浏览 125提问于2019-04-18得票数 1
我有一个查询(最初是为SQL Server编写的)，它有多个子查询作为计算计数的列。在SQL server中，我可以使用一个等式将列设置为count子查询，例如： Pass = (select count(*) from report.sub_2018 p where p.ABST =中运行查询，但它不允许这种
浏览 17提问于2019-04-17得票数 2
回答已采纳
1回答
我试图使用Databricks SQL执行以下SQL子句：查询的目的是根据新数据表列中的值删除历史数据表中的一组行。出于我无法理解的原因，它产生了一个错误，例如：
SQL语句中的错误
浏览 6提问于2022-10-31得票数 1
在我希望每个用户只看到一行的情况下，我有一个连接几个表并生成许多行的查询。我已经通过使用group by user.id解决了“只有一个用户”的问题，但是我注意到，现在对于每个用户，我从表示第一个条目(而不是最后一个条目)的连接表中获取值。group by user.id解决了每个用户只给我一个项目的问题，但他们总是以item.id最低的第一个项目出现，而我想要最新的项目。有没有更好的方法来实现这一点...我最初是在使用distinct，但这似乎没有起到作用。
浏览 1提问于2012-08-23得票数 2
回答已采纳
|| 1 | 12 | 40 |我想查询每个类的最高分数，所以我编写了以下SQL语句：from sc having score = max(score);
但产出与我所期望的不一样。
浏览 4提问于2022-08-20得票数 -2
回答已采纳
2回答
并在dataframe中创建一个列，并将这些产品设置为1，其余的设置为0。from pyspark.sql.window import Window
浏览 8提问于2022-07-15得票数 1
回答已采纳
我正在编写一个查询，以在人员表(包括每个副本)中查找重复行：FROM Person SELECTMySQL 8.0.19的MySQL 8.0.19中运行此操作时，如果出现以下错误，将失败：
查询1错误: with子句的表达式#1不按子句分组，而是包含非聚合列&#
浏览 4提问于2020-02-28得票数 2
1回答
这是我的家庭作业问题：
编写一个从user_id返回的SQL查询、用户名、来自表“user”的电子邮件、“文章”的标题、所有文章的评论内容都是在2013年创建的。
浏览 1提问于2014-04-02得票数 0
回答已采纳
as countGROUP BY ROUND(UNIX_TIMESTAMP(created_at) / 43200)
但是，如何才能获得以前已经出现的唯一用户的数量呢
浏览 4提问于2014-11-20得票数 2
回答已采纳
2回答
我有列X，Y，Z的表A。SELECT X, YGROUP BY X;
这个查询有用吗？Y应该与X一起分组，但我没有在查询中明确指定它。然而，MySQL是否仍然含蓄地这样做呢？
浏览 4提问于2020-04-02得票数 1
回答已采纳
我有两个表Project和Comptes，我想在一个查询中显示项目和他的厨师 Query q=se.createQuery("SELECT p.idpro,p.IdProjet,p.NomProjet,p.DateDeb,p.DateFin,p.nomimg (SELECT c.Nom,c.Prenom FROM Compte u WHERE u.Id = p.IdChef group byu.id) FROM Projets p ");
l
浏览 2提问于2013-06-20得票数 1
回答已采纳
1回答
我有以下SQL查询，当我最初对其进行编码时，查询速度异常快，现在需要超过1秒才能完成： FROM
然而，是否有更好的方法可以使用呢？最理想的情况是，我不需要临时表；像YouTube/Facebook这样的网站对于大表做什么来保
浏览 3提问于2014-08-28得票数 0
回答已采纳
my数据库更大，但查询只涉及这两个，它们由主键"Id_TipoMed“和外键"TipoMedicamento_FK”关联SELECTCantidad*Precio)
浏览 3提问于2016-04-12得票数 0
回答已采纳
对has_many关联运行以下查询。Recommendation has_many Approval。我正在运行rails 3和PostgreSQL：这将返回以下错误：
浏览 2提问于2011-12-31得票数 2
回答已采纳
1回答
away_team
Name: user_picks下面是我尝试连接这两个表的sql：SELECT game_feed_game_id , away_team FROM game_feed_mlbAND user_picks.user_id_fk = 1";
$result = mysqli_query(
浏览 0提问于2017-09-24得票数 0
有人能解释为什么在使用SQL时，下面的第一个查询只需4分钟，而第二个只需2秒？唯一的区别是第一行中的"orders“前缀。gps.IsProcessed <> 1))更奇怪的是，如果我注释掉下面的@UntilDate比较，同样的性能增益就不适用了--只有当我删除@FromDate日期比较时才会有区别Server解析和编译时间: CPU时间=0 ms，运行时间=0 ms。
S
浏览 6提问于2017-05-22得票数 0
回答已采纳
3回答
所以通常你可以这样做且COUNT(field)将返回条件为field.id > 100的条目数SELECT COUNT(field.id), field.id * 10 AS foo FROM table HAVING foo > 100如何计算其标准是通过HAVING子句指定的条目？
浏览 0提问于2010-09-20得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
