• SpringBoot连接TDengine集群写入超时


    Sping DataSource配置

    主要修改最大连接时长(初始设置为30秒,发现有部分线程写入时长达到60秒左右,需增加最大等待时长):

    spring.datasource.druid.max-wait=30000

    1. spring.datasource.driver-class-name=com.taosdata.jdbc.TSDBDriver
    2. spring.datasource.url=jdbc:TAOS://:/tst?timezone=UTC-8&charset=UTF-8&locale=en_US.UTF-8
    3. spring.datasource.username=test
    4. spring.datasource.password=
    5. spring.datasource.druid.initial-size=10
    6. spring.datasource.druid.min-idle=10
    7. spring.datasource.druid.max-active=200
    8. spring.datasource.druid.max-wait=90000
    9. spring.datasource.druid.validation-query=select server_status();

    报错日志

    1. ### Cause: java.sql.SQLException: TDengine ERROR (8000000b): Unable to establish connection
    2. ; uncategorized SQLException; SQL state []; error code [-2147483637]; TDengine ERROR (8000000b): Unable to establish connection; nested exception is java.sql.SQLException: TDengine ERROR (8000000b): Unable to establish connection
    3.     at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:89)
    4.     at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:81)
    5.     at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:81)
    6.     at org.mybatis.spring.MyBatisExceptionTranslator.translateExceptionIfPossible(MyBatisExceptionTranslator.java:73)
    7.     at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:446)
    8.     at com.sun.proxy.$Proxy101.insert(Unknown Source)
    9.     at org.mybatis.spring.SqlSessionTemplate.insert(SqlSessionTemplate.java:278)
    10.     at org.apache.ibatis.binding.MapperMethod.execute(MapperMethod.java:57)
    11.     at org.apache.ibatis.binding.MapperProxy.invoke(MapperProxy.java:59)
    12.     at com.sun.proxy.$Proxy102.savebatch(Unknown Source)
    13.     at com.taosdata.example.service.FanComputerService.savebatch(FanComputerService.java:58)
    14.     at com.taosdata.example.kafka.KakfaDataConsumer$1.run(KakfaDataConsumer.java:79)
    15.     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    16.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    17.     at java.lang.Thread.run(Thread.java:748)
    18. Caused by: java.sql.SQLException: TDengine ERROR (8000000b): Unable to establish connection
    19.     at com.taosdata.jdbc.TSDBError.createSQLException(TSDBError.java:76)
    20.     at com.taosdata.jdbc.TSDBJNIConnector.executeQuery(TSDBJNIConnector.java:119)
    21.     at com.taosdata.jdbc.TSDBStatement.execute(TSDBStatement.java:98)
    22.     at com.taosdata.jdbc.TSDBPreparedStatement.execute(TSDBPreparedStatement.java:261)
    23.     at com.alibaba.druid.pool.DruidPooledPreparedStatement.execute(DruidPooledPreparedStatement.java:497)
    24.     at org.apache.ibatis.executor.statement.PreparedStatementHandler.update(PreparedStatementHandler.java:46)
    25.     at org.apache.ibatis.executor.statement.RoutingStatementHandler.update(RoutingStatementHandler.java:74)
    26.     at org.apache.ibatis.executor.SimpleExecutor.doUpdate(SimpleExecutor.java:50)
    27.     at org.apache.ibatis.executor.BaseExecutor.update(BaseExecutor.java:117)
    28.     at org.apache.ibatis.executor.CachingExecutor.update(CachingExecutor.java:76)
    29.     at org.apache.ibatis.session.defaults.DefaultSqlSession.update(DefaultSqlSession.java:198)
    30.     at org.apache.ibatis.session.defaults.DefaultSqlSession.insert(DefaultSqlSession.java:185)
    31.     at sun.reflect.GeneratedMethodAccessor161.invoke(Unknown Source)
    32.     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    33.     at java.lang.reflect.Method.invoke(Method.java:498)
    34.     at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:433)
    35.     ... 10 more
    36. org.springframework.jdbc.UncategorizedSQLException: 
    37. ### Error updating database.  Cause: java.sql.SQLException: TDengine ERROR (8000000b): Unable to establish connection
    38. ### The error may involve com.taosdata.example.dao.TabComputerMapper.savebatch-Inline
    39. ### The error occurred while setting parameters
    40. ### SQL: insert into xxx.tab_? using xxx.tab_xxx (a,b,c) tags (?,?,?) (ts, vame, vmin, vmax, vavg, vlast) values                       (?, ?, 9.2, ?, 9.2, 9.2, ?, 1667271000000, 1667270986430, ?, 18.4, 2)                        (?, ?, 49.93, ?, 59.53666666666667, 69.96, ?, 1667271000000, 1667270968088, ?, 714.44, 12)                        (?, ?, 24.4, ?, 24.4, 24.4, ?, 1667271000000, 1667270982422, ?, 48.8, 2)                        (?, ?, 556374.44, ?, 558656.51, 558266.56, ?, 1667271000000, 1667270968088, ?, 5027908.59, 9)                        (?, ?, 45.4, ?, 45.4, 45.4, ?, 1667271000000, 1667270984018, ?, 90.8, 2)                        (?, ?, 4.760643, ?, 5.0304940799999995, 5.0477376, ?, 1667271000000, 1667270978110, ?, 25.1524704, 5)                        (?, ?, 34.1, ?, 34.1, 34.1, ?, 1667271000000, 1667270984052, ?, 68.2, 2)                        (?, ?, 20.9, ?, 20.9, 20.9, ?, 1667271000000, 1667270986052, ?, 41.8, 2)                        (?, ?, 669.59, ?, 679.1966666666667, 689.62, ?, 1667271000000, 1667270968087, ?, 8150.360000000001, 12)                        (?, ?, 28.3, ?, 28.366666666666664, 28.3, ?, 1667271000000, 1667270978112, ?, 85.1, 3)                        (?, ?, -0.0012207218, ?, -5.2643626E-4, -6.675822E-4, ?, 1667271000000, 1667270986430, ?, -0.0026321812999999996, 5)                        (?, ?, 121.00243, ?, 129.51232333333334, 137.01703, ?, 1667271000000, 1667270968089, ?, 1554.14788, 12)                        (?, ?, 1.6995232, ?, 1.822367475, 2.088352, ?, 1667271000000, 1667270974109, ?, 7.2894699, 4)                        (?, ?, 3.9023676, ?, 4.075580136363636, 3.9627671, ?, 1667271000000, 1667270968194, ?, 44.8313815, 11)                        (?, ?, 3.9002872, ?, 4.07430021, 3.9402905, ?, 1667271000000, 1667270968188, ?, 40.7430021, 10)
    41. ### Cause: java.sql.SQLException: TDengine ERROR (8000000b): Unable to establish connection
    42. ; uncategorized SQLException; SQL state []; error code [-2147483637]; TDengine ERROR (8000000b): Unable to establish connection; nested exception is java.sql.SQLException: TDengine ERROR (8000000b): Unable to establish connection
    43.     at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:89)
    44.     at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:81)
    45.     at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:81)
    46.     at org.mybatis.spring.MyBatisExceptionTranslator.translateExceptionIfPossible(MyBatisExceptionTranslator.java:73)
    47.     at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:446)
    48.     at com.sun.proxy.$Proxy101.insert(Unknown Source)
    49.     at org.mybatis.spring.SqlSessionTemplate.insert(SqlSessionTemplate.java:278)
    50.     at org.apache.ibatis.binding.MapperMethod.execute(MapperMethod.java:57)
    51.     at org.apache.ibatis.binding.MapperProxy.invoke(MapperProxy.java:59)
    52.     at com.sun.proxy.$Proxy102.savebatch(Unknown Source)
    53.     at com.taosdata.example.service.TabComputerService.savebatch(FanComputerService.java:58)
    54.     at com.taosdata.example.kafka.KakfaDataConsumer$1.run(KakfaDataConsumer.java:79)
    55.     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    56.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    57.     at java.lang.Thread.run(Thread.java:748)
    58. Caused by: java.sql.SQLException: TDengine ERROR (8000000b): Unable to establish connection
    59.     at com.taosdata.jdbc.TSDBError.createSQLException(TSDBError.java:76)
    60.     at com.taosdata.jdbc.TSDBJNIConnector.executeQuery(TSDBJNIConnector.java:119)
    61.     at com.taosdata.jdbc.TSDBStatement.execute(TSDBStatement.java:98)
    62.     at com.taosdata.jdbc.TSDBPreparedStatement.execute(TSDBPreparedStatement.java:261)
    63.     at com.alibaba.druid.pool.DruidPooledPreparedStatement.execute(DruidPooledPreparedStatement.java:497)
    64.     at org.apache.ibatis.executor.statement.PreparedStatementHandler.update(PreparedStatementHandler.java:46)
    65.     at org.apache.ibatis.executor.statement.RoutingStatementHandler.update(RoutingStatementHandler.java:74)
    66.     at org.apache.ibatis.executor.SimpleExecutor.doUpdate(SimpleExecutor.java:50)
    67.     at org.apache.ibatis.executor.BaseExecutor.update(BaseExecutor.java:117)
    68.     at org.apache.ibatis.executor.CachingExecutor.update(CachingExecutor.java:76)
    69.     at org.apache.ibatis.session.defaults.DefaultSqlSession.update(DefaultSqlSession.java:198)
    70.     at org.apache.ibatis.session.defaults.DefaultSqlSession.insert(DefaultSqlSession.java:185)
    71.     at sun.reflect.GeneratedMethodAccessor161.invoke(Unknown Source)
    72.     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    73.     at java.lang.reflect.Method.invoke(Method.java:498)
    74.     at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:433)
    75.     ... 10 more

  • 相关阅读:
    亚马逊测评自养号策略:手机与PC结合的重要性
    [附源码]计算机毕业设计JAVA大学生心理健康评估系统
    【已解决】ChatGPT报错“Unable to load history Retry“等问题
    Go-Excelize API源码阅读(三十六)——SetSheetRow、InsertPageBreak
    web前端期末大作业:基于HTML+CSS+JS外卖服务平台10页 带购物车 (web课程设计与实现)
    C++ 与 QML 之间进行数据交互的几种方法
    防错与自働化的结合|优思学院・精益管理学会|CLMP
    Centos根目录空间占满的解决思路
    java-springboot基于机器学习得心脏病预测系统 的设计与实现-计算机毕业设计
    [附源码]java毕业设计法律咨询信息管理系统
  • 原文地址:https://blog.csdn.net/learnworm/article/details/127630657