Changed configuration of broadcast test job

VonRosenchild · Mar 11, 2011 · ebfe519 · ebfe519
1 parent 3e2f7e9
commit ebfe519
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...ephele-examples/src/main/java/eu/stratosphere/nephele/example/broadcast/BroadcastJob.java b/...ephele-examples/src/main/java/eu/stratosphere/nephele/example/broadcast/BroadcastJob.java
@@ -82,6 +82,8 @@ public static void main(String[] args) {
  final JobFileOutputVertex consumer = new JobFileOutputVertex("Broadcast Consumer", jobGraph);
  consumer.setFileOutputClass(BroadcastConsumer.class);
  consumer.setFilePath(new Path("file:https:///tmp/"));
+ consumer.setNumberOfSubtasks(8);
+ consumer.setVertexToShareInstancesWith(producer);
 
  try {
  producer.connectTo(consumer, ChannelType.NETWORK, CompressionLevel.NO_COMPRESSION);