[streaming] jobgraphbuilder setnumberoftasksperinstance update

edd89686 · gyfora · Stephan Ewen · e3f0f4bc · edd89686
隐藏空白更改
内联并排

Showing with 2 addition and 0 deletion

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/JobGraphBuilder.java ...n/java/eu/stratosphere/streaming/api/JobGraphBuilder.java +2 -0

未找到文件。
--- a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/JobGraphBuilder.java
+++ b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/JobGraphBuilder.java
@@ -171,6 +171,8 @@ public class JobGraphBuilder {
 			final Class<? extends UserInvokable> InvokableClass,
 			int parallelism, AbstractJobVertex component) {
 		component.setNumberOfSubtasks(parallelism);
+		component.setNumberOfSubtasksPerInstance(parallelism);
+
 		Configuration config = new TaskConfig(component.getConfiguration())
 				.getConfiguration();
 		config.setClass("userfunction", InvokableClass);