database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](group commit)fix group commit regresstion test (#29079)

Browse Source
This commit is contained in:
huanghaibin
2023-12-29 00:50:22 +08:00
committed by GitHub
parent 825732a395
commit 69c90b1640
15 changed files with 238 additions and 195 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/LoadAction.java
View File

@ -85,11 +85,10 @@ public class LoadAction extends RestBaseController {
@PathVariable(value = DB_KEY) String db, @PathVariable(value = TABLE_KEY) String table) {
boolean groupCommit = false;
String groupCommitStr = request.getHeader("group_commit");
if (groupCommitStr != null && groupCommitStr.equals("true")) {
if (groupCommitStr != null && groupCommitStr.equals("async_mode")) {
groupCommit = true;
try {
String[] pair = new String[] {db, table};
LOG.info(pair[0] + ":" + pair[1]);
if (isGroupCommitBlock(pair)) {
String msg = "insert table " + pair[1] + " is blocked on schema change";
return new RestBaseResult(msg);
@ -128,7 +127,7 @@ public class LoadAction extends RestBaseController {
LOG.info("streaming load sql={}", sql);
boolean groupCommit = false;
String groupCommitStr = request.getHeader("group_commit");
if (groupCommitStr != null && groupCommitStr.equals("true")) {
if (groupCommitStr != null && groupCommitStr.equals("async_mode")) {
groupCommit = true;
try {
String[] pair = parseDbAndTb(sql);