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

[Extension] Add DataX doriswriter extension directory (#6111)

Browse Source 
This CL only add the script for building DataX development environment
This commit is contained in:
Mingyu Chen
2021-06-30 09:55:19 +08:00
committed by GitHub
parent 6441a4c0ca
commit b69ebc3ec4
4 changed files with 106 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
fe/fe-core/src/test/java/org/apache/doris/common/ThreadPoolManagerTest.java
View File

@ -19,11 +19,12 @@ package org.apache.doris.common;
import org.apache.doris.metric.Metric;
import org.apache.doris.metric.MetricRepo;
import org.junit.Assert;
import org.junit.Test;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.List;
import java.util.concurrent.ThreadPoolExecutor;
public class ThreadPoolManagerTest {
@ -68,10 +69,10 @@ public class ThreadPoolManagerTest {
for (int i = 0; i < 4; i++) {
testFixedThreaddPool.submit(task);
}
Assert.assertTrue(testFixedThreaddPool.getActiveCount() <= 2);
Assert.assertTrue(testFixedThreaddPool.getQueue().size() > 0);
Assert.assertEquals(2, testFixedThreaddPool.getPoolSize());
Assert.assertEquals(2, testFixedThreaddPool.getActiveCount());
Assert.assertEquals(2, testFixedThreaddPool.getQueue().size());
Assert.assertEquals(0, testFixedThreaddPool.getCompletedTaskCount());
Thread.sleep(2000);