You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/03/09 12:02:30 UTC
[5/9] flink git commit: [FLINK-4545] [network] remove fixed-size
BufferPool instances
http://git-wip-us.apache.org/repos/asf/flink/blob/8b49ee5a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
index e141cc2..424fc8b 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/taskmanager/TaskManagerFailsITCase.scala
@@ -24,6 +24,7 @@ import org.apache.flink.configuration.ConfigConstants
import org.apache.flink.configuration.Configuration
import org.apache.flink.runtime.akka.{AkkaUtils, ListeningBehaviour}
import org.apache.flink.runtime.client.JobExecutionException
+import org.apache.flink.runtime.io.network.partition.ResultPartitionType
import org.apache.flink.runtime.jobgraph.{DistributionPattern, JobGraph, JobVertex}
import org.apache.flink.runtime.jobmanager.Tasks.{BlockingReceiver, Sender}
import org.apache.flink.runtime.testtasks.{BlockingNoOpInvokable, NoOpInvokable}
@@ -94,7 +95,8 @@ class TaskManagerFailsITCase(_system: ActorSystem)
receiver.setInvokableClass(classOf[BlockingReceiver])
sender.setParallelism(num_tasks)
receiver.setParallelism(num_tasks)
- receiver.connectNewDataSetAsInput(sender, DistributionPattern.POINTWISE)
+ receiver.connectNewDataSetAsInput(sender, DistributionPattern.POINTWISE,
+ ResultPartitionType.PIPELINED)
val jobGraph = new JobGraph("Pointwise Job", sender, receiver)
val jobID = jobGraph.getJobID
@@ -146,7 +148,8 @@ class TaskManagerFailsITCase(_system: ActorSystem)
receiver.setInvokableClass(classOf[BlockingReceiver])
sender.setParallelism(num_tasks)
receiver.setParallelism(num_tasks)
- receiver.connectNewDataSetAsInput(sender, DistributionPattern.POINTWISE)
+ receiver.connectNewDataSetAsInput(sender, DistributionPattern.POINTWISE,
+ ResultPartitionType.PIPELINED)
val jobGraph = new JobGraph("Pointwise Job", sender, receiver)
val jobID = jobGraph.getJobID