Repository: beam Updated Branches: refs/heads/master 7d22dbcab -> ca678d887
Fix DataflowRunner message about uploaded vs cached files Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/05a006a1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/05a006a1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/05a006a1 Branch: refs/heads/master Commit: 05a006a14de2bc42d31321f34a49706ff3814962 Parents: 7d22dbc Author: Dan Halperin <dhalp...@google.com> Authored: Wed Mar 1 17:17:10 2017 -0800 Committer: Thomas Groh <tg...@google.com> Committed: Wed Mar 1 17:33:46 2017 -0800 ---------------------------------------------------------------------- .../java/org/apache/beam/runners/dataflow/util/PackageUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/05a006a1/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PackageUtil.java ---------------------------------------------------------------------- diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PackageUtil.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PackageUtil.java index 685d48c..482ddd9 100644 --- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PackageUtil.java +++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PackageUtil.java @@ -330,7 +330,7 @@ class PackageUtil { LOG.info( "Staging files complete: {} files cached, {} files newly uploaded", - numUploaded.get(), numCached.get()); + numCached.get(), numUploaded.get()); return packages; }
