• 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

  • 相关阅读:
    6182. 反转二叉树的奇数层(层次遍历)
    什么是RPA?
    C++ copy()函数用法详解(深入了解,一文学会)
    爱上开源之DockerUI-如何实现Web端的Xshell终端模拟器
    Springboot项目连接Redis(jedis)
    在docker环境下从头搭建openvslam/orb_slam3的流程记录以及问题总结
    我来图书馆实现用云函数cfc进行自动化抢位置
    stm32单片机个人学习笔记3(GPIO输出)
    毛玻璃态卡片悬停效果
    (附源码)基于Springboot智慧园区管理系统-计算机毕设 88160
  • 原文地址:https://blog.csdn.net/learnworm/article/details/127630657