Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ public class TestCompressorDecompressor {

@Test
public void testCompressorDecompressor() {
// no more for this data
// no more for this data, test
int SIZE = 44 * 1024;

byte[] rawData = generate(SIZE);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -168,6 +168,7 @@ public void testSnappyDecompressorCompressAIOBException() {

@Test
public void testSnappyCompressDecompress() {
// test
int BYTE_SIZE = 1024 * 54;
byte[] bytes = BytesGenerator.get(BYTE_SIZE);
SnappyCompressor compressor = new SnappyCompressor();
Expand Down Expand Up @@ -395,6 +396,7 @@ public static byte[] get(int size) {

@Test
public void testSnappyCompressDecompressInMultiThreads() throws Exception {
// test
MultithreadedTestUtil.TestContext ctx = new MultithreadedTestUtil.TestContext();
for(int i=0;i<10;i++) {
ctx.addThread( new MultithreadedTestUtil.TestingThread(ctx) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,7 @@ public void testZlibCompressorDecompressor() {

@Test
public void testCompressorDecompressorWithExeedBufferLimit() {
// test
int BYTE_SIZE = 100 * 1024;
byte[] rawData = generate(BYTE_SIZE);
try {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@
import org.slf4j.LoggerFactory;

public class TestDiskChecker {
// test
public static final Logger LOG =
LoggerFactory.getLogger(TestDiskChecker.class);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,7 @@
*/
public class TestReadWriteDiskValidator {

// test
private MetricsSystem ms;

@Before
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1414,6 +1414,7 @@ public void testDistributedShellResourceProfiles() throws Exception {

@Test
public void testDSShellWithOpportunisticContainers() throws Exception {
// test
Client client = new Client(new Configuration(yarnCluster.getConfig()));
try {
String[] args = {
Expand Down Expand Up @@ -1444,6 +1445,7 @@ public void testDSShellWithOpportunisticContainers() throws Exception {
@Test
@TimelineVersion(2.0f)
public void testDSShellWithEnforceExecutionType() throws Exception {
// test
Client client = new Client(new Configuration(yarnCluster.getConfig()));
try {
String[] args = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,7 @@ public void beforeMethod() {

@Test
public void testIdentityService() throws IOException {
// test
try {
driver.start();
CsiClient client = new CsiClientImpl(domainSocket);
Expand Down