From 5ceb820be51061c8d855a02c0e181b0e2f350627 Mon Sep 17 00:00:00 2001
From: jortiz16 <jortiz16@uw.edu>
Date: Tue, 26 May 2015 11:18:35 -0700
Subject: [PATCH] fixing ingest w/ rebase

---
 .../washington/escience/myria/systemtest/DbDeleteTest.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/systemtest/edu/washington/escience/myria/systemtest/DbDeleteTest.java b/systemtest/edu/washington/escience/myria/systemtest/DbDeleteTest.java
index 64bde9c6a..00c83a6ef 100644
--- a/systemtest/edu/washington/escience/myria/systemtest/DbDeleteTest.java
+++ b/systemtest/edu/washington/escience/myria/systemtest/DbDeleteTest.java
@@ -19,6 +19,7 @@
 import edu.washington.escience.myria.io.DataSource;
 import edu.washington.escience.myria.io.FileSource;
 import edu.washington.escience.myria.operator.TupleSource;
+import edu.washington.escience.myria.operator.network.partition.RoundRobinPartitionFunction;
 import edu.washington.escience.myria.util.JsonAPIUtils;
 
 /**
@@ -98,6 +99,7 @@ public void ingestTestDataset() throws Exception {
     DataSource relationSource = new FileSource(Paths.get("testdata", "filescan", "simple_two_col_int.txt").toString());
     relationKey = RelationKey.of("public", "adhoc", "testIngest");
     relationSchema = Schema.of(ImmutableList.of(Type.INT_TYPE, Type.INT_TYPE), ImmutableList.of("x", "y"));
-    JsonAPIUtils.ingestData("localhost", masterDaemonPort, ingest(relationKey, relationSchema, relationSource, ' '));
+    JsonAPIUtils.ingestData("localhost", masterDaemonPort, ingest(relationKey, relationSchema, relationSource, ' ',
+        new RoundRobinPartitionFunction(workerIDs.length)));
   }
 }