问题标签 [presto-jdbc]

我的 presto 已启动并运行，在连接器上有以下问题。我已经在 root 中安装了 presto，我的配置单元在“hadoop”用户中，而我的“sql”在另一个用户中

我得到 Java.net.connectexception: Failed to connect /127.0.0.1:8090 for sql

蜂巢超时

sql.properties：connector.name=sqlserver connection-url=jdbc:sqlserver://localhost:1433 connection-user=SA connection-password=xxxxxx

是否可以CALL system.sync_partition_metadata('dummy','dummy','FULL')使用 JDBC 执行 Presto JDBC 驱动程序不支持 CallableStatements？

我在使用 presto date 函数获取当天和前一天的数据时遇到问题。

“与 Presto 通信时发生错误。连接错误：Tableau 无法连接到数据源。错误代码：9F80FB23 [Simba][Presto] (1060) Presto 查询错误：第 30:37 行：'>=' 不能应用于 varchar，日期 (1) [Simba][Presto] (1060) Presto 查询错误：行9:24: '>=' 不能应用于 varchar，日期 (1)”</p>

你能帮助/建议我们解决它吗？

根据以下错误，Presto 似乎不是与 Spring JPA 描述兼容的有效数据源：

请想法或建议？

以下 ItemReader bean 通过 PrestDriver 读取行。执行批处理时，我收到此错误消息：

......

ItemReader 代码

我创建了一个“hello world”应用程序来测试驱动程序，这次使用的是普通的 JDBCDriver。本次测试成功。

任何想法为什么会发生这种情况？或一些解决方法将不胜感激。

谢谢

以下 ItemReader 获取数千个帐户 ( acc ) 的列表。

ItemReader 将连接到以检索数据的数据库是 HIVE。我没有创建任何表的权限，只有读取选项。

这是我在使用 ItemReader 时收到的错误消息：

我确信根本原因是由于驱动程序，但这次我使用 DriverManager 使用相同的 SQL 测试了驱动程序，并且它运行完美。

我不确定有什么不同？是驱动程序还是备用批次？

我正在寻找一种解决方法。如何通过带有 spring batch 的 IN 子句检索数千个帐户？

谢谢

我有一个在 AWS Glue 上运行的 pyspark 作业。当我通过本地机器运行代码时，它运行良好。但是当我尝试从 AWS Glue 运行相同的代码时，我无法获取数据。下面是我的代码和错误信息。从输出中您会注意到我能够获取架构信息。一旦我尝试获取数据，就会发生错误。

更新：问题正在发生，因为工作节点无法访问主节点中存在的密钥库。有人可以帮助如何将文件复制到子节点或如何使子节点可以访问文件吗？

输出：

我需要从日期与格式 yyyy-MM-dd 不匹配的表中获取所有记录。

在这里，列 ID 是唯一的 bigint 列。start_date 是 varchar 数据类型。

样本输入：

预期输出：

谢谢

我们正在尝试执行 presto jdbc connection 。我们遵循了简单的例子

https://www.tutorialspoint.com/apache_presto/apache_presto_jdbc_interface.htm

• 添加了罐子，
• 在 eclipse 中作为 java 应用程序运行。

笔记 ：

• Presto 安装在 linux 服务器上。presto cli 在 linux 中运行良好。在 linux 中开始 presto 。
• 我们在 Windows 机器 eclipse ide 中运行这个类。我们在 linux 机器上没有防火墙。
• linux机器上也安装了mysql。我们可以使用java代码在windows中访问mysql。但无法从 windows 执行此操作。

还尝试添加 ssl =true 如下所示 connection = DriverManager.getConnection("jdbc:presto://19.255.24.127:8080/mysql/tutorials?user=root&password=Redcar88!&SSL=true");

异常：java.sql.SQLException：在 com.facebook.presto.jdbc.PrestoStatement.execute(PrestoStatement.java:228) 的 com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:279) 执行查询时出错com.facebook.presto.jdbc.PrestoStatement.executeQuery(PrestoStatement.java:77) at testdbPresto.PrestoJdbcSample.main(PrestoJdbcSample.java:22) 原因：java.io.UncheckedIOException: javax.net.ssl.SSLException: 不支持或com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:154) 上 com.facebook.presto.jdbc.internal.client.StatementClientV1.(StatementClientV1.java:130) 上无法识别的 SSL 消息.facebook.presto.jdbc.internal.client.StatementClientFactory.newStatementClient(StatementClientFactory.java:24) 在 com.facebook.presto.jdbc.QueryExecutor.startQuery(QueryExecutor.java:46) 在 com.facebook.presto.jdbc.PrestoConnection.startQuery(PrestoConnection.java:717) at com.facebook.presto.jdbc.PrestoStatement.internalExecute(PrestoStatement.java:240) ... 3 更多原因：javax.net.ssl.SSLException ：在 sun.security.ssl.SSLSocketInputRecord.decode(SSLSocketInputRecord.java:174) 在 sun.security.ssl.SSLTransport.decode 的 sun.security.ssl.SSLSocketInputRecord.handleUnknownRecord(SSLSocketInputRecord.java:448) 中不受支持或无法识别的 SSL 消息(SSLTransport.java:110) 在 sun.security.ssl.SSLSocketImpl.decode(SSLSocketImpl.java:1279) 在 sun.security.ssl.SSLSocketImpl.readHandshakeRecord(SSLSocketImpl.java:1188) 在 sun.security.ssl.SSLSocketImpl。 startHandshake(SSLSocketImpl.java:401) 在 sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:373) 在 com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection。connectTls(RealConnection.java:299) 在 com.facebook.presto.jdbc.internal.okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:268) 在 com.facebook.presto.jdbc.internal.okhttp3.internal。 connection.RealConnection.connect(RealConnection.java:160) 在 com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:256) 在 com.facebook.presto.jdbc.internal。 okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:134) 在 com.facebook.presto.jdbc.internal.okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:113) 在 com.facebook.presto。 jdbc.internal.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42) 在 com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain。在 com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) 在 com.facebook.presto.jdbc.internal.okhttp3.internal 继续（RealInterceptorChain.java:147）。 cache.CacheInterceptor.intercept(CacheInterceptor.java:93) 在 com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) 在 com.facebook.presto.jdbc.internal。 okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) 在 com.facebook.presto.jdbc.internal.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93) 在 com.facebook.presto。 jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) 在 com.facebook.presto.jdbc.internal.okhttp3.internal.http.RetryAndFollowUpInterceptor。在 com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) 在 com.facebook.presto.jdbc.internal.okhttp3.internal 拦截(RetryAndFollowUpInterceptor.java:125)。 http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) 在 com.facebook.presto.jdbc.internal.client.OkHttpUtil.lambda$basicAuth$1(OkHttpUtil.java:91) 在 com.facebook.presto.jdbc.internal.okhttp3 .internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) 在 com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) 在 com.facebook.presto.jdbc .internal.client.OkHttpUtil.lambda$userAgent$0(OkHttpUtil.java:77) 在 com.facebook.presto.jdbc.internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147) 在 com.facebook。 presto.jdbc。internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121) 在 com.facebook.presto.jdbc.internal.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200) 在 com.facebook.presto.jdbc。 internal.okhttp3.RealCall.execute(RealCall.java:77) at com.facebook.presto.jdbc.internal.client.JsonResponse.execute(JsonResponse.java:131) ... 还有 8 个

presto 安装的 config.properties 。 在代码中，我使用机器的 ip 作为 Host 。

我们正在尝试使用 Dbvisualizer 连接到 presto。并执行一些查询。我们使用的目录日志是 mysql 。

• Presto 安装在 linux 服务器上。presto cli 在 linux 中运行良好。在 linux 中开始 presto 。
• linux机器上也安装了mysql。我们可以使用 Dbvisualizer 在 Windows 中访问 mysql。
• 为 Presto 创建了一个 mysql 连接器目录。使用 Presto-cli as 查询mysql数据成功presto --server localhost:8080 --catalog mysql --schema tutorials

DBvisualizer 安装在 Windows 机器上。我能够访问 mysql 并执行查询。Presto 也在 Dbvisualizer 中连接。但是我们无法查询数据。当我们尝试运行查询时。它给了我们 Error Executing Query 。

网上提供的信息不多，我们不知道我们在这里缺少什么，有人可以解释一下这样做的方法。我们需要从 windows machine 执行查询。我们还尝试了使用 jdbc jar 从 java 代码。同样的例外

添加 Presto 安装的 Config.properties 截图。这里还有什么要添加的属性吗？ . 任何建议表示赞赏。谢谢