Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: temp workaround for omg/48020 #1521

Merged
merged 19 commits into from
Feb 8, 2022
Prev Previous commit
Next Next commit
.
yirutang committed Feb 8, 2022
commit e578493740a1af29f5c739507dd7195ebd7af19d
Original file line number Diff line number Diff line change
@@ -412,7 +412,7 @@ public void testJsonStreamWriterWithDefaultStream()
}
}

// This test runs about 4-5 minutes, sometimes 10 minutes.
// This test runs about 1 min.
@Test
public void testJsonStreamWriterWithDefaultStreamLarge()
throws IOException, InterruptedException, ExecutionException,
@@ -432,8 +432,8 @@ public void testJsonStreamWriterWithDefaultStreamLarge()
.setWriteStream(
WriteStream.newBuilder().setType(WriteStream.Type.COMMITTED).build())
.build());
int totalRequest = 100;
int rowBatch = 20000;
int totalRequest = 10;
int rowBatch = 40000;
ArrayList<ApiFuture<AppendRowsResponse>> allResponses =
new ArrayList<ApiFuture<AppendRowsResponse>>(totalRequest);
// Sends a total of 150MB over the wire.
@@ -445,7 +445,7 @@ public void testJsonStreamWriterWithDefaultStreamLarge()
JSONObject row = new JSONObject();
row.put("col1", "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa");
JSONArray jsonArr = new JSONArray();
// 1.5MB batch.
// 3MB batch.
for (int j = 0; j < rowBatch; j++) {
jsonArr.put(row);
}