diff --git a/nephele/nephele-examples/src/main/java/eu/stratosphere/nephele/example/broadcast/BroadcastJob.java b/nephele/nephele-examples/src/main/java/eu/stratosphere/nephele/example/broadcast/BroadcastJob.java
index 8d21118565524..3404071702613 100644
--- a/nephele/nephele-examples/src/main/java/eu/stratosphere/nephele/example/broadcast/BroadcastJob.java
+++ b/nephele/nephele-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:///tmp/"));
+		consumer.setNumberOfSubtasks(8);
+		consumer.setVertexToShareInstancesWith(producer);
 
 		try {
 			producer.connectTo(consumer, ChannelType.NETWORK, CompressionLevel.NO_COMPRESSION);