Fixup usage of canonical name with name since canonical name != name for inner classes.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/96d39314 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/96d39314 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/96d39314 Branch: refs/heads/python-sdk Commit: 96d393147c365d0911a091d0b3600fef621709f4 Parents: ef1a858 Author: Luke Cwik <lc...@google.com> Authored: Tue Dec 20 11:47:42 2016 -0800 Committer: Luke Cwik <lc...@google.com> Committed: Tue Dec 20 13:04:24 2016 -0800 ---------------------------------------------------------------------- .../org/apache/beam/runners/dataflow/DataflowRunnerTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/96d39314/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java ---------------------------------------------------------------------- diff --git a/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java index b29c4cd..21d575a 100644 --- a/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java +++ b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java @@ -267,7 +267,7 @@ public class DataflowRunnerTest { "--runner=DataflowRunner", "--tempLocation=/tmp/not/a/gs/path", "--project=test-project", - "--credentialFactoryClass=" + NoopCredentialFactory.class.getCanonicalName(), + "--credentialFactoryClass=" + NoopCredentialFactory.class.getName(), }; try { @@ -286,7 +286,7 @@ public class DataflowRunnerTest { "--runner=DataflowRunner", "--tempLocation=gs://does/not/exist", "--project=test-project", - "--credentialFactoryClass=" + NoopCredentialFactory.class.getCanonicalName(), + "--credentialFactoryClass=" + NoopCredentialFactory.class.getName(), }; try { @@ -306,8 +306,8 @@ public class DataflowRunnerTest { "--runner=DataflowRunner", "--tempLocation=/tmp/testing", "--project=test-project", - "--credentialFactoryClass=" + NoopCredentialFactory.class.getCanonicalName(), - "--pathValidatorClass=" + NoopPathValidator.class.getCanonicalName(), + "--credentialFactoryClass=" + NoopCredentialFactory.class.getName(), + "--pathValidatorClass=" + NoopPathValidator.class.getName(), }; // Should not crash, because gcpTempLocation should get set from tempLocation TestPipeline.fromOptions(PipelineOptionsFactory.fromArgs(args).create());