[hotfix] Set RescalingHandlers timeout to RpcUtils.INF_TIMEOUT

changzhiwin · Mar 27, 2018 · c28096a · c28096a
1 parent a0ba69e
commit c28096a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../src/main/java/org/apache/flink/runtime/rest/handler/job/rescaling/RescalingHandlers.java b/.../src/main/java/org/apache/flink/runtime/rest/handler/job/rescaling/RescalingHandlers.java
@@ -32,6 +32,7 @@
 import org.apache.flink.runtime.rest.messages.RescalingParallelismQueryParameter;
 import org.apache.flink.runtime.rest.messages.TriggerId;
 import org.apache.flink.runtime.rest.messages.TriggerIdPathParameter;
+import org.apache.flink.runtime.rpc.RpcUtils;
 import org.apache.flink.runtime.webmonitor.RestfulGateway;
 import org.apache.flink.runtime.webmonitor.retriever.GatewayRetriever;
 import org.apache.flink.util.SerializedThrowable;
@@ -80,7 +81,7 @@ protected CompletableFuture<Acknowledge> triggerOperation(HandlerRequest<EmptyRe
 				jobId,
 				newParallelism,
 				RescalingBehaviour.STRICT,
-				timeout);
+				RpcUtils.INF_TIMEOUT);
 
 			return rescalingFuture;
 		}