阅读背景：

【异常】java.sql.SQLException: Could not retrieve transaction read-only status from server Query

发表于:2025-08-14

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

$$anonfun$apply$mcV$sp.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

$$anonfun$apply$mcV$sp.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

$$anonfun$apply$mcV$sp

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

$$anonfun$apply$mcV$sp

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

$$anonfun$apply$mcV$sp

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun

1 详细异常

java.sql.SQLException: Could not retrieve transaction read-only status from server Query: replace into wm_offsets (`group_id`, `topic`, `partition_id`, `offset`) values(?,?,?,?) Parameters: [[ChargingOrderRealTimeStatistics, maxwell, 0, 4608134], [ChargingOrderRealTimeStatistics, maxwell, 1, 4564556], [ChargingOrderRealTimeStatistics, maxwell, 2, 4538179]] at org.apache.commons.dbutils.AbstractQueryRunner.rethrow(AbstractQueryRunner.java:527) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:195) at org.apache.commons.dbutils.QueryRunner.batch(QueryRunner.java:151) at com.*****.common.mysql.dao.OffsetManager$.saveOffset2MySQLByGroup(OffsetManager.scala:61) at com。***.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:191) at com.*******.spark.streaming.ChargingOrderRealTimeStatisticsEtl$$anonfun$main$1.apply(ChargingOrderRealTimeStatisticsEtl.scala:107) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.DStream$$anonfun$foreachRDD$1$$anonfun$apply$mcV$sp$3.apply(DStream.scala:628) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1$$anonfun$apply$mcV$sp$1.apply(ForEachDStream.scala:51) at org.apache.spark.streaming.dstream.DStream.createRDDWithLocalProperties(DStream.scala:416) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply$mcV$sp(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at org.apache.spark.streaming.dstream.ForEachDStream$$anonfun$1.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　

2 解决方案

看报错感觉是事务问题

https://dev.mysql.com/doc/connector-j/8.0/en/

mysql5.7推荐的驱动是8.0的

1 查询网上的说法，修改了事务级别，但是不起作用

2 根据官方mysql的推荐，更新的mysql驱动版本到8.0.7 解决问题

.apply(ForEachDStream.scala:50) at scala.util.Try$.apply(Try.scala:192) 看报错感觉是事务问题 https://de 　　 java.sql.SQLException: Could not retrieve t

分享到：

非常感谢你花费了来阅读本文,如果你在本站获取到了新知识,那就请点击分享按钮将本站分享出去吧。

你可能喜欢:

【Flask】前端RSA加密后端Python解密示例

oracle insert into 多条数据

linux安装rabbitmq以及相关的操作命令

郭宁宁-不忘初心，牢记使命——农业银行互联网金融服务三农的探索与实践

为什么基于for循环而不是直接在C ++中使用参数数组呢？ [重复]

如何获得当月的所有日子？

将算数表达式转换成后缀表达式并计算结果

学习go语言编程系列之helloworld

为什么WPF在不同版本的Windows上呈现不同？

错误膨胀类android.support.design.widget.NavigationView

相关阅读:

OpenTofu路在何方：定量分析Terraform issue数据，洞察用户需求｜OpenTofu Day 闪电演讲

我的第一本著作：Spark技术内幕上市！

UI控件之菜单(Menu)

避雷指南：11个常见 Kubernetes 误区详解

Selenium 与 Android自动化测试

DevOps迈向标准化，平台工程让开发运维更轻松

Android 百分比布局库(percent-support-lib) 解析与扩展

足不出户闹元宵，挑战 IT 人专属灯谜！

Node.js 切近实战(六) 之Excel在线（文件列表）

引用android-support-v7-appcompat库文件出错的问题

随便看看:

jQuery中:password选择器用法实例

FragmentActivity 长期后台被放置问题

统计信息过期导致SQL进行NESTED LOOPS查询缓慢

Spring Cloud(Finchley.RCI) (九) Spring Cloud分布式配置中心

Android Scroll分析 (二) 教你使用七种方法实现滑动

全链路国产化！国产开源操作系统OpenCloudOS首度披露技术路线

js 省地市级联选择

通过命令行将本地的静态文件同步至阿里云OSS

华为FusionCloud云计算vCPU资源计算公式（MHz）

DDD | 领域驱动设计初探