我有一个在AWS Glue上运行的pyspark作业。当我在本地机器上运行代码时，它运行得很好。但是，当我尝试从AWS Glue运行相同的代码时，我无法获取数据。下面是我的代码和错误消息。从输出中，您会注意到我能够获得模式信息。只要我尝试获取数据，就会发生错误。 更新:发生此问题是因为工作节点无法访问主节点中存在的密钥库。import SQLContext
from pyspark.sql.type
浏览 90提问于2020-12-31得票数 1
回答已采纳
我的presto版本是0.240我的操作:我想在presto中使用ssl来使用https，所以我改变了我的配置，只通过这个url：https://trino.io/docs/current/security/internal-communication.html，但我不能访问presto地址https://192.168.100.142:9999/，我不知道我做错了哪一步。如何为Presto
浏览 188提问于2021-01-12得票数 1
回答已采纳
我们正在尝试使用Java代码连接Presto并执行一些查询。我们使用的是MySQL目录。
我为Presto创建了一个MySQL连接器目录。我成功地使用Presto作为MySQL来查询
浏览 10提问于2021-02-08得票数 0
1回答
我使用trino-python-client查询hive数据库 host="<host>",<table_name>")现在，我想使用trino连接来获取蜂窝表的last_updated时间。因此，我尝试运行以下查询，但它们都没有工作。期望：“目录”、“列”、“创建”
浏览 14提问于2022-07-05得票数 0
1回答
我使用Spark Structured Streaming (3.1.1)从Kafka读取数据，并使用HUDI (0.8.0)作为S3上的存储系统，按日期对数据进行分区。(本节无问题)我创建了一个具有以下模
浏览 6提问于2021-12-23得票数 3
1回答
我试图使用带有PySpark的JDBC连接器从Trino中的表中读取数据，但是，每当我试图编写string / VARCHAR列时，我都会得到错误"Unknown type 'TEXT' for column我使用的代码如下：from pyspark import SparkContext
sc = SparkCont
浏览 42提问于2022-05-09得票数 0
回答已采纳
我在和Presto/Trino合作。 我需要多次运行同一个SQL查询，但每次都使用不同的输入。SQL代码由几个链接的CTE组成，它们根据一个日期和周数分析数据，因此查询将根据该日期和该日期之前的数据周数来分析数据。#I might modify this number sometimes
{
SELECT with several CTEs with SQLusin
浏览 34提问于2021-08-26得票数 0
例如，我有一张桌子：-------+----------+--------- 109 2 13:56 111 3 14:31 113 2 15:52因此，所需的输出需要(对于个人ID之一)：
seenID | personID |
浏览 5提问于2021-09-22得票数 0
回答已采纳
我已经配置了火花放电，可以直接使用PostgreSQL。但是，我希望使用jdbc连接器将数据从spark传递到presto，然后使用pyspark和presto在postgresql上运行查询。from pyspark.sql import SparkSessionfrom pyspark.<e
浏览 4提问于2019-04-15得票数 1
为了这个问题的目的，我指的是prestosql.io或Trino之后的品牌重组。我这里有张桌子(细节修改)： Table foo
...它生活在mysql数据库中。我有一个presto目录a，它有一个mysqldb连接器来查询来自presto的数据。看到是如何实现的，在我看来，连接器似乎从Presto传入了一个无效的表名，因此我无法<
浏览 1提问于2021-01-07得票数 0
回答已采纳
我在一个Presto教程上看到了这一点，它的好处是“查询数据所在的位置”。编辑:通过链接到主页上的报价添加上下文
“它能做什么？”
浏览 26提问于2021-05-19得票数 2
回答已采纳
我是S3和Trino的初学者(Presto)。我有:安装在现场使用码头的Trino(Presto)。S3桶，定位文件与拼花文件扩展。我安装Apache-钻，在盒子里他有s3 conector。我要在Trino(Presto)中这样做，但我没有结果(有错误)。我怎么能在Trino(Presto)里做同样的事？
P.s.
浏览 9提问于2022-06-27得票数 1
回答已采纳
我有一个HDFS数据湖，可以通过Hive和Presto、Impala和Spark (集群中的)查询数据。可以在本地安装(例如，我的笔记本电脑)，可以使用JDBC连接数据源(Hive或Presto)，就像在中一样？因此，我可以使用PySpark的dataframe语法和Python来查询数据</em
浏览 3提问于2019-10-21得票数 1
回答已采纳
我有一个在线的MySQL (presto)数据库，它不断地自动更新(也就是说，新的行每天都会被添加到表中(确切地说，是视图)。我希望每天从它中获取数据，但不想重新获取我以前已经获取的数据。我使用python3从在线主机数据库中提取数据，如下所示：import numpy as np
cursor=pre
浏览 0提问于2018-06-05得票数 2
回答已采纳
2回答
TABLE `normaldata_source`( `column2` string,
`column3` struct<column4:string>) 示例数据如下
浏览 148提问于2020-12-27得票数 4
1回答
将表描述添加到火花放电的冰山表中
、、、、
使用以下trino命令，我能够使用trino向冰山表添加表注释：此外，还可以使用以下方法从火花放电中读取：我无法找到一种方法来将这些注释插入到表中使
浏览 7提问于2022-02-26得票数 1
1回答
我有一个根据分区从s3导入拼图文件的presto表，如下所示： create table hive.data.datadump tUnixEpoch varchar,
tDateTimeexternal_location = 's3a://dev/files'); 存储地块文件的S3文件夹结构如下所示： s3a://dev/files/series=S5/sno=242=/date=2020-1-23 并且分区从</em
浏览 10提问于2020-01-24得票数 2
我对trino很陌生，我试图用它来查询弹性搜索中嵌套的对象。trino中对id字段执行查询的语法是什么？是否需要使用弹性目标索引映射的特殊定义来映射trino的嵌套部分？我们试图根据id字段查询数据。发送es-查询从trino到弹性: SELECT *从es.default。“$query：”它可以工作，但当我们试图检索id与许多文档，我们从弹性客户端超时。从文档中我无法理解，当我们使用</
浏览 7提问于2021-05-24得票数 1
我使用AWS数据目录作为元存储，通过CDK运行Presto部署了一个EMR集群。集群将只具有运行查询的默认用户。默认情况下，主用户是hadoop，我可以使用它通过JDBC连接到集群并运行查询。我已经阅读了Presto文档，它们提到了LDAP、Kerberos和基于文件的身份验证。我只想让它表现得像，比方说，一个MySQL数据库，在这里，我必须同时传递用户名和密码才能连接。这要求您获得有效的证书，并将其添加到Trino协调员的配置中。”
我已经从我的公司
浏览 27提问于2022-06-28得票数 1
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号