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 2014/09/21 04:12:41 UTC
[17/63] [abbrv] git commit: Refactor job graph construction to
incremental attachment based
Refactor job graph construction to incremental attachment based
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/b32e77a2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/b32e77a2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/b32e77a2
Branch: refs/heads/master
Commit: b32e77a2d8be76aeafa28b94fd7cfbb8de80f4cb
Parents: c16f6d8
Author: Stephan Ewen <se...@apache.org>
Authored: Mon Jun 30 21:16:15 2014 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Sat Sep 20 20:02:48 2014 +0200
----------------------------------------------------------------------
docs/img/state_machine.svg | 235 ++
.../mapred/HadoopInputFormat.java | 7 +-
.../mapred/record/HadoopRecordInputFormat.java | 8 +-
.../mapred/record/HadoopRecordOutputFormat.java | 2 +-
.../mapred/wrapper/HadoopInputSplit.java | 6 +
.../mapreduce/HadoopInputFormat.java | 7 +-
.../flink/addons/hbase/TableInputFormat.java | 20 +-
.../flink/addons/hbase/TableInputSplit.java | 2 +
.../flink/api/java/io/jdbc/JDBCInputFormat.java | 11 +-
.../org/apache/flink/client/CliFrontend.java | 2 +-
.../flink/client/CliFrontendListCancelTest.java | 11 -
.../plantranslate/NepheleJobGraphGenerator.java | 10 +-
.../common/io/DefaultInputSplitAssigner.java | 75 +
.../flink/api/common/io/FileInputFormat.java | 7 +-
.../flink/api/common/io/FileOutputFormat.java | 1 -
.../apache/flink/api/common/io/FormatUtil.java | 186 --
.../flink/api/common/io/GenericInputFormat.java | 5 +-
.../flink/api/common/io/InitializeOnMaster.java | 1 -
.../apache/flink/api/common/io/InputFormat.java | 9 +-
.../common/io/LocatableInputSplitAssigner.java | 197 ++
.../flink/api/common/io/NonParallelInput.java | 3 +-
.../flink/api/common/io/OutputFormat.java | 2 -
.../apache/flink/core/fs/FileInputSplit.java | 15 +-
.../apache/flink/core/io/GenericInputSplit.java | 2 +-
.../flink/core/io/IOReadableWritable.java | 1 -
.../apache/flink/core/io/InputSplitSource.java | 48 +
.../flink/core/memory/DataInputViewStream.java | 43 +
.../flink/core/memory/DataOutputViewStream.java | 43 +
.../java/org/apache/flink/util/ClassUtils.java | 1 -
.../org/apache/flink/util/ExceptionUtils.java | 78 +
.../flink/util/NumberSequenceIterator.java | 24 +-
.../apache/flink/util/SimpleStringUtils.java | 2 -
.../flink/util/TraversableOnceException.java | 7 +
.../apache/flink/api/common/io/FormatUtil.java | 186 ++
.../flink/core/io/DefaultSplitAssignerTest.java | 125 +
.../core/io/LocatableSplitAssignerTest.java | 385 +++
...ternalProcessFixedLengthInputFormatTest.java | 6 +-
.../io/ExternalProcessInputFormatTest.java | 9 +-
.../TypeExtractorInputFormatsTest.java | 5 +-
.../org/apache/flink/runtime/AbstractID.java | 20 +-
.../org/apache/flink/runtime/JobException.java | 32 +
.../flink/runtime/JobSubmissionException.java | 44 -
.../flink/runtime/client/AbstractJobResult.java | 16 +-
.../apache/flink/runtime/client/JobClient.java | 27 +-
.../runtime/client/JobSubmissionResult.java | 19 -
.../deployment/ChannelDeploymentDescriptor.java | 45 +-
.../deployment/GateDeploymentDescriptor.java | 122 +-
.../deployment/TaskDeploymentDescriptor.java | 367 +--
.../flink/runtime/event/job/AbstractEvent.java | 43 +-
.../event/job/ExecutionStateChangeEvent.java | 27 +-
.../flink/runtime/event/job/JobEvent.java | 17 +-
.../runtime/event/job/ManagementEvent.java | 8 +-
.../event/job/VertexAssignmentEvent.java | 151 -
.../flink/runtime/event/job/VertexEvent.java | 51 +-
.../flink/runtime/event/task/AbstractEvent.java | 10 +-
.../flink/runtime/execution/Environment.java | 14 -
.../runtime/execution/ExecutionAttempt.java | 100 +
.../runtime/execution/ExecutionListener.java | 49 +-
.../runtime/execution/ExecutionObserver.java | 19 +-
.../runtime/execution/ExecutionState2.java | 38 +
.../execution/ExecutionStateTransition.java | 118 -
.../runtime/execution/RuntimeEnvironment.java | 379 +--
.../librarycache/LibraryCacheManager.java | 6 +-
.../librarycache/LibraryCacheUpdate.java | 26 +-
.../executiongraph/AllVerticesIterator.java | 71 +
.../DistributionPatternProvider.java | 83 -
.../executiongraph/ExecutionAttemptID.java | 30 +
.../runtime/executiongraph/ExecutionEdge2.java | 74 +
.../runtime/executiongraph/ExecutionGraph.java | 2688 ++++++++++--------
.../executiongraph/ExecutionGraphIterator.java | 444 ---
.../ExecutionGroupVertexIterator.java | 331 ---
.../executiongraph/ExecutionJobVertex.java | 220 ++
.../executiongraph/ExecutionPipeline.java | 129 -
.../executiongraph/ExecutionSignature.java | 158 -
.../runtime/executiongraph/ExecutionStage.java | 411 ---
.../executiongraph/ExecutionStageListener.java | 43 -
.../runtime/executiongraph/ExecutionState.java | 34 +
.../runtime/executiongraph/ExecutionVertex.java | 34 +-
.../executiongraph/ExecutionVertex2.java | 638 ++++-
.../executiongraph/ExecutionVertexID.java | 74 -
.../GraphConversionException.java | 51 -
.../executiongraph/IntermediateResult.java | 82 +
.../IntermediateResultPartition.java | 68 +
.../executiongraph/InternalJobStatus.java | 104 -
.../executiongraph/JobStatusListener.java | 22 +-
.../flink/runtime/instance/AllocatedSlot.java | 48 +-
.../instance/DefaultInstanceManager.java | 314 --
.../apache/flink/runtime/instance/Instance.java | 26 +
.../flink/runtime/instance/InstanceManager.java | 281 +-
.../runtime/instance/LocalInstanceManager.java | 9 +-
.../disk/iomanager/ChannelReaderInputView.java | 11 +-
.../disk/iomanager/ChannelWriterOutputView.java | 10 +-
.../runtime/io/disk/iomanager/Deserializer.java | 61 -
.../HeaderlessChannelReaderInputView.java | 11 +-
.../runtime/io/disk/iomanager/IOManager.java | 21 +-
.../runtime/io/network/ChannelManager.java | 22 +-
.../runtime/io/network/gates/InputGate.java | 16 +-
.../runtime/io/network/gates/OutputGate.java | 9 +-
.../concurrent/SolutionSetUpdateBarrier.java | 1 -
.../jobgraph/AbstractJobInputVertex.java | 72 -
.../jobgraph/AbstractJobOutputVertex.java | 42 -
.../runtime/jobgraph/AbstractJobVertex.java | 623 ++--
.../runtime/jobgraph/DistributionPattern.java | 3 -
.../jobgraph/InputFormatInputVertex.java | 103 -
.../runtime/jobgraph/InputFormatVertex.java | 58 +
.../runtime/jobgraph/IntermediateDataSet.java | 83 +
.../runtime/jobgraph/IntermediateDataSetID.java | 53 +
.../apache/flink/runtime/jobgraph/JobEdge.java | 137 +-
.../apache/flink/runtime/jobgraph/JobGraph.java | 662 ++---
.../jobgraph/JobGraphDefinitionException.java | 33 -
.../flink/runtime/jobgraph/JobStatus.java | 36 +-
.../flink/runtime/jobgraph/JobTaskVertex.java | 55 -
.../flink/runtime/jobgraph/JobVertexID.java | 6 +
.../jobgraph/OutputFormatOutputVertex.java | 83 -
.../runtime/jobgraph/OutputFormatVertex.java | 66 +
.../runtime/jobgraph/SimpleInputVertex.java | 61 -
.../runtime/jobgraph/SimpleOutputVertex.java | 53 -
.../jobgraph/tasks/AbstractInvokable.java | 37 +-
.../jobgraph/tasks/InputSplitIterator.java | 5 +-
.../jobgraph/tasks/InputSplitProvider.java | 12 +-
.../runtime/jobmanager/DeploymentManager.java | 47 -
.../runtime/jobmanager/EventCollector.java | 253 +-
.../flink/runtime/jobmanager/JobManager.java | 999 ++-----
.../runtime/jobmanager/JobManagerUtils.java | 119 -
.../jobmanager/scheduler/DefaultScheduler.java | 18 +-
.../jobmanager/scheduler/LifoSetQueue.java | 25 +-
.../scheduler/NoResourceAvailableException.java | 31 +-
.../scheduler/SlotAvailablilityListener.java | 3 +-
.../jobmanager/scheduler/SlotSharingGroup.java | 13 +-
.../DefaultInputSplitAssigner.java | 75 -
.../splitassigner/InputSplitWrapper.java | 144 -
.../LocatableInputSplitAssigner.java | 197 --
.../managementgraph/ManagementVertex.java | 30 +-
.../managementgraph/ManagementVertexID.java | 4 +
.../runtime/operators/CollectorMapDriver.java | 1 +
.../flink/runtime/operators/CrossDriver.java | 2 +-
.../operators/sort/MergeMatchIterator.java | 4 +-
.../operators/sort/UnilateralSortMerger.java | 6 -
.../runtime/profiling/TaskManagerProfiler.java | 12 +-
.../profiling/impl/EnvironmentListenerImpl.java | 55 +-
.../profiling/impl/EnvironmentThreadSet.java | 11 +-
.../profiling/impl/JobProfilingData.java | 10 +-
.../profiling/impl/TaskManagerProfilerImpl.java | 13 +-
.../InternalExecutionVertexProfilingData.java | 24 +-
...ernalExecutionVertexThreadProfilingData.java | 21 +-
.../types/InternalInputGateProfilingData.java | 24 +-
.../types/InternalOutputGateProfilingData.java | 21 +-
.../impl/types/InternalProfilingData.java | 5 +-
.../protocols/ExtendedManagementProtocol.java | 26 -
.../protocols/InputSplitProviderProtocol.java | 27 +-
.../protocols/JobManagementProtocol.java | 5 +-
.../protocols/TaskOperationProtocol.java | 88 +-
.../runtime/taskmanager/AbstractTaskResult.java | 144 -
.../apache/flink/runtime/taskmanager/Task.java | 426 +--
.../runtime/taskmanager/TaskCancelResult.java | 50 -
.../runtime/taskmanager/TaskExecutionState.java | 130 +-
.../taskmanager/TaskInputSplitProvider.java | 56 +-
.../runtime/taskmanager/TaskKillResult.java | 50 -
.../flink/runtime/taskmanager/TaskManager.java | 1280 ++++-----
.../taskmanager/TaskOperationResult.java | 110 +
.../taskmanager/TaskSubmissionResult.java | 50 -
.../apache/flink/runtime/util/EnumUtils.java | 8 +-
.../runtime/util/ExecutorThreadFactory.java | 32 +-
.../runtime/util/SerializableArrayList.java | 38 +-
.../flink/runtime/client/JobResultTest.java | 2 -
.../ChannelDeploymentDescriptorTest.java | 6 +-
.../GateDeploymentDescriptorTest.java | 138 -
.../TaskDeploymentDescriptorTest.java | 291 +-
.../flink/runtime/event/job/JobEventTest.java | 32 +-
.../runtime/event/job/ManagementEventTest.java | 28 +-
.../executiongraph/AllVerticesIteratorTest.java | 67 +
.../ExecutionGraphConstructionTest.java | 570 ++++
.../ExecutionGraphDeploymentTest.java | 145 +
.../executiongraph/ExecutionGraphTest.java | 955 -------
.../executiongraph/ExecutionGraphTestUtils.java | 179 ++
.../ExecutionVertexCancelTest.java | 466 +++
.../ExecutionVertexDeploymentTest.java | 219 ++
.../ForwardTask1Input1Output.java | 52 -
.../ForwardTask1Input2Outputs.java | 58 -
.../ForwardTask2Inputs1Output.java | 64 -
.../executiongraph/PointwisePatternTest.java | 330 +++
.../executiongraph/SelfCrossForwardTask.java | 40 -
.../executiongraph/VertexSlotSharingTest.java | 103 +
.../runtime/instance/AllocatedSlotTest.java | 140 +
.../instance/DefaultInstanceManagerTest.java | 275 --
.../runtime/instance/InstanceManagerTest.java | 276 ++
.../instance/LocalInstanceManagerTest.java | 25 +-
.../flink/runtime/instance/SlotTestUtils.java | 23 +
.../flink/runtime/jobgraph/JobGraphTest.java | 274 +-
.../runtime/jobgraph/JobTaskVertexTest.java | 166 ++
.../runtime/jobmanager/DoubleSourceTask.java | 138 -
.../runtime/jobmanager/DoubleTargetTask.java | 63 -
.../flink/runtime/jobmanager/ForwardTask.java | 51 -
.../runtime/jobmanager/JobManagerITCase.java | 1073 +------
.../runtime/jobmanager/JobManagerTest.java | 23 +
.../jobmanager/RuntimeExceptionTask.java | 42 -
.../flink/runtime/jobmanager/UnionTask.java | 63 -
.../splitassigner/DefaultSplitAssignerTest.java | 124 -
.../LocatableSplitAssignerTest.java | 382 ---
.../runtime/jobmanager/tasks/NoOpInvokable.java | 33 +
.../sort/SortMergeMatchIteratorITCase.java | 2 -
.../operators/testutils/DriverTestBase.java | 1 -
.../operators/testutils/MockEnvironment.java | 10 -
.../operators/util/HashVsSortMiniBenchmark.java | 2 -
.../flink/runtime/taskmanager/OneShotLatch.java | 41 +
.../taskmanager/TaskExecutionStateTest.java | 72 +
.../runtime/taskmanager/TaskManagerTest.java | 390 +++
.../flink/runtime/taskmanager/TaskTest.java | 346 +++
.../testutils/tasks/DoubleSourceTask.java | 138 -
.../runtime/testutils/tasks/FileLineReader.java | 137 -
.../runtime/testutils/tasks/FileLineWriter.java | 76 -
.../testutils/tasks/JobFileInputVertex.java | 259 --
.../testutils/tasks/JobFileOutputVertex.java | 113 -
.../util/DelegatingConfigurationTest.java | 93 +
.../util/TestDelegatingConfiguration.java | 93 -
.../BroadcastVarsNepheleITCase.java | 18 +-
.../KMeansIterativeNepheleITCase.java | 33 +-
.../ConnectedComponentsNepheleITCase.java | 58 +-
.../IterationWithChainingNepheleITCase.java | 8 +-
.../test/iterative/nephele/JobGraphUtils.java | 33 +-
.../CustomCompensatableDanglingPageRank.java | 6 +-
...mpensatableDanglingPageRankWithCombiner.java | 11 +-
.../CompensatableDanglingPageRank.java | 10 +-
.../nephele/jobgraph/IntermediateDataSet.java | 42 -
.../nephele/jobgraph/IntermediateDataSetID.java | 50 -
225 files changed, 11600 insertions(+), 14492 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/docs/img/state_machine.svg
----------------------------------------------------------------------
diff --git a/docs/img/state_machine.svg b/docs/img/state_machine.svg
new file mode 100644
index 0000000..6aadb50
--- /dev/null
+++ b/docs/img/state_machine.svg
@@ -0,0 +1,235 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<!-- Created with Inkscape (http://www.inkscape.org/) -->
+
+<svg
+ xmlns:dc="http://purl.org/dc/elements/1.1/"
+ xmlns:cc="http://creativecommons.org/ns#"
+ xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#"
+ xmlns:svg="http://www.w3.org/2000/svg"
+ xmlns="http://www.w3.org/2000/svg"
+ version="1.0"
+ width="230.41mm"
+ height="154.87mm"
+ id="svg2985">
+ <metadata
+ id="metadata3079">
+ <rdf:RDF>
+ <cc:Work
+ rdf:about="">
+ <dc:format>image/svg+xml</dc:format>
+ <dc:type
+ rdf:resource="http://purl.org/dc/dcmitype/StillImage" />
+ <dc:title></dc:title>
+ </cc:Work>
+ </rdf:RDF>
+ </metadata>
+ <defs
+ id="defs2987" />
+ <g
+ id="g2989">
+ <path
+ d="m 146.66237,340.91829 c 0,-20.55261 16.68962,-37.20472 37.27974,-37.20472 20.59011,0 37.26098,16.65211 37.26098,37.20472 0,20.53386 -16.67087,37.18597 -37.26098,37.18597 -20.59012,0 -37.27974,-16.65211 -37.27974,-37.18597"
+ id="path2991"
+ style="fill:#5b9bd5;fill-opacity:1;fill-rule:evenodd;stroke:none" />
+ <path
+ d="m 146.66237,340.91829 c 0,-20.55261 16.68962,-37.20472 37.27974,-37.20472 20.59011,0 37.26098,16.65211 37.26098,37.20472 0,20.53386 -16.67087,37.18597 -37.26098,37.18597 -20.59012,0 -37.27974,-16.65211 -37.27974,-37.18597"
+ id="path2993"
+ style="fill:none;stroke:#41719c;stroke-width:1.25640953px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" />
+ <text
+ x="148.53239"
+ y="346.52737"
+ id="text2995"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">CREATED</text>
+ <path
+ d="m 321.52833,238.17399 c 0,-20.59011 16.68962,-37.27973 37.27973,-37.27973 20.59012,0 37.26098,16.68962 37.26098,37.27973 0,20.57137 -16.67086,37.26099 -37.26098,37.26099 -20.59011,0 -37.27973,-16.68962 -37.27973,-37.26099"
+ id="path2997"
+ style="fill:#5b9bd5;fill-opacity:1;fill-rule:evenodd;stroke:none" />
+ <path
+ d="m 321.52833,238.17399 c 0,-20.59011 16.68962,-37.27973 37.27973,-37.27973 20.59012,0 37.26098,16.68962 37.26098,37.27973 0,20.57137 -16.67086,37.26099 -37.26098,37.26099 -20.59011,0 -37.27973,-16.68962 -37.27973,-37.26099"
+ id="path2999"
+ style="fill:none;stroke:#41719c;stroke-width:1.25640953px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" />
+ <text
+ x="335.59247"
+ y="234.72913"
+ id="text3001"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">SCHE</text>
+ <text
+ x="377.29776"
+ y="234.72913"
+ id="text3003"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">-</text>
+ <text
+ x="333.49219"
+ y="252.73141"
+ id="text3005"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">DULED</text>
+ <path
+ d="m 295.91258,509.1459 c 0,-20.59011 16.68961,-37.27973 37.26098,-37.27973 20.59011,0 37.27973,16.68962 37.27973,37.27973 0,20.57136 -16.68962,37.26098 -37.27973,37.26098 -20.57137,0 -37.26098,-16.68962 -37.26098,-37.26098"
+ id="path3007"
+ style="fill:#5b9bd5;fill-opacity:1;fill-rule:evenodd;stroke:none" />
+ <path
+ d="m 294.07484,511.09615 -0.0375,-1.95025 0.0563,-2.02526 0.15002,-1.98775 0.24378,-1.95025 0.33755,-1.91274 0.41255,-1.78147 3.65671,0.8251 -0.3938,1.74397 0.0188,-0.0938 -0.33755,1.83773 0.0188,-0.11251 -0.22503,1.87524 0,-0.0938 -0.15002,1.89399 0,-0.0938 -0.0375,1.91275 0,-0.075 0.0375,1.91274 -3.75048,0.075 z m 2.3628,-15.45196 0.67509,-1.74397 0.7876,-1.74398 0.86261,-1.66896 0.93762,-1.63145 1.01263,-1.59396 1.10639,-1.53769 0.28128,-0.37505 2.96288,2.30654 -0.26254,0.33755 0.0375,-0.075 -1.03138,1.46268 0.0563,-0.075 -0.97513,1.51895 0.0563,-0.0563 -0.90012,1.55645 0.0375,-0.0938 -0.82511,1.61271 0.0375,-0.0938 -0.7501,1.65021 0.0375,-0.0938 -0.65633,1.70647 -3.48795,-1.36892 z m 8.21355,-13.29544 0.84385,-0.88136 1.36893,-1.31267 1.42518,-1.2189 1.48144,-1.16265 1.51894,-1.08764 1.59395,-1.01263 1.01263,-0.58132 1.85648,3.24416 -0.95637,0.56257 0.075,-0.0563 -1.50019,0.97513 0.0563,-0.0375 -1.46269,1.03138 0.075,-0.0563 -1.40643,1.10639 0.075,-0.0563 -1.36892,1.16265
0.075,-0.0563 -1.29391,1.23766 0.0562,-0.075 -0.80635,0.86261 -2.71909,-2.58783 z m 12.73286,-9.0199 0.56257,-0.26253 1.78148,-0.69384 1.81898,-0.61883 1.85649,-0.52506 1.89399,-0.43131 1.91274,-0.33754 1.53769,-0.20628 0.48757,3.71297 -1.50019,0.20628 0.0938,-0.0188 -1.81898,0.31879 0.075,-0.0188 -1.80023,0.41255 0.0938,-0.0188 -1.76272,0.50631 0.075,-0.0188 -1.72522,0.58132 0.0938,-0.0375 -1.68772,0.65633 0.075,-0.0375 -0.50631,0.24378 -1.55645,-3.41294 z m 15.30194,-3.31917 0.48757,-0.0188 2.02525,0.0563 1.98776,0.15002 1.95024,0.26253 1.9315,0.33754 1.89399,0.43131 1.38768,0.3938 -1.03138,3.60045 -1.35018,-0.37504 0.11252,0.0188 -1.80023,-0.41255 0.075,0.0188 -1.83773,-0.31879 0.0938,0.0188 -1.85649,-0.24378 0.0938,0.0188 -1.89399,-0.15002 0.11252,0 -1.9315,-0.0563 0.0938,0 -0.45005,0.0188 -0.0938,-3.75048 z m 15.37696,2.92537 0.35629,0.13127 1.72522,0.7876 1.70647,0.88136 1.63146,0.93762 1.5752,1.01263 1.53769,1.08764 1.48144,1.16265 0.11251,0.0938 -2.43781,2.85036 -0.0938,-0.
075 0.075,0.0563 -1.40643,-1.10639 0.075,0.0563 -1.46268,-1.03138 0.0562,0.0375 -1.50019,-0.97513 0.075,0.0563 -1.55644,-0.90011 0.075,0.0375 -1.6127,-0.8251 0.0938,0.0375 -1.65021,-0.75009 0.075,0.0375 -0.31879,-0.11251 1.38768,-3.48795 z m 13.0329,8.75737 1.06889,1.12514 1.2189,1.42518 1.16265,1.48144 1.08764,1.53769 1.01263,1.59396 0.95637,1.63145 0.37505,0.71259 -3.33793,1.72522 -0.35629,-0.69384 0.0375,0.0938 -0.90011,-1.55645 0.0562,0.0563 -0.97512,-1.51895 0.0563,0.075 -1.05014,-1.46268 0.0563,0.075 -1.10639,-1.40643 0.0563,0.075 -1.16265,-1.35017 0.0563,0.0563 -1.03138,-1.08764 2.71909,-2.58782 z m 8.49483,13.08916 0.3563,0.90011 0.61883,1.81898 0.52506,1.85649 0.43131,1.91274 0.35629,1.91274 0.24378,1.95025 0.0938,1.12515 -3.75047,0.30003 -0.075,-1.08763 0,0.0938 -0.22503,-1.87524 0.0188,0.11251 -0.33754,-1.83773 0.0188,0.0938 -0.41255,-1.81898 0.0188,0.11252 -0.50631,-1.76273 0.0375,0.075 -0.58132,-1.74397 0.0375,0.0938 -0.33754,-0.84386 3.46919,-1.38767 z m 2.7191,15.4144
6 -0.0375,0.97512 -0.15002,1.969 -0.24378,1.95025 -0.35629,1.93149 -0.43131,1.89399 -0.52506,1.87524 -0.33755,0.99388 -3.5442,-1.20016 0.31879,-0.95637 -0.0375,0.075 0.50631,-1.76272 -0.0188,0.0938 0.41255,-1.80023 -0.0188,0.0938 0.33754,-1.83773 -0.0188,0.0938 0.22503,-1.87524 0,0.0938 0.15002,-1.87524 -0.0188,0.0938 0.0375,-0.91887 3.75048,0.0938 z m -3.5442,15.24568 -0.30004,0.67509 -0.86261,1.68771 -0.95637,1.63146 -1.01263,1.59395 -1.08764,1.5377 -1.16265,1.48143 -1.05013,1.21891 -2.83161,-2.45656 1.01263,-1.1814 -0.0563,0.0562 1.10639,-1.40642 -0.0563,0.075 1.05014,-1.46269 -0.0563,0.075 0.97512,-1.50019 -0.0562,0.0563 0.90011,-1.55645 -0.0375,0.0938 0.8251,-1.6127 -0.0375,0.075 0.28128,-0.63758 3.41294,1.55645 z m -9.18867,12.62035 -0.075,0.0563 -1.42518,1.23766 -1.48144,1.16265 -1.53769,1.08763 -1.5752,1.01263 -1.65021,0.93762 -1.68772,0.88136 -0.4313,0.18753 -1.5377,-3.41294 0.3938,-0.18752 -0.0938,0.0563 1.6127,-0.82511 -0.075,0.0375 1.55644,-0.90012 -0.075,0.0375 1.51895,
-0.95637 -0.0938,0.0375 1.46269,-1.03138 -0.0563,0.0563 1.40643,-1.10639 -0.075,0.0562 1.36893,-1.1814 -0.075,0.0563 0.0375,-0.0187 2.58783,2.71909 z m -13.50171,8.04478 -1.25641,0.41255 -1.85649,0.54382 -1.89399,0.4313 -1.9315,0.33754 -1.95024,0.24379 -1.98776,0.16877 -0.69383,0.0187 -0.0938,-3.75048 0.63758,-0.0187 -0.0938,0 1.89399,-0.15002 -0.0938,0.0188 1.85649,-0.24378 -0.0938,0.0188 1.83773,-0.3188 -0.075,0 1.80023,-0.41255 -0.11252,0.0375 1.78148,-0.50632 -0.075,0.0188 1.20015,-0.41256 1.20016,3.56296 z m -15.50822,2.08151 -1.38768,-0.11251 -1.95025,-0.24379 -1.93149,-0.33754 -1.89399,-0.4313 -1.85649,-0.54382 -1.81898,-0.60008 -0.65633,-0.26253 1.38767,-3.48794 0.60008,0.24378 -0.0938,-0.0375 1.72522,0.58133 -0.075,-0.0188 1.76272,0.50632 -0.0938,-0.0375 1.80023,0.41255 -0.075,0 1.83773,0.3188 -0.11251,-0.0188 1.87523,0.24378 -0.0938,-0.0188 1.35017,0.11252 -0.30003,3.73172 z m -15.07692,-4.12552 -0.97512,-0.50632 -1.63146,-0.93762 -1.59395,-1.01263 -1.51894,-1.08763 -1.481
44,-1.16265 -1.42518,-1.23766 -0.93762,-0.88136 2.58783,-2.7191 0.90011,0.84386 -0.075,-0.0563 1.36892,1.1814 -0.075,-0.0562 1.40643,1.10639 -0.075,-0.0563 1.46269,1.03138 -0.075,-0.0375 1.51894,0.95637 -0.075,-0.0375 1.55645,0.90012 -0.075,-0.0563 0.91887,0.48756 -1.70647,3.33793 z m -12.2453,-9.71374 -0.26254,-0.30004 -1.16264,-1.48143 -1.08764,-1.5377 -1.03138,-1.59395 -0.93762,-1.63146 -0.86261,-1.68771 -0.7876,-1.74397 -0.0563,-0.11252 3.5067,-1.36892 0.0188,0.075 -0.0375,-0.0938 0.7501,1.6502 -0.0375,-0.075 0.82511,1.59395 -0.0375,-0.0563 0.88137,1.55645 -0.0563,-0.0938 0.97512,1.51894 -0.0375,-0.075 1.03138,1.46269 -0.0375,-0.075 1.10639,1.40642 -0.0563,-0.0562 0.24378,0.28128 -2.85036,2.43781 z m -7.50096,-13.783 -0.46881,-1.65021 -0.45005,-1.89399 -0.33755,-1.91274 -0.26253,-1.969 -0.13127,-1.95025 3.73173,-0.26253 0.15002,1.89399 -0.0188,-0.11252 0.24379,1.87524 -0.0188,-0.0938 0.33755,1.83773 -0.0188,-0.0938 0.41256,1.80023 -0.0188,-0.0938 0.45006,1.59395 -3.60046,1.03138
z"
+ id="path3009"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875238px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <text
+ x="300.41989"
+ y="505.78619"
+ id="text3011"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">CANCEL</text>
+ <text
+ x="361.32761"
+ y="505.78619"
+ id="text3013"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">-</text>
+ <text
+ x="322.77271"
+ y="523.78845"
+ id="text3015"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">ED</text>
+ <path
+ d="m 681.76157,143.15568 c 0,-20.59012 16.65212,-37.27974 37.16722,-37.27974 20.55261,0 37.20472,16.68962 37.20472,37.27974 0,20.59011 -16.65211,37.27973 -37.20472,37.27973 -20.5151,0 -37.16722,-16.68962 -37.16722,-37.27973"
+ id="path3017"
+ style="fill:#5b9bd5;fill-opacity:1;fill-rule:evenodd;stroke:none" />
+ <path
+ d="m 679.92384,145.14343 -0.0375,-1.98775 0.0375,-2.02526 0.15002,-1.95025 0.26253,-1.98775 0.33754,-1.91274 0.41256,-1.76273 3.63796,0.82511 -0.37505,1.72522 0,-0.075 -0.33754,1.83773 0.0375,-0.11251 -0.26253,1.87524 0.0375,-0.11252 -0.15002,1.91274 0,-0.11251 -0.0375,1.91274 0,-0.075 0.0375,1.91275 -3.75047,0.11251 z m 2.32529,-15.41446 0,-0.0375 0.71259,-1.76273 0.7501,-1.72521 0.86261,-1.68772 0.93762,-1.65021 1.05013,-1.5752 1.08764,-1.53769 0.30004,-0.37505 2.92537,2.32529 -0.26253,0.33755 0.0375,-0.075 -1.01263,1.46268 0.0375,-0.075 -0.97513,1.50019 0.075,-0.075 -0.90011,1.5377 0.0375,-0.075 -0.8251,1.61271 0.0375,-0.075 -0.75009,1.65021 0.0375,-0.075 -0.67508,1.68771 0.0375,-0.075 0,0 -3.52545,-1.23766 z m 8.21355,-13.35169 0.86261,-0.90012 1.35017,-1.27516 1.42518,-1.23766 1.46268,-1.16264 1.5377,-1.08764 1.5752,-1.05013 1.01263,-0.56258 1.87524,3.26292 -0.97513,0.56257 0.075,-0.075 -1.50019,0.97512 0.075,-0.0375 -1.46269,1.05013 0.075,-0.075 -1.38767,1.12515 0.0375,
-0.075 -1.35017,1.16264 0.075,-0.0375 -1.27516,1.23766 0.0375,-0.075 -0.7876,0.86261 -2.73784,-2.58783 z m 12.75162,-9.03865 0.52506,-0.26253 1.76273,-0.67509 1.83773,-0.63758 1.83773,-0.52507 1.87524,-0.41255 1.95025,-0.33754 1.53769,-0.22503 0.48757,3.71297 -1.5002,0.22503 0.075,-0.0375 -1.83773,0.33755 0.11252,-0.0375 -1.80023,0.41256 0.075,0 -1.76273,0.48756 0.075,0 -1.72522,0.56257 0.11252,-0.0375 -1.68772,0.67509 0.075,-0.0375 -0.48756,0.22503 -1.53769,-3.41293 z m 15.26443,-3.30042 0.45006,-0.0375 2.02526,0.075 1.98775,0.15001 1.95025,0.26254 1.91274,0.33754 1.91274,0.41255 1.42518,0.41256 -1.01262,3.60045 -1.42518,-0.37504 0.11251,0 -1.80023,-0.41256 0.075,0.0375 -1.80023,-0.33755 0.075,0.0375 -1.83773,-0.26253 0.075,0.0375 -1.87524,-0.15002 0.075,0 -1.91274,-0.075 0.11251,0 -0.41255,0.0375 -0.11252,-3.75048 z m 15.37696,2.92537 0.30003,0.11252 1.72522,0.7876 1.68772,0.90011 1.65021,0.93762 1.5752,1.01263 1.53769,1.08764 1.46269,1.16264 0.18752,0.15002 -2.47531,2.85037 -0.15
002,-0.15002 0.075,0.075 -1.38768,-1.12515 0.075,0.075 -1.46268,-1.05013 0.075,0.0375 -1.5002,-0.93762 0.075,0.0375 -1.5752,-0.90011 0.075,0.0375 -1.5752,-0.8251 0.075,0.0375 -1.65021,-0.7501 0.075,0.0375 -0.26253,-0.11251 1.38768,-3.48795 z m 13.01415,8.81362 1.01263,1.05013 1.20015,1.42519 1.16265,1.50019 1.08764,1.53769 1.01262,1.5752 0.93762,1.65021 0.45006,0.82511 -3.37543,1.68771 -0.37505,-0.7876 0.0375,0.075 -0.90012,-1.5377 0.0375,0.075 -0.93762,-1.50019 0.0375,0.075 -1.05013,-1.46268 0.075,0.075 -1.12514,-1.42518 0.0375,0.075 -1.16264,-1.38768 0.075,0.075 -0.97512,-1.01263 2.73785,-2.58783 z m 8.43857,13.12667 0.33754,0.7876 0.60008,1.83773 0.52507,1.83774 0.45005,1.91274 0.33755,1.91274 0.22502,1.95025 0.11252,1.23766 -3.75048,0.30003 -0.075,-1.20015 0,0.11252 -0.22503,-1.87524 0,0.11251 -0.33754,-1.83773 0.0375,0.075 -0.41256,-1.80023 0.0375,0.075 -0.52507,-1.76272 0.0375,0.11251 -0.60008,-1.72522 0.0375,0.075 -0.30004,-0.7501 3.48794,-1.38767 z m 2.66284,15.41446 0,0.862
61 -0.15002,1.98775 -0.26253,1.95025 -0.33755,1.91274 -0.45005,1.91274 -0.52507,1.87524 -0.37505,1.08764 -3.56295,-1.20016 0.37505,-1.05013 -0.0375,0.075 0.52507,-1.76272 -0.0375,0.11251 0.41256,-1.83773 -0.0375,0.11251 0.33754,-1.83773 0,0.075 0.22503,-1.87524 0,0.11251 0.15002,-1.87523 0,0.075 0,-0.7876 3.75048,0.075 z m -3.56295,15.22693 -0.26254,0.60008 -0.86261,1.68771 -0.93762,1.6127 -1.01262,1.61271 -1.08764,1.53769 -1.16265,1.46269 -1.12514,1.31267 -2.85037,-2.43781 1.12515,-1.27516 -0.075,0.075 1.12514,-1.42519 -0.075,0.075 1.05013,-1.46268 -0.0375,0.075 0.93762,-1.50019 -0.0375,0.075 0.90012,-1.5752 -0.0375,0.075 0.82511,-1.61271 -0.0375,0.11252 0.22503,-0.56258 3.41294,1.5377 z m -9.30119,12.67661 -1.31266,1.16265 -1.46269,1.16264 -1.53769,1.08764 -1.5752,1.01263 -1.65021,0.93762 -1.68772,0.86261 -0.56257,0.26253 -1.53769,-3.41293 0.52506,-0.26253 -0.075,0.075 1.5752,-0.82511 -0.075,0.0375 1.5752,-0.90012 -0.075,0.0375 1.5002,-0.97513 -0.075,0.075 1.46268,-1.05013 -0.075,
0.0375 1.38768,-1.08763 -0.075,0.0375 1.31267,-1.08764 2.4378,2.81286 z m -13.4267,7.95101 -1.12514,0.37505 -1.83774,0.52506 -1.91274,0.45006 -1.91274,0.33754 -1.95025,0.22503 -1.98775,0.18753 -0.86261,0 -0.075,-3.75048 0.7876,0 -0.11252,0 1.91275,-0.15002 -0.11252,0 1.87524,-0.22503 -0.075,0 1.80023,-0.30004 -0.075,0 1.80023,-0.41255 -0.11251,0.0375 1.76272,-0.52507 -0.075,0.0375 1.08764,-0.37504 1.20015,3.56295 z m -15.52697,2.02526 -1.20015,-0.11252 -1.95025,-0.22503 -1.95025,-0.33754 -1.87524,-0.45006 -1.83773,-0.52506 -1.83773,-0.60008 -0.82511,-0.33754 1.38768,-3.48795 0.7876,0.30004 -0.11252,-0.0375 1.72522,0.60007 -0.075,-0.0375 1.76273,0.52507 -0.075,-0.0375 1.80023,0.41255 -0.11252,-0.0375 1.83773,0.33754 -0.075,0 1.83774,0.22503 -0.075,0 1.16265,0.075 -0.30004,3.75048 z m -15.03941,-4.20054 -0.7876,-0.41255 -1.65021,-0.93762 -1.5752,-1.01263 -1.5377,-1.08764 -1.46268,-1.16264 -1.42518,-1.23766 -1.08764,-1.05013 2.58783,-2.70035 1.05013,1.01263 -0.075,-0.075 1.35017,1.1626
5 -0.0375,-0.0375 1.38767,1.08763 -0.075,-0.0375 1.46269,1.01263 -0.075,-0.0375 1.50019,0.97513 -0.075,-0.0375 1.5752,0.90012 -0.075,-0.0375 0.71259,0.37505 -1.68771,3.33792 z m -12.18905,-9.78874 -0.11251,-0.15002 -1.16265,-1.46269 -1.12514,-1.53769 -1.01263,-1.61271 -0.90012,-1.6127 -0.90011,-1.68771 -0.7501,-1.72522 -0.15002,-0.33755 3.48795,-1.38767 0.11251,0.30004 -0.0375,-0.075 0.75009,1.65021 -0.0375,-0.11252 0.8251,1.61271 -0.0375,-0.075 0.90011,1.5752 -0.075,-0.075 0.97513,1.50019 -0.0375,-0.075 1.01263,1.46268 -0.0375,-0.075 1.12514,1.42519 -0.075,-0.075 0.11251,0.11251 -2.85036,2.43781 z m -7.42594,-13.83926 -0.37505,-1.42518 -0.45006,-1.87524 -0.33754,-1.95024 -0.26253,-1.95025 -0.15002,-1.95025 3.75047,-0.26253 0.15002,1.87523 -0.0375,-0.075 0.26253,1.83773 -0.0375,-0.075 0.33754,1.83773 -0.0375,-0.11251 0.45006,1.80023 -0.0375,-0.075 0.37504,1.35017 -3.60045,1.05013 z"
+ id="path3019"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.03750476px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <text
+ x="693.01093"
+ y="148.82382"
+ id="text3021"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">FAILED</text>
+ <path
+ d="m 213.98342,303.26351 3.76923,-6.82587 3.86299,-6.75086 1.969,-3.31917 2.04401,-3.26291 2.10027,-3.22541 2.17527,-3.1129 2.25029,-3.03788 2.34405,-2.94413 2.43781,-2.8316 2.56907,-2.70035 2.68159,-2.58783 2.83161,-2.41905 2.96288,-2.28779 3.11289,-2.10027 3.26292,-1.91274 3.41293,-1.76273 3.56295,-1.59395 3.67547,-1.42518 3.80673,-1.31267 3.88175,-1.16265 3.99425,-1.06888 4.08802,-0.93762 4.16303,-0.88136 4.21929,-0.76885 4.27554,-0.71259 4.3318,-0.67509 8.73861,-1.20015 6.97589,-0.86261 0.22503,1.85649 -6.95714,0.88136 0,-0.0188 -8.71986,1.20015 0,0 -4.31304,0.65633 0.0188,0 -4.25679,0.71259 0.0188,0 -4.20053,0.7876 0.0188,-0.0188 -4.14428,0.86261 0.0188,0 -4.05052,0.95637 0.0188,-0.0188 -3.95675,1.05013 0.0188,0 -3.86299,1.16265 0.0375,-0.0188 -3.75048,1.29391 0.0375,0 -3.63797,1.40643 0.0375,-0.0188 -3.52545,1.5752 0.0563,-0.0187 -3.37543,1.72522 0.0563,-0.0188 -3.22541,1.89399 0.0375,-0.0375 -3.05664,2.06276 0.0375,-0.0188 -2.90662,2.23153 0.0375,-0.0375 -2.77536,2.400
3 0.0375,-0.0375 -2.66284,2.55032 0.0375,-0.0375 -2.53157,2.68159 0.0188,-0.0375 -2.41906,2.81286 0.0375,-0.0375 -2.32529,2.92538 0.0188,-0.0375 -2.23153,3.01913 0.0188,-0.0375 -2.15652,3.1129 0,-0.0188 -2.08152,3.18791 0,-0.0187 -2.02526,3.24416 0.0188,0 -1.969,3.30042 0,-0.0188 -3.84424,6.73211 0.0188,0 -3.76923,6.82587 z m 91.99918,-67.02101 9.46996,4.03176 -8.19479,6.24454 c -0.41256,0.31879 -0.99388,0.24378 -1.31267,-0.16877 -0.30004,-0.41255 -0.22503,-0.99387 0.18752,-1.31266 l 6.90088,-5.26942 0.20628,1.6127 -7.98852,-3.41293 c -0.48756,-0.20628 -0.69384,-0.76885 -0.50631,-1.23766 0.20627,-0.48756 0.76884,-0.69384 1.23765,-0.48756 z"
+ id="path3023"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875238px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <path
+ d="m 217.90267,373.6412 8.32606,6.91962 8.2698,6.88213 4.06926,3.43168 4.01301,3.41294 3.95676,3.41293 3.90049,3.35668 3.80673,3.35667 3.71298,3.31917 3.61921,3.30042 3.50669,3.24417 3.39418,3.22541 3.26292,3.16915 3.11289,3.13165 2.96288,3.09414 2.81285,3.03788 2.66284,3.00038 2.51282,2.94413 2.38155,2.90662 2.26904,2.86911 2.15653,2.83161 2.04401,2.81286 1.95024,2.7566 1.87524,2.7566 1.80023,2.71909 1.74397,2.70035 1.68772,2.68159 3.26291,5.34443 2.21278,3.69422 -1.59395,0.95637 -2.23153,-3.69422 0,0.0188 -3.24417,-5.32568 0,0 -1.68771,-2.66283 0,0 -1.72522,-2.68159 0,0 -1.78148,-2.70035 0,0 -1.85648,-2.73785 0,0.0188 -1.95025,-2.7566 0.0188,0 -2.04401,-2.79411 0.0188,0.0187 -2.13778,-2.81285 0,0.0188 -2.25028,-2.86911 0,0.0188 -2.3628,-2.88787 0,0.0188 -2.49407,-2.94412 0.0188,0.0188 -2.64408,-2.98163 0,0.0188 -2.79411,-3.03789 0.0188,0.0188 -2.96288,-3.07539 0.0187,0.0187 -3.11289,-3.13164 0.0188,0.0188 -3.24416,-3.16915 0,0 -3.37543,-3.20666 0,0 -3.5067,-3.24416 0.0188,0
-3.61921,-3.28167 0,0 -3.71298,-3.30042 0,0 -3.78798,-3.35667 0,0.0188 -3.88174,-3.37543 0,0 -3.95675,-3.39418 0,0.0187 -4.01301,-3.41293 0,0 -4.06927,-3.43169 0,0 -8.23229,-6.88212 -8.32606,-6.91963 z m 91.30534,88.09868 0.15002,10.29506 -9.03864,-4.95063 c -0.45006,-0.24378 -0.61883,-0.8251 -0.3563,-1.27516 0.24378,-0.45006 0.80635,-0.61883 1.25641,-0.37505 l 7.63222,4.18178 -1.40643,0.82511 -0.11251,-8.68236 c 0,-0.50631 0.41255,-0.93761 0.93761,-0.93761 0.50632,-0.0188 0.93762,0.3938 0.93762,0.91886 z"
+ id="path3025"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875238px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <path
+ d="m 451.38857,238.17399 c 0,-20.59011 16.68962,-37.27973 37.27973,-37.27973 20.59012,0 37.26098,16.68962 37.26098,37.27973 0,20.57137 -16.67086,37.26099 -37.26098,37.26099 -20.59011,0 -37.27973,-16.68962 -37.27973,-37.26099"
+ id="path3027"
+ style="fill:#5b9bd5;fill-opacity:1;fill-rule:evenodd;stroke:none" />
+ <path
+ d="m 451.38857,238.17399 c 0,-20.59011 16.68962,-37.27973 37.27973,-37.27973 20.59012,0 37.26098,16.68962 37.26098,37.27973 0,20.57137 -16.67086,37.26099 -37.26098,37.26099 -20.59011,0 -37.27973,-16.68962 -37.27973,-37.26099"
+ id="path3029"
+ style="fill:none;stroke:#41719c;stroke-width:1.25640953px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" />
+ <text
+ x="456.49106"
+ y="234.72913"
+ id="text3031"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">DEPLOY</text>
+ <text
+ x="516.04858"
+ y="234.72913"
+ id="text3033"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">-</text>
+ <text
+ x="475.39346"
+ y="252.73141"
+ id="text3035"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">ING</text>
+ <path
+ d="m 734.56828,356.7828 c 0,-20.59011 16.65211,-37.27973 37.20472,-37.27973 20.51511,0 37.16722,16.68962 37.16722,37.27973 0,20.59012 -16.65211,37.27974 -37.16722,37.27974 -20.55261,0 -37.20472,-16.68962 -37.20472,-37.27974"
+ id="path3037"
+ style="fill:#5b9bd5;fill-opacity:1;fill-rule:evenodd;stroke:none" />
+ <path
+ d="m 732.73054,358.73305 -0.0375,-1.95025 0.0375,-1.98775 0.15002,-2.02525 0.26254,-1.95025 0.33754,-1.91275 0.41255,-1.76272 3.63796,0.82511 -0.37504,1.72521 0,-0.075 -0.30004,1.83773 0,-0.11252 -0.22503,1.87524 0,-0.11251 -0.15002,1.91274 0,-0.11251 -0.0375,1.91274 0,-0.075 0.0375,1.91274 -3.75048,0.075 z m 2.3628,-15.45196 0.67509,-1.72522 0.7876,-1.72522 0.86261,-1.68771 0.93762,-1.65021 1.01263,-1.5752 1.08763,-1.5752 0.30004,-0.37505 2.92537,2.3253 -0.26253,0.33754 0.075,-0.075 -1.05013,1.46269 0.0375,-0.075 -0.93762,1.53769 0.0375,-0.075 -0.90012,1.5377 0.0375,-0.075 -0.82511,1.6127 0.0375,-0.075 -0.71259,1.65021 0.0375,-0.11251 -0.67508,1.72522 -3.48795,-1.38768 z m 8.21355,-13.27669 0.8251,-0.90011 1.35017,-1.31267 1.42518,-1.20015 1.46269,-1.16265 1.53769,-1.08763 1.5752,-1.05014 1.05014,-0.56257 1.83773,3.26291 -0.97512,0.56258 0.11251,-0.075 -1.53769,0.97512 0.075,-0.0375 -1.46269,1.05013 0.075,-0.075 -1.38768,1.08764 0.075,-0.0375 -1.35017,1.16265 0.075,-0.0375 -
1.31267,1.23765 0.075,-0.075 -0.8251,0.86261 -2.70034,-2.58783 z m 12.71411,-9.03864 0.52507,-0.26254 1.80023,-0.67508 1.80022,-0.63758 1.83774,-0.52507 1.91274,-0.41255 1.91274,-0.33755 1.5752,-0.22502 0.48757,3.71297 -1.5377,0.22503 0.075,-0.0375 -1.83773,0.33754 0.11251,-0.0375 -1.80023,0.41255 0.11252,0 -1.76273,0.48756 0.075,0 -1.72522,0.56258 0.075,-0.0375 -1.68771,0.67509 0.075,-0.0375 -0.45006,0.22503 -1.5752,-3.41293 z m 15.30194,-3.30042 0.45006,-0.0375 1.98775,0.075 1.98776,0.15002 1.95024,0.26253 1.95025,0.33755 1.87524,0.41255 1.46268,0.41255 -1.05013,3.63796 -1.38767,-0.41255 0.075,0 -1.80022,-0.41255 0.11251,0.0375 -1.83773,-0.33754 0.075,0.0375 -1.83774,-0.26254 0.075,0.0375 -1.87524,-0.15002 0.075,0 -1.91274,-0.075 0.11252,0 -0.41256,0.0375 -0.075,-3.75047 z m 15.37696,2.92537 0.26253,0.11251 1.76272,0.7876 1.65021,0.90012 1.65021,0.90011 1.5752,1.05014 1.5377,1.08763 1.46268,1.16265 0.22503,0.15002 -2.47531,2.85036 -0.15002,-0.15002 0.0375,0.0375 -1.38767,-1.08764
0.075,0.075 -1.46269,-1.05013 0.075,0.0375 -1.50019,-0.97512 0.075,0.075 -1.5377,-0.90012 0.075,0.0375 -1.6127,-0.82511 0.075,0.0375 -1.65021,-0.7501 0.075,0.0375 -0.22503,-0.11252 1.38768,-3.48794 z m 12.97664,8.81362 1.01263,1.05013 1.23766,1.42518 1.16265,1.50019 1.05013,1.5377 1.05013,1.5752 0.93762,1.65021 0.41256,0.8251 -3.33793,1.68772 -0.41255,-0.7876 0.0375,0.075 -0.86261,-1.5377 0.0375,0.075 -0.97512,-1.53769 0.0375,0.075 -1.01263,-1.46269 0.0375,0.075 -1.08764,-1.38768 0.0375,0.075 -1.16264,-1.35017 0.0375,0.0375 -0.93762,-1.01263 2.70034,-2.58783 z m 8.47608,13.12667 0.30004,0.7876 0.60007,1.83773 0.56258,1.83773 0.41255,1.91274 0.33754,1.91275 0.26253,1.95025 0.11252,1.23765 -3.75048,0.30004 -0.11251,-1.20015 0.0375,0.11251 -0.26253,-1.87524 0.0375,0.11252 -0.33754,-1.83773 0,0.075 -0.41255,-1.80022 0.0375,0.11251 -0.48756,-1.76272 0,0.075 -0.56257,-1.76273 0.0375,0.11252 -0.30004,-0.7501 3.48794,-1.38767 z m 2.66284,15.41445 -0.0375,0.86261 -0.15002,1.98775 -0.26253,1.
95025 -0.33754,1.91274 -0.41255,1.91275 -0.52507,1.87524 -0.37505,1.08763 -3.56295,-1.20015 0.37505,-1.05013 -0.0375,0.075 0.48756,-1.76273 -0.0375,0.075 0.41255,-1.80023 0,0.11252 0.33754,-1.83773 -0.0375,0.075 0.26253,-1.87524 0,0.11251 0.11252,-1.87524 0,0.075 0.0375,-0.7876 3.75048,0.075 z m -3.56295,15.22694 -0.26254,0.60007 -0.86261,1.68772 -0.93762,1.6127 -1.05013,1.61271 -1.05013,1.53769 -1.16265,1.46269 -1.16265,1.31266 -2.81285,-2.43781 1.08763,-1.27516 -0.0375,0.0375 1.08764,-1.38768 -0.0375,0.075 1.01263,-1.46269 -0.0375,0.075 0.97512,-1.53769 -0.0375,0.11251 0.86261,-1.5752 -0.0375,0.075 0.8251,-1.6127 -0.0375,0.075 0.22503,-0.52507 3.45044,1.5377 z m -9.30118,12.67661 -1.35018,1.16264 -1.46268,1.12515 -1.5377,1.12514 -1.5752,1.01263 -1.65021,0.93762 -1.68771,0.86261 -0.56257,0.26253 -1.5377,-3.41293 0.52507,-0.26254 -0.075,0.075 1.6127,-0.8251 -0.11251,0.0375 1.5752,-0.90011 -0.075,0.0375 1.50019,-0.97512 -0.075,0.075 1.46269,-1.05013 -0.075,0.0375 1.42518,-1.08764 -0.
075,0.0375 1.27516,-1.12515 2.47532,2.85037 z m -13.46421,7.95101 -1.08764,0.37504 -1.87524,0.52507 -1.91274,0.45006 -1.91275,0.33754 -1.95024,0.22503 -1.98776,0.18752 -0.86261,0 -0.075,-3.75047 0.7876,0 -0.075,0 1.87524,-0.15002 -0.075,0 1.83774,-0.22503 -0.075,0 1.83773,-0.33754 -0.11251,0.0375 1.80022,-0.41255 -0.075,0.0375 1.76272,-0.52506 -0.075,0.0375 1.05013,-0.37505 1.20016,3.56296 z m -15.52698,2.02525 -1.20015,-0.11251 -1.95025,-0.22503 -1.91274,-0.33754 -1.91274,-0.45006 -1.83774,-0.52507 -1.80022,-0.60007 -0.86261,-0.33755 1.38767,-3.48794 0.7876,0.30004 -0.075,-0.0375 1.72522,0.60008 -0.11251,-0.0375 1.80023,0.52506 -0.11252,-0.0375 1.80023,0.41255 -0.11251,-0.0375 1.83773,0.33754 -0.075,0 1.83773,0.22503 -0.075,0 1.16265,0.075 -0.30004,3.75047 z m -15.03941,-4.20053 -0.7876,-0.41255 -1.65021,-0.93762 -1.5752,-1.01263 -1.53769,-1.12514 -1.46269,-1.16265 -1.42518,-1.20015 -1.08764,-1.05014 2.58783,-2.70034 1.05014,0.97512 -0.0375,-0.0375 1.35017,1.16265 -0.075,-0.0375 1.
38768,1.08764 -0.075,-0.0375 1.46269,1.01262 -0.075,-0.0375 1.50019,0.97512 -0.075,-0.0375 1.5752,0.90011 -0.075,-0.0375 0.75009,0.37505 -1.72522,3.33792 z m -12.18904,-9.78874 -0.11252,-0.15002 -1.16265,-1.46269 -1.08763,-1.53769 -1.01263,-1.61271 -0.93762,-1.6127 -0.86261,-1.68772 -0.7876,-1.76272 -0.15002,-0.30004 3.48794,-1.38768 0.15002,0.30004 -0.0375,-0.11251 0.71259,1.65021 -0.0375,-0.075 0.82511,1.6127 -0.0375,-0.075 0.90012,1.5752 -0.0375,-0.075 0.93762,1.50019 -0.0375,-0.075 1.05013,1.46269 -0.075,-0.075 1.12514,1.38768 -0.075,-0.0375 0.11252,0.11252 -2.85036,2.43781 z m -7.42595,-13.83926 -0.37504,-1.42518 -0.45006,-1.87524 -0.33754,-1.95025 -0.26254,-1.95025 -0.15002,-1.95024 3.75048,-0.26254 0.15002,1.87524 0,-0.11251 0.22503,1.87524 -0.0375,-0.075 0.33755,1.83773 0,-0.11252 0.41255,1.80023 -0.0375,-0.075 0.41256,1.38768 -3.63797,1.01263 z"
+ id="path3039"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.03750476px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <text
+ x="736.83307"
+ y="362.34521"
+ id="text3041"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">FINISHED</text>
+ <path
+ d="m 586.42447,238.19275 c 0,-20.59012 16.68961,-37.27974 37.27973,-37.27974 20.59011,0 37.24223,16.68962 37.24223,37.27974 0,20.55261 -16.65212,37.24223 -37.24223,37.24223 -20.59012,0 -37.27973,-16.68962 -37.27973,-37.24223"
+ id="path3043"
+ style="fill:#5b9bd5;fill-opacity:1;fill-rule:evenodd;stroke:none" />
+ <path
+ d="m 586.42447,238.19275 c 0,-20.59012 16.68961,-37.27974 37.27973,-37.27974 20.59011,0 37.24223,16.68962 37.24223,37.27974 0,20.55261 -16.65212,37.24223 -37.24223,37.24223 -20.59012,0 -37.27973,-16.68962 -37.27973,-37.24223"
+ id="path3045"
+ style="fill:none;stroke:#41719c;stroke-width:1.23765719px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" />
+ <text
+ x="588.8078"
+ y="243.73027"
+ id="text3047"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">RUNNING</text>
+ <path
+ d="m 400.92591,237.14261 38.40488,0 0,1.87524 -38.40488,0 z m 31.37273,-4.23804 8.88863,5.17566 -8.88863,5.19441 c -0.45005,0.26253 -1.03138,0.11252 -1.29391,-0.33754 -0.26253,-0.45006 -0.11251,-1.01263 0.33754,-1.27516 l 7.50095,-4.38806 0,1.63146 -7.50095,-4.38806 c -0.4313,-0.26253 -0.60007,-0.82511 -0.33754,-1.27516 0.26253,-0.45006 0.84386,-0.60008 1.29391,-0.33755 z"
+ id="path3049"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875238px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <path
+ d="m 535.47425,237.14261 38.40487,0 0,1.87524 -38.40487,0 z m 31.37273,-4.23804 8.88863,5.17566 -8.88863,5.19441 c -0.45006,0.26253 -1.03138,0.11252 -1.29392,-0.33754 -0.26253,-0.45006 -0.0938,-1.01263 0.33755,-1.27516 l 7.50095,-4.38806 0,1.63146 -7.50095,-4.38806 c -0.43131,-0.26253 -0.60008,-0.82511 -0.33755,-1.27516 0.26254,-0.45006 0.84386,-0.60008 1.29392,-0.33755 z"
+ id="path3051"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875238px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <path
+ d="m 672.49789,252.8196 6.60084,5.21317 6.52583,5.17565 6.41332,5.10065 3.1504,2.55032 3.07539,2.51282 3.03788,2.47532 2.96288,2.47531 2.88787,2.43781 2.81285,2.40031 2.70035,2.3628 2.58782,2.28779 2.51282,2.28779 2.40031,2.21278 2.25028,2.17527 2.17528,2.13778 2.02526,2.10026 1.95024,2.02526 1.87524,2.02526 1.76273,1.95024 1.68771,1.95025 1.61271,1.91275 1.5752,1.87523 1.50019,1.87524 2.85036,3.63796 2.77535,3.63797 1.5752,2.06276 -1.50019,1.12514 -1.5752,-2.06276 0,0 -2.73785,-3.60046 0,0 -2.85036,-3.63796 0,0 -1.50019,-1.83773 0,0 -1.5377,-1.87524 0,0 -1.6127,-1.87524 0,0 -1.68771,-1.95025 0.0375,0.0375 -1.76272,-1.98776 0,0.0375 -1.83774,-2.02526 0,0.0375 -1.95024,-2.06277 0.0375,0.0375 -2.06276,-2.10027 0.0375,0.0375 -2.17527,-2.13777 0.0375,0 -2.28779,-2.13778 0.0375,0 -2.40031,-2.21278 0,0 -2.47531,-2.28779 0,0.0375 -2.58783,-2.3253 0,0 -2.70034,-2.32529 0,0 -2.81286,-2.40031 0.0375,0 -2.88786,-2.43781 0,0 -2.96288,-2.43781 0,0 -3.00038,-2.47531 0,0 -3.1129,-2.51282 -3
.1504,-2.55032 0.0375,0 -6.41332,-5.10065 0,0 -6.52582,-5.17566 -6.60084,-5.17566 z m 72.45921,60.68271 1.20015,10.2388 -9.48871,-3.97551 c -0.48756,-0.22502 -0.71259,-0.7876 -0.52506,-1.23765 0.22503,-0.48756 0.75009,-0.71259 1.23765,-0.52507 l 7.98852,3.37543 -1.27516,0.97512 -1.01263,-8.62609 c -0.0375,-0.48756 0.30004,-0.97513 0.8251,-1.01263 0.52507,-0.075 0.97513,0.30004 1.05014,0.7876 z"
+ id="path3053"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.03750476px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <path
+ d="m 350.93206,285.18621 -1.35017,12.71412 -1.33142,12.67661 -1.29391,12.56409 -1.27516,12.43283 -0.61883,6.15078 -0.58133,6.09453 -0.60007,6.03826 -0.56257,5.98201 -0.54382,5.88825 -0.52507,5.85074 -0.48756,5.73823 -0.48756,5.66322 -0.45006,5.56946 -0.43131,5.47569 -0.3938,5.40069 -0.3938,5.32568 -0.35629,5.25066 -0.33754,5.17566 -0.33755,5.13815 -0.31879,5.06315 -0.58132,10.03252 -0.56257,9.86375 -0.52507,9.78874 -0.41255,7.876 1.87524,0.0938 0.41255,-7.876 0.52507,-9.76999 0.54381,-9.88251 0.60008,-10.01377 0,0.0188 0.31879,-5.08189 0.31879,-5.1194 0.3563,-5.19441 0.35629,-5.23192 0,0 0.37505,-5.32567 0.41255,-5.38194 0,0 0.43131,-5.47569 0.45005,-5.56946 0,0 0.46881,-5.64447 0.50632,-5.75698 0,0 0.52506,-5.81324 0.54382,-5.907 0.56257,-5.96325 0,0 0.58133,-6.03827 0.60007,-6.09452 0,0 0.61883,-6.15078 1.25641,-12.43283 1.31267,-12.5641 1.33142,-12.65786 1.33142,-12.71411 z m -18.63987,170.51541 4.70685,9.15116 5.66322,-8.60735 c 0.28129,-0.4313 0.15002,-1.01262 -0.28128,-
1.29391 -0.43131,-0.28129 -1.01263,-0.16877 -1.29392,0.26253 l -4.7631,7.25718 1.6127,0.0938 -3.9755,-7.72598 c -0.22503,-0.46881 -0.7876,-0.63758 -1.25641,-0.41256 -0.46881,0.24378 -0.63758,0.80636 -0.41256,1.27517 z"
+ id="path3055"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875238px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <path
+ d="m 452.32619,422.88495 c 0,-20.59012 16.68962,-37.27974 37.27973,-37.27974 20.59012,0 37.26098,16.68962 37.26098,37.27974 0,20.57136 -16.67086,37.26098 -37.26098,37.26098 -20.59011,0 -37.27973,-16.68962 -37.27973,-37.26098"
+ id="path3057"
+ style="fill:#5b9bd5;fill-opacity:1;fill-rule:evenodd;stroke:none" />
+ <path
+ d="m 452.32619,422.88495 c 0,-20.59012 16.68962,-37.27974 37.27973,-37.27974 20.59012,0 37.26098,16.68962 37.26098,37.27974 0,20.57136 -16.67086,37.26098 -37.26098,37.26098 -20.59011,0 -37.27973,-16.68962 -37.27973,-37.26098"
+ id="path3059"
+ style="fill:none;stroke:#41719c;stroke-width:1.25640953px;stroke-linecap:butt;stroke-linejoin:miter;stroke-miterlimit:4;stroke-opacity:1;stroke-dasharray:none" />
+ <text
+ x="456.80737"
+ y="419.42795"
+ id="text3061"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">CANCEL</text>
+ <text
+ x="517.71515"
+ y="419.42795"
+ id="text3063"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">-</text>
+ <text
+ x="476.30984"
+ y="437.43024"
+ id="text3065"
+ xml:space="preserve"
+ style="font-size:15.00190544px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Arial">ING</text>
+ <path
+ d="m 440.64345,443.55007 -69.85262,41.51777 0.95638,1.61271 69.85262,-41.51777 z m -65.98963,34.2606 -4.98813,9.00115 10.29506,-0.075 c 0.50631,0 0.93762,-0.43131 0.91886,-0.95637 0,-0.50632 -0.41255,-0.91887 -0.93761,-0.91887 l -8.68236,0.075 0.82511,1.38767 4.21928,-7.59471 c 0.24378,-0.45006 0.075,-1.03138 -0.37504,-1.27516 -0.45006,-0.24378 -1.01263,-0.0938 -1.27517,0.35629 z"
+ id="path3067"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875238px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <path
+ d="m 491.57492,285.20497 -1.01263,12.6016 -0.50631,6.22579 -0.46881,6.18828 -0.46881,6.05702 -0.43131,5.96326 -0.3938,5.83199 -0.37504,5.66322 -0.33755,5.47569 -0.30003,5.32568 -0.26254,5.17566 -0.24378,5.06314 -0.22503,4.96938 -0.20627,4.89437 -0.31879,7.8385 1.85648,0.075 0.31879,-7.81975 0.20628,-4.91312 0,0 0.22503,-4.95063 0.24378,-5.06314 0,0 0.28128,-5.17566 0,0 0.30004,-5.30692 0,0 0.31879,-5.4757 0,0 0.37505,-5.64446 0.41255,-5.81324 0.43131,-5.96326 0,0 0.45005,-6.07577 0.48757,-6.16953 0.48756,-6.2258 1.01263,-12.6016 z m -9.52621,80.07266 4.81936,9.09491 5.55071,-8.68235 c 0.28128,-0.43131 0.15002,-1.01263 -0.28129,-1.29392 -0.4313,-0.28128 -1.01263,-0.15002 -1.29391,0.28129 l -4.6881,7.33218 1.63146,0.0563 -4.06927,-7.66973 c -0.24378,-0.45006 -0.80635,-0.63758 -1.27516,-0.3938 -0.45006,0.24378 -0.61883,0.80635 -0.3938,1.27516 z"
+ id="path3069"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.01875238px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <path
+ d="m 609.93995,278.0228 -4.05051,8.73861 -4.05052,8.70111 -4.12552,8.55108 -2.10027,4.23804 -2.13777,4.16303 -2.13777,4.12552 -2.21278,4.05052 -2.21278,4.01301 -2.28779,3.90049 -2.3253,3.78798 -2.3628,3.75048 -2.4003,3.60046 -2.51282,3.52545 -2.51282,3.41293 -2.62534,3.30042 -2.62533,3.1879 -2.70034,3.07539 -2.73785,3.00038 -2.77535,2.92538 -2.81286,2.85036 -2.85036,2.77535 -2.88787,2.70034 -2.92537,2.66284 -5.85074,5.21316 -5.92575,5.06315 -4.53808,3.82548 -1.20015,-1.42518 4.50057,-3.82548 0,0 5.92575,-5.06315 0,0 5.85074,-5.17565 0,0 2.88787,-2.62534 0,0 2.85036,-2.70034 0,0 2.85036,-2.77535 -0.0375,0 2.81286,-2.81286 0,0 2.73784,-2.88787 0,0 2.73785,-3.00038 -0.0375,0.0375 2.70034,-3.07539 -0.0375,0 2.66283,-3.1504 -0.0375,0 2.58783,-3.26292 0,0.0375 2.51282,-3.37543 0,0 2.47531,-3.48794 -0.0375,0 2.4003,-3.60046 0,0.0375 2.3628,-3.71297 0,0 2.28779,-3.78798 0,0 2.25029,-3.86299 0,0 2.21278,-3.97551 0,0 2.17527,-4.013 0,0 2.17528,-4.12553 -0.0375,0.0375 2.13777,-4.16303 0
,0 2.10026,-4.23804 0,0.0375 4.12553,-8.58859 0,0.0375 4.05051,-8.70111 0,0 4.05052,-8.73861 z m -70.58396,107.8637 -10.12629,1.76272 3.45044,-9.67622 c 0.15002,-0.48757 0.71259,-0.7501 1.20015,-0.60008 0.48756,0.18752 0.7501,0.71259 0.56257,1.20015 l -2.92537,8.17604 -1.05013,-1.23766 8.58859,-1.46268 c 0.48756,-0.11252 0.97512,0.22503 1.08764,0.75009 0.075,0.52507 -0.26254,0.97513 -0.7876,1.08764 z"
+ id="path3071"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.03750476px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <path
+ d="m 637.39344,198.32518 2.70034,-3.56295 2.66284,-3.52545 2.70034,-3.41293 2.70034,-3.33792 2.70035,-3.18791 1.35017,-1.50019 1.38767,-1.46268 1.35018,-1.42519 1.38767,-1.35017 1.38768,-1.27516 1.38767,-1.23766 1.35018,-1.12514 1.42518,-1.05013 1.38767,-0.97513 1.38768,-0.93762 1.38768,-0.8626 1.42518,-0.82511 2.77535,-1.46269 2.81286,-1.31266 2.77535,-1.20015 2.81286,-1.12515 1.05013,-0.37504 0.63758,1.72521 -1.01263,0.41256 0,0 -2.77535,1.08763 0.0375,0 -2.77535,1.20016 0.0375,-0.0375 -2.77536,1.31267 0.0375,-0.0375 -2.73785,1.46269 0,0 -1.35017,0.7876 0,-0.0375 -1.35017,0.8626 0,0 -1.35017,0.90012 0,0 -1.35017,0.93762 0.0375,0 -1.38768,1.05013 0.0375,-0.0375 -1.35017,1.12514 0,-0.0375 -1.35017,1.20016 0,0 -1.35018,1.23765 0.0375,0 -1.38768,1.31267 0.0375,0 -1.35017,1.38768 0,0 -1.35018,1.42518 0.0375,0 -1.35017,1.50019 0,0 -2.70035,3.1504 0.0375,-0.0375 -2.70034,3.33793 0,0 -2.66284,3.41293 0,0 -2.70034,3.48794 0,0 -2.66284,3.56296 z m 34.20434,-37.99232 10.16379,1.65021
-6.45082,8.02602 c -0.33754,0.41255 -0.93762,0.48756 -1.31266,0.15002 -0.41256,-0.33755 -0.48757,-0.90012 -0.15002,-1.31267 l 5.43819,-6.78836 0.56257,1.53769 -8.55109,-1.42518 c -0.52506,-0.075 -0.86261,-0.56257 -0.7876,-1.08764 0.11252,-0.48756 0.56257,-0.8251 1.08764,-0.75009 z"
+ id="path3073"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.03750476px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ <path
+ d="m 499.67595,198.06265 12.6016,-7.53846 6.3008,-3.75047 6.2633,-3.71297 6.26329,-3.63797 6.18829,-3.56295 6.18828,-3.48794 6.15078,-3.37543 6.07577,-3.30042 6.03827,-3.11289 6.00076,-3.00039 5.88825,-2.81285 5.85074,-2.66284 5.77574,-2.47532 5.66322,-2.25028 2.81285,-1.08764 2.77536,-0.97512 2.77535,-0.93762 2.73785,-0.86261 5.40068,-1.61271 5.28817,-1.38767 5.25067,-1.20016 5.13815,-1.01262 5.10065,-0.86261 5.02564,-0.71259 4.95063,-0.56258 4.91312,-0.45005 4.87562,-0.37505 4.83811,-0.26253 4.80061,-0.22503 4.76311,-0.11252 4.7631,-0.11251 7.57597,-0.075 0.0375,1.87524 -7.57596,0.075 0,0 -4.76311,0.11251 0,0 -4.7631,0.11252 0.0375,0 -4.80061,0.22502 0.0375,0 -4.83812,0.26254 0.0375,0 -4.87562,0.33754 0.0375,0 -4.91312,0.48756 0.0375,0 -4.95063,0.56257 0,0 -4.98814,0.71259 0.0375,0 -5.06314,0.82511 0.0375,0 -5.13815,1.01263 0.0375,0 -5.21316,1.20015 0.0375,0 -5.28818,1.38768 0,-0.0375 -5.36318,1.61271 0.0375,0 -2.73785,0.86261 0,0 -2.73785,0.90011 0.0375,0 -2.77536,1.01263
0,-0.0375 -2.77535,1.05014 0,0 -5.66322,2.25028 0.0375,0 -5.73823,2.43781 0,0 -5.81324,2.66284 0.0375,0 -5.88825,2.81286 0,0 -5.96326,2.96287 0,0 -6.03827,3.1504 0.0375,-0.0375 -6.07577,3.26291 0,0 -6.11328,3.37543 0,0 -6.18828,3.48795 0,0 -6.18829,3.56295 0,0 -6.2633,3.63796 0,0 -6.26329,3.71297 0.0375,0 -6.3008,3.75048 -12.6016,7.53846 z m 167.98383,-65.67084 8.92613,5.06314 -8.81362,5.28818 c -0.45005,0.26253 -1.01262,0.15001 -1.27516,-0.30004 -0.26253,-0.45006 -0.15002,-1.01263 0.30004,-1.31267 l 0,0 7.46345,-4.46307 0,1.65021 -7.53846,-4.31304 c -0.45006,-0.26254 -0.60007,-0.82511 -0.33754,-1.27517 0.22503,-0.45005 0.8251,-0.60007 1.27516,-0.33754 z"
+ id="path3075"
+ style="fill:#000000;fill-opacity:1;fill-rule:nonzero;stroke:#000000;stroke-width:0.03750476px;stroke-linecap:butt;stroke-linejoin:round;stroke-opacity:1;stroke-dasharray:none" />
+ </g>
+</svg>
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java
index c224d64..f1edc26 100644
--- a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java
+++ b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopInputFormat.java
@@ -26,6 +26,8 @@ import java.util.ArrayList;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+
+import org.apache.flink.api.common.io.DefaultInputSplitAssigner;
import org.apache.flink.api.common.io.InputFormat;
import org.apache.flink.api.common.io.FileInputFormat.FileBaseStatistics;
import org.apache.flink.api.common.io.statistics.BaseStatistics;
@@ -37,6 +39,7 @@ import org.apache.flink.configuration.Configuration;
import org.apache.flink.core.fs.FileStatus;
import org.apache.flink.core.fs.FileSystem;
import org.apache.flink.core.fs.Path;
+import org.apache.flink.core.io.InputSplitAssigner;
import org.apache.flink.hadoopcompatibility.mapred.utils.HadoopUtils;
import org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopDummyReporter;
import org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopInputSplit;
@@ -145,8 +148,8 @@ public class HadoopInputFormat<K extends Writable, V extends Writable> implement
}
@Override
- public Class<? extends HadoopInputSplit> getInputSplitType() {
- return HadoopInputSplit.class;
+ public InputSplitAssigner getInputSplitAssigner(HadoopInputSplit[] inputSplits) {
+ return new DefaultInputSplitAssigner(inputSplits);
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/record/HadoopRecordInputFormat.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/record/HadoopRecordInputFormat.java b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/record/HadoopRecordInputFormat.java
index dcf1952..f3065e7 100644
--- a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/record/HadoopRecordInputFormat.java
+++ b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/record/HadoopRecordInputFormat.java
@@ -23,9 +23,11 @@ import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
+import org.apache.flink.api.common.io.DefaultInputSplitAssigner;
import org.apache.flink.api.common.io.InputFormat;
import org.apache.flink.api.common.io.statistics.BaseStatistics;
import org.apache.flink.configuration.Configuration;
+import org.apache.flink.core.io.InputSplitAssigner;
import org.apache.flink.hadoopcompatibility.mapred.record.datatypes.HadoopTypeConverter;
import org.apache.flink.hadoopcompatibility.mapred.utils.HadoopUtils;
import org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopDummyReporter;
@@ -84,8 +86,8 @@ public class HadoopRecordInputFormat<K, V> implements InputFormat<Record, Hadoop
}
@Override
- public Class<? extends HadoopInputSplit> getInputSplitType() {
- return HadoopInputSplit.class;
+ public InputSplitAssigner getInputSplitAssigner(HadoopInputSplit[] inputSplits) {
+ return new DefaultInputSplitAssigner(inputSplits);
}
@Override
@@ -129,7 +131,7 @@ public class HadoopRecordInputFormat<K, V> implements InputFormat<Record, Hadoop
/**
* Custom serialization methods.
- * @see http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html
+ * @see "http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html"
*/
private void writeObject(ObjectOutputStream out) throws IOException {
out.writeUTF(hadoopInputFormatName);
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/record/HadoopRecordOutputFormat.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/record/HadoopRecordOutputFormat.java b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/record/HadoopRecordOutputFormat.java
index 337b543..68fd93d 100644
--- a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/record/HadoopRecordOutputFormat.java
+++ b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/record/HadoopRecordOutputFormat.java
@@ -110,7 +110,7 @@ public class HadoopRecordOutputFormat<K,V> implements OutputFormat<Record> {
/**
* Custom serialization methods.
- * @see http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html
+ * @see "http://docs.oracle.com/javase/7/docs/api/java/io/Serializable.html"
*/
private void writeObject(ObjectOutputStream out) throws IOException {
out.writeUTF(hadoopOutputFormatName);
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/wrapper/HadoopInputSplit.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/wrapper/HadoopInputSplit.java b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/wrapper/HadoopInputSplit.java
index da46690..d132902 100644
--- a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/wrapper/HadoopInputSplit.java
+++ b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/wrapper/HadoopInputSplit.java
@@ -30,8 +30,14 @@ import org.apache.hadoop.mapred.JobConf;
public class HadoopInputSplit implements InputSplit {
+ private static final long serialVersionUID = 1L;
+
+
private transient org.apache.hadoop.mapred.InputSplit hadoopInputSplit;
+
+ @SuppressWarnings("unused")
private JobConf jobConf;
+
private int splitNumber;
private String hadoopInputSplitTypeName;
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapreduce/HadoopInputFormat.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapreduce/HadoopInputFormat.java b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapreduce/HadoopInputFormat.java
index de443c1..d9da2b4 100644
--- a/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapreduce/HadoopInputFormat.java
+++ b/flink-addons/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapreduce/HadoopInputFormat.java
@@ -27,6 +27,8 @@ import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+
+import org.apache.flink.api.common.io.DefaultInputSplitAssigner;
import org.apache.flink.api.common.io.InputFormat;
import org.apache.flink.api.common.io.FileInputFormat.FileBaseStatistics;
import org.apache.flink.api.common.io.statistics.BaseStatistics;
@@ -38,6 +40,7 @@ import org.apache.flink.configuration.Configuration;
import org.apache.flink.core.fs.FileStatus;
import org.apache.flink.core.fs.FileSystem;
import org.apache.flink.core.fs.Path;
+import org.apache.flink.core.io.InputSplitAssigner;
import org.apache.flink.hadoopcompatibility.mapreduce.utils.HadoopUtils;
import org.apache.flink.hadoopcompatibility.mapreduce.wrapper.HadoopInputSplit;
import org.apache.flink.types.TypeInformation;
@@ -166,8 +169,8 @@ public class HadoopInputFormat<K extends Writable, V extends Writable> implement
}
@Override
- public Class<? extends HadoopInputSplit> getInputSplitType() {
- return HadoopInputSplit.class;
+ public InputSplitAssigner getInputSplitAssigner(HadoopInputSplit[] inputSplits) {
+ return new DefaultInputSplitAssigner(inputSplits);
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java b/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
index fdf3c6c..63362f8 100644
--- a/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
+++ b/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
@@ -29,8 +29,10 @@ import org.apache.flink.addons.hbase.common.HBaseKey;
import org.apache.flink.addons.hbase.common.HBaseResult;
import org.apache.flink.addons.hbase.common.HBaseUtil;
import org.apache.flink.api.common.io.InputFormat;
+import org.apache.flink.api.common.io.LocatableInputSplitAssigner;
import org.apache.flink.api.common.io.statistics.BaseStatistics;
import org.apache.flink.configuration.Configuration;
+import org.apache.flink.core.io.InputSplitAssigner;
import org.apache.flink.types.Record;
import org.apache.flink.util.OperatingSystem;
import org.apache.hadoop.fs.Path;
@@ -73,7 +75,7 @@ public class TableInputFormat implements InputFormat<Record, TableInputSplit> {
/**
* Base-64 encoded scanner. All other SCAN_ confs are ignored if this is specified.
- * See {@link TableMapReduceUtil#convertScanToString(Scan)} for more details.
+ * See TableMapReduceUtil.convertScanToString(Scan) for more details.
*/
public static final String SCAN = "hbase.scan";
@@ -120,7 +122,7 @@ public class TableInputFormat implements InputFormat<Record, TableInputSplit> {
* Read the configuration and creates a {@link Scan} object.
*
* @param parameters
- * @return
+ * @return The scanner
*/
protected Scan createScanner(Configuration parameters) {
Scan scan = null;
@@ -380,15 +382,12 @@ public class TableInputFormat implements InputFormat<Record, TableInputSplit> {
return true;
}
-
@Override
- public Class<TableInputSplit> getInputSplitType() {
-
- return TableInputSplit.class;
+ public InputSplitAssigner getInputSplitAssigner(TableInputSplit[] inputSplits) {
+ return new LocatableInputSplitAssigner(inputSplits);
}
-
- public void setTable(HTable table)
- {
+
+ public void setTable(HTable table) {
this.table = table;
}
@@ -396,8 +395,7 @@ public class TableInputFormat implements InputFormat<Record, TableInputSplit> {
return table;
}
- public void setScan(Scan scan)
- {
+ public void setScan(Scan scan) {
this.scan = scan;
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputSplit.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputSplit.java b/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputSplit.java
index a77402d..c984667 100644
--- a/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputSplit.java
+++ b/flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputSplit.java
@@ -31,6 +31,8 @@ import org.apache.flink.core.memory.DataOutputView;
*/
public class TableInputSplit extends LocatableInputSplit {
+ private static final long serialVersionUID = 1L;
+
/**
* The name of the table to retrieve data from
*/
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-addons/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java b/flink-addons/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
index b17f658..fc384f8 100644
--- a/flink-addons/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
+++ b/flink-addons/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
@@ -28,12 +28,15 @@ import java.sql.Statement;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+
+import org.apache.flink.api.common.io.DefaultInputSplitAssigner;
import org.apache.flink.api.common.io.InputFormat;
import org.apache.flink.api.common.io.statistics.BaseStatistics;
import org.apache.flink.api.java.tuple.Tuple;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.core.io.GenericInputSplit;
import org.apache.flink.core.io.InputSplit;
+import org.apache.flink.core.io.InputSplitAssigner;
import org.apache.flink.types.NullValue;
/**
@@ -47,7 +50,6 @@ import org.apache.flink.types.NullValue;
public class JDBCInputFormat<OUT extends Tuple> implements InputFormat<OUT, InputSplit> {
private static final long serialVersionUID = 1L;
- @SuppressWarnings("unused")
private static final Logger LOG = LoggerFactory.getLogger(JDBCInputFormat.class);
private String username;
@@ -184,8 +186,6 @@ public class JDBCInputFormat<OUT extends Tuple> implements InputFormat<OUT, Inpu
/**
* Enters data value from the current resultSet into a Record.
*
- * @param pos Tuple position to be set.
- * @param type SQL type of the resultSet value.
* @param reuse Target Record.
*/
private void addValue(OUT reuse) throws SQLException {
@@ -289,9 +289,10 @@ public class JDBCInputFormat<OUT extends Tuple> implements InputFormat<OUT, Inpu
}
@Override
- public Class<? extends InputSplit> getInputSplitType() {
- return GenericInputSplit.class;
+ public InputSplitAssigner getInputSplitAssigner(InputSplit[] inputSplits) {
+ return new DefaultInputSplitAssigner(inputSplits);
}
+
/**
* A builder used to set parameters to the output format's configuration in a fluent way.
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
----------------------------------------------------------------------
diff --git a/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java b/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
index d15b0d0..d95b808 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java
@@ -541,7 +541,7 @@ public class CliFrontend {
if (running && rje.getJobStatus().equals(JobStatus.RUNNING)) {
runningJobs.add(rje);
}
- if (scheduled && rje.getJobStatus().equals(JobStatus.SCHEDULED)) {
+ if (scheduled && rje.getJobStatus().equals(JobStatus.CREATED)) {
scheduledJobs.add(rje);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-clients/src/test/java/org/apache/flink/client/CliFrontendListCancelTest.java
----------------------------------------------------------------------
diff --git a/flink-clients/src/test/java/org/apache/flink/client/CliFrontendListCancelTest.java b/flink-clients/src/test/java/org/apache/flink/client/CliFrontendListCancelTest.java
index f335745..593916f 100644
--- a/flink-clients/src/test/java/org/apache/flink/client/CliFrontendListCancelTest.java
+++ b/flink-clients/src/test/java/org/apache/flink/client/CliFrontendListCancelTest.java
@@ -35,7 +35,6 @@ import org.apache.flink.runtime.event.job.RecentJobEvent;
import org.apache.flink.runtime.jobgraph.JobGraph;
import org.apache.flink.runtime.jobgraph.JobID;
import org.apache.flink.runtime.managementgraph.ManagementGraph;
-import org.apache.flink.runtime.managementgraph.ManagementVertexID;
import org.apache.flink.runtime.protocols.ExtendedManagementProtocol;
import org.apache.flink.runtime.types.IntegerRecord;
import org.junit.Assert;
@@ -190,16 +189,6 @@ public class CliFrontendListCancelTest {
}
@Override
- public void killTask(JobID jobID, ManagementVertexID id) throws IOException {
- throw new UnsupportedOperationException();
- }
-
- @Override
- public void logBufferUtilization(JobID jobID) throws IOException {
- throw new UnsupportedOperationException();
- }
-
- @Override
public int getAvailableSlots() {
return 1;
}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-compiler/src/main/java/org/apache/flink/compiler/plantranslate/NepheleJobGraphGenerator.java
----------------------------------------------------------------------
diff --git a/flink-compiler/src/main/java/org/apache/flink/compiler/plantranslate/NepheleJobGraphGenerator.java b/flink-compiler/src/main/java/org/apache/flink/compiler/plantranslate/NepheleJobGraphGenerator.java
index cb912de..ad6bb70 100644
--- a/flink-compiler/src/main/java/org/apache/flink/compiler/plantranslate/NepheleJobGraphGenerator.java
+++ b/flink-compiler/src/main/java/org/apache/flink/compiler/plantranslate/NepheleJobGraphGenerator.java
@@ -66,12 +66,8 @@ import org.apache.flink.runtime.iterative.task.IterationTailPactTask;
import org.apache.flink.runtime.jobgraph.AbstractJobOutputVertex;
import org.apache.flink.runtime.jobgraph.AbstractJobVertex;
import org.apache.flink.runtime.jobgraph.DistributionPattern;
-import org.apache.flink.runtime.jobgraph.InputFormatInputVertex;
import org.apache.flink.runtime.jobgraph.JobGraph;
import org.apache.flink.runtime.jobgraph.JobGraphDefinitionException;
-import org.apache.flink.runtime.jobgraph.JobTaskVertex;
-import org.apache.flink.runtime.jobgraph.OutputFormatOutputVertex;
-import org.apache.flink.runtime.jobgraph.SimpleOutputVertex;
import org.apache.flink.runtime.operators.CoGroupDriver;
import org.apache.flink.runtime.operators.CoGroupWithSolutionSetFirstDriver;
import org.apache.flink.runtime.operators.CoGroupWithSolutionSetSecondDriver;
@@ -809,8 +805,8 @@ public class NepheleJobGraphGenerator implements Visitor<PlanNode> {
return vertex;
}
- private AbstractJobVertex createDataSourceVertex(SourcePlanNode node) throws CompilerException {
- final InputFormatInputVertex vertex = new InputFormatInputVertex(node.getNodeName(), this.jobGraph);
+ private InputFormatVertex createDataSourceVertex(SourcePlanNode node) throws CompilerException {
+ final InputFormatVertex vertex = new InputFormatVertex(node.getNodeName(), this.jobGraph);
final TaskConfig config = new TaskConfig(vertex.getConfiguration());
vertex.setInvokableClass(DataSourceTask.class);
@@ -824,7 +820,7 @@ public class NepheleJobGraphGenerator implements Visitor<PlanNode> {
}
private AbstractJobOutputVertex createDataSinkVertex(SinkPlanNode node) throws CompilerException {
- final OutputFormatOutputVertex vertex = new OutputFormatOutputVertex(node.getNodeName(), this.jobGraph);
+ final OutputFormatVertex vertex = new OutputFormatVertex(node.getNodeName(), this.jobGraph);
final TaskConfig config = new TaskConfig(vertex.getConfiguration());
vertex.setInvokableClass(DataSinkTask.class);
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-core/src/main/java/org/apache/flink/api/common/io/DefaultInputSplitAssigner.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/io/DefaultInputSplitAssigner.java b/flink-core/src/main/java/org/apache/flink/api/common/io/DefaultInputSplitAssigner.java
new file mode 100644
index 0000000..10746af
--- /dev/null
+++ b/flink-core/src/main/java/org/apache/flink/api/common/io/DefaultInputSplitAssigner.java
@@ -0,0 +1,75 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.api.common.io;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.List;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.apache.flink.core.io.InputSplit;
+import org.apache.flink.core.io.InputSplitAssigner;
+
+/**
+ * This is the default implementation of the {@link InputSplitAssigner} interface. The default input split assigner
+ * simply returns all input splits of an input vertex in the order they were originally computed.
+ */
+public class DefaultInputSplitAssigner implements InputSplitAssigner {
+
+ /** The logging object used to report information and errors. */
+ private static final Logger LOG = LoggerFactory.getLogger(DefaultInputSplitAssigner.class);
+
+ /** The list of all splits */
+ private final List<InputSplit> splits = new ArrayList<InputSplit>();
+
+
+ public DefaultInputSplitAssigner(InputSplit[] splits) {
+ Collections.addAll(this.splits, splits);
+ }
+
+ public DefaultInputSplitAssigner(Collection<? extends InputSplit> splits) {
+ this.splits.addAll(splits);
+ }
+
+
+ @Override
+ public InputSplit getNextInputSplit(String host) {
+ InputSplit next = null;
+
+ // keep the synchronized part short
+ synchronized (this.splits) {
+ if (this.splits.size() > 0) {
+ next = this.splits.remove(this.splits.size() - 1);
+ }
+ }
+
+ if (LOG.isDebugEnabled()) {
+ if (next == null) {
+ LOG.debug("Assigning split " + next + " to " + host);
+ } else {
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("No more input splits available");
+ }
+ }
+ }
+ return next;
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java b/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
index ccd6c51..522e69a 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
@@ -16,7 +16,6 @@
* limitations under the License.
*/
-
package org.apache.flink.api.common.io;
import java.io.IOException;
@@ -44,7 +43,7 @@ import org.apache.flink.core.fs.Path;
* The base class for {@link InputFormat}s that read from files. For specific input types the
* <tt>nextRecord()</tt> and <tt>reachedEnd()</tt> methods need to be implemented.
* Additionally, one may override {@link #open(FileInputSplit)} and {@link #close()} to
- * change the lifecycle behavior.
+ * change the life cycle behavior.
* <p>
* After the {@link #open(FileInputSplit)} method completed, the file input data is available
* from the {@link #stream} field.
@@ -358,8 +357,8 @@ public abstract class FileInputFormat<OT> implements InputFormat<OT, FileInputSp
}
@Override
- public Class<FileInputSplit> getInputSplitType() {
- return FileInputSplit.class;
+ public LocatableInputSplitAssigner getInputSplitAssigner(FileInputSplit[] splits) {
+ return new LocatableInputSplitAssigner(splits);
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/b32e77a2/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java b/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
index 4331116..008493d 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
@@ -16,7 +16,6 @@
* limitations under the License.
*/
-
package org.apache.flink.api.common.io;
import java.io.IOException;