Repository: incubator-gobblin Updated Branches: refs/heads/master 5abfb797a -> 44d870275
[GOBBLIN-605] Avoid setting the flowExecutionId twice during path finding in Multi-hop flow compilation.[] Closes #2471 from sv2000/flowExecutionId Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/44d87027 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/44d87027 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/44d87027 Branch: refs/heads/master Commit: 44d870275cdc3a917e306a63b465e1745a64e131 Parents: 5abfb79 Author: sv2000 <[email protected]> Authored: Mon Oct 8 15:13:37 2018 -0700 Committer: Hung Tran <[email protected]> Committed: Mon Oct 8 15:13:37 2018 -0700 ---------------------------------------------------------------------- .../service/modules/flowgraph/pathfinder/BFSPathFinder.java | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/44d87027/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/pathfinder/BFSPathFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/pathfinder/BFSPathFinder.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/pathfinder/BFSPathFinder.java index 02dd67b..6c95ae5 100644 --- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/pathfinder/BFSPathFinder.java +++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/pathfinder/BFSPathFinder.java @@ -75,9 +75,6 @@ public class BFSPathFinder extends AbstractPathFinder { //Initialization of auxiliary data structures used for path computation this.pathMap = new HashMap<>(); - // Generate flow execution id for this compilation - this.flowExecutionId = System.currentTimeMillis(); - //Path computation must be thread-safe to guarantee read consistency. In other words, we prevent concurrent read/write access to the // flow graph. //Base condition 1: Source Node or Dest Node is inactive; return null
