Skip to content

Commit

Permalink
remove gradle error message for milestone-8
Browse files Browse the repository at this point in the history
  • Loading branch information
cwensel committed Apr 10, 2012
1 parent 23f1b5a commit 089156e
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 77 deletions.
4 changes: 2 additions & 2 deletions build.gradle
Expand Up @@ -38,8 +38,8 @@ dependencies {
repositories {
mavenLocal()
mavenCentral()
mavenRepo name: 'conjars', urls: 'http://conjars.org/repo/'
mavenRepo name: 'apache', urls: 'https://repository.apache.org/content/repositories/releases/'
mavenRepo name: 'conjars', url: 'http://conjars.org/repo/'
mavenRepo name: 'apache', url: 'https://repository.apache.org/content/repositories/releases/'
}

dependencies {
Expand Down
76 changes: 1 addition & 75 deletions src/test/cascading/load/AllLoadsTest.java
Expand Up @@ -15,16 +15,10 @@
import cascading.load.generate.GenerateData;
import cascading.load.join.MultiJoin;
import cascading.load.pipeline.Pipeline;
import cascading.test.HadoopPlatform;
import cascading.test.LocalPlatform;
import cascading.test.PlatformRunner;
import org.junit.Test;

/**
*
*/
//@PlatformRunner.Platform({LocalPlatform.class, HadoopPlatform.class})
@PlatformRunner.Platform({HadoopPlatform.class})
public class AllLoadsTest extends LoadTestCase
{
String output = "build/test/output/load/";
Expand All @@ -34,7 +28,6 @@ public AllLoadsTest()
super();
}

@Test
public void testAllLoads() throws Exception
{
String output = this.output + "api/";
Expand Down Expand Up @@ -87,7 +80,6 @@ public void testAllLoads() throws Exception
assertEquals( 2, new File( pipeline.getOutputPaths()[ 0 ] ).list().length );
}

@Test
public void testMain() throws Exception
{
String output = this.output + "main/";
Expand All @@ -114,7 +106,6 @@ public void testMain() throws Exception
assertEquals( 6, new File( output + "output" ).list().length );
}

@Test
public void testCleanWorkFiles() throws Exception
{
String output = this.output + "maincwf/";
Expand Down Expand Up @@ -143,7 +134,6 @@ public void testCleanWorkFiles() throws Exception
assertEquals( 1, new File( output ).list().length );
}

@Test
public void testSingleLineStatus() throws Exception
{
String output = this.output + "mainsls/";
Expand Down Expand Up @@ -178,7 +168,6 @@ public void testSingleLineStatus() throws Exception
assertEquals( 15, lineNo );
}

@Test
public void testAllDiscreteFlows() throws Exception
{
String output = this.output + "mainadf/";
Expand All @@ -189,8 +178,7 @@ public void testAllDiscreteFlows() throws Exception
"-W", output + "working",
"-O", output + "output",

"-MXCF", "1", // Serial execution
"-MXCS", "1",
"-MXCF", "0", // Serial execution

"-g",
"-gf", "1",
Expand All @@ -212,66 +200,4 @@ public void testAllDiscreteFlows() throws Exception
assertEquals( 8, new File( output + "output" ).list().length );
}

@Test
public void testLocalMode() throws Exception
{
String output = this.output + "mainlm/";

String[] args = new String[]{
"-S", output + "status",
"-I", output + "input",
"-W", output + "working",
"-O", output + "output",

"-LM", // Local mode

"-g",
//"-gf", "1", // Local mode only has single file support
"-gs", "1",

"-ALL", // Original loads

//TODO own test
"-gwm", "0", // Normal distribution
"-gws", "0.2",

"-SLS"
};

assertTrue( new Main( args ).execute() );

assertEquals( 6, new File( output + "output" ).list().length );
}

@Test
public void testLocalModeCleanWorkFiles() throws Exception
{
String output = this.output + "mainlmcwf/";

String[] args = new String[]{
"-S", output + "status",
"-I", output + "input",
"-W", output + "working",
"-O", output + "output",

"-LM", // Local mode

"-g",
//"-gf", "1", // Local mode only has single file support
"-gs", "1",

"-ALL", // Original loads

//TODO own test
"-gwm", "0", // Normal distribution
"-gws", "0.2",

"-CWF"
};

assertTrue( new Main( args ).execute() );

assertEquals( 1, new File( output ).list().length );
}

}

0 comments on commit 089156e

Please sign in to comment.