你模拟的过程是什么,我这边是用tispark写入代码:
df.write.
format(“tidb”).
option(“tidb.addr”, “172.xxx”).
option(“tidb.port”, “4000”).
option(“tidb.user”, “bdata”).
option(“tidb.password”, “”).
option(“database”, “bdata”).
option(“table”,tblName).
option(“replace”,true).
option(“isolationLevel”,“NONE”).
option(JDBCOptions.JDBC_BATCH_INSERT_SIZE,1000).
mode(“append”).
save()