通过catalog查询mysql报错

💬 StarRocks 用户问答
#1

【详述】通过catalog查询mysql报错，且同一个mysql建立的外表能正常查询
【背景】无
【业务影响】
【StarRocks版本】例如：3.1.0
【集群规模】例如：1 master 2 flower 16c 32g 3 be 32c 64g 单独部署
【联系方式】社区群1-Cellophane
【附件】

  • fe.log
    2023-09-19 14:29:19,032 WARN (starrocks-mysql-nio-pool-43|755) [Coordinator.getNext():1394] get next fail, need cancel. status errorCode INTERNAL_ERROR open JDBCScanner failed, error: java.sql.SQLException[com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129), com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.transla
    teException(SQLExceptionsMapping.java:122), com.mysql.cj.jdbc.StatementImpl.executeSimpleNonQuery(StatementImpl.java:1242), com.mysql.cj.jdbc.StatementImpl.setupStreamingTimeout(StatementImpl.java:632), com.mysql.cj.jdbc.ClientPreparedStatement.executeQuery(ClientPreparedStatement.java:984), com.zaxxer.hikari.pool.ProxyPreparedStatement.e
    xecuteQuery(ProxyPreparedStatement.java:52), com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeQuery(HikariProxyPreparedStatement.java), com.starrocks.jdbcbridge.JDBCScanner.open(JDBCScanner.java:68)], query id: dcdbb71e-56b5-11ee-b241-00163e0ac9c5
    2023-09-19 14:29:19,032 WARN (starrocks-mysql-nio-pool-43|755) [Coordinator.updateStatus():1374] one instance report fail throw updateStatus(), need cancel. job id: -1, query id: dcdbb71e-56b5-11ee-b241-00163e0ac9c5, instance id: NaN
    2023-09-19 14:29:19,032 INFO (starrocks-mysql-nio-pool-43|755) [Coordinator.cancelInternal():1495] unfinished instance: dcdbb71e-56b5-11ee-b241-00163e0ac9c6
    2023-09-19 14:29:19,032 WARN (thrift-server-pool-388|770) [Coordinator.updateFragmentExecStatus():1570] exec state report failed status=errorCode INTERNAL_ERROR open JDBCScanner failed, error: java.sql.SQLException[com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129), com.mysql.cj.jdbc.exceptions.SQLExceptionsMappin
    g.translateException(SQLExceptionsMapping.java:122), com.mysql.cj.jdbc.StatementImpl.executeSimpleNonQuery(StatementImpl.java:1242), com.mysql.cj.jdbc.StatementImpl.setupStreamingTimeout(StatementImpl.java:632), com.mysql.cj.jdbc.ClientPreparedStatement.executeQuery(ClientPreparedStatement.java:984), com.zaxxer.hikari.pool.ProxyPreparedSt
    atement.executeQuery(ProxyPreparedStatement.java:52), com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeQuery(HikariProxyPreparedStatement.java), com.starrocks.jdbcbridge.JDBCScanner.open(JDBCScanner.java:68)], query_id=dcdbb71e-56b5-11ee-b241-00163e0ac9c5, instance_id=dcdbb71e-56b5-11ee-b241-00163e0ac9c6
    2023-09-19 14:29:19,032 WARN (starrocks-mysql-nio-pool-43|755) [Coordinator.getNext():1420] query failed: open JDBCScanner failed, error: java.sql.SQLException[com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129), com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122), co
    m.mysql.cj.jdbc.StatementImpl.executeSimpleNonQuery(StatementImpl.java:1242), com.mysql.cj.jdbc.StatementImpl.setupStreamingTimeout(StatementImpl.java:632), com.mysql.cj.jdbc.ClientPreparedStatement.executeQuery(ClientPreparedStatement.java:984), com.zaxxer.hikari.pool.ProxyPreparedStatement.executeQuery(ProxyPreparedStatement.java:52), c
    om.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeQuery(HikariProxyPreparedStatement.java), com.starrocks.jdbcbridge.JDBCScanner.open(JDBCScanner.java:68)]
    2023-09-19 14:29:19,032 INFO (starrocks-mysql-nio-pool-43|755) [QeProcessorImpl.unregisterQuery():105] deregister query id dcdbb71e-56b5-11ee-b241-00163e0ac9c5
    2023-09-19 14:29:19,032 INFO (starrocks-mysql-nio-pool-43|755) [StmtExecutor.execute():646] execute Exception, sql: select * from liv_task limit 1, error: open JDBCScanner failed, error: java.sql.SQLException[com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129), com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.tran
    slateException(SQLExceptionsMapping.java:122), com.mysql.cj.jdbc.StatementImpl.executeSimpleNonQuery(StatementImpl.java:1242), com.mysql.cj.jdbc.StatementImpl.setupStreamingTimeout(StatementImpl.java:632), com.mysql.cj.jdbc.ClientPreparedStatement.executeQuery(ClientPreparedStatement.java:984), com.zaxxer.hikari.pool.ProxyPreparedStatemen
    t.executeQuery(ProxyPreparedStatement.java:52), com.zaxxer.hikari.pool.HikariProxyPreparedStatement.executeQuery(HikariProxyPreparedStatement.java), com.starrocks.jdbcbridge.JDBCScanner.open(JDBCScanner.java:68)]
  • 查询报错：
    open JDBCScanner failed, error: java.sql.SQLException[com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:129), com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122), com.mysql.cj.jdbc.StatementImpl.executeSimpleNonQuery(StatementImpl.java:1242), com.mysql.cj.jdbc.StatementImpl.setupStreamingTimeout(StatementImpl.java:632), com.mysql.cj.jdbc.ClientPreparedStatement.executeQuery(ClientPreparedStatement.java:984), com.zaxxer.hikari.pool.ProxyPr
#2

没有MySQL catalog，请问是参考什么文档操作？

#3

JDBC catalog @ jdbc_catalog @ StarRocks Docs 这个文档，这个catalog之前是可以查询的，现在有时可以查有时不可以

#4

明白了，我们排查一下。

#5

什么时候可以给个答复呢

#6

mysql catalog的创建语句发下，另外mysql是否开启了ssl认证

#7 
CREATE EXTERNAL CATALOG mysql_catalog

PROPERTIES

(

    "type"="jdbc",

    "user"="test",

    "password"="abc",

    "jdbc_uri"="jdbc:mysql://127.0.0.1:3306",

    "driver_url"="https://repo1.maven.org/maven2/mysql/mysql-connector-java/8.0.28/mysql-connector-java-8.0.28.jar",

    "driver_class"="com.mysql.cj.jdbc.Driver"

);

没有开启ssl

#8

这个改为ip地址，别用本地local地址

#9

使用的是ocenbase

#10

为了脱敏这里写的回环地址

#11

您说以前可以，是什么版本？现在偶现不行是3.1版本？

#12

以前也是3.1版本，这个catalog是在升级了3.1之后创建的

#13

jdbc catalog?

#14

是的，jdbc catalog

#15

把驱动放在本地试试

CREATE EXTERNAL CATALOG test
COMMENT “Tencent StarRocks test”
PROPERTIES (
“driver_class” = “com.mysql.cj.jdbc.Driver”,
“driver_url” = “file:///u/StarRocks/jdbc/mysql-connector-java-8.0.28.jar”,
“type” = “jdbc”,
“user” = “xxxxx”,
“password”=“xxxxx”,
“jdbc_uri” = “jdbc:mysql:loadbalance://xxxxx”
);

#16

已经放到本地，一开始就是放本地的

#17

be的info或者out有相关的错误日志吗

京ICP备2022026421号-1