This is an automated email from the ASF dual-hosted git repository.
heejong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 3bca2e3 [BEAM-12454] Add original filesToStage to final pipeline
options
new acc0f76 Merge pull request #14946 from kw2542/BEAM-12454
3bca2e3 is described below
commit 3bca2e3d78d902beb1c4b91c526409acd017640d
Author: Ke Wu <[email protected]>
AuthorDate: Thu Jun 3 18:02:56 2021 -0700
[BEAM-12454] Add original filesToStage to final pipeline options
Add original filesToStage to final pipeline options to fix the bug that
the originally specified files to be staged is not properly staged by
artifact staging service.
---
.../main/java/org/apache/beam/runners/portability/PortableRunner.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableRunner.java
b/runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableRunner.java
index 0bed22d..8611487 100644
---
a/runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableRunner.java
+++
b/runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableRunner.java
@@ -138,6 +138,8 @@ public class PortableRunner extends
PipelineRunner<PipelineResult> {
+ "Defaulting to files from the classpath: {}",
classpathResources.size());
filesToStageBuilder.addAll(classpathResources);
+ } else {
+ filesToStageBuilder.addAll(stagingFiles);
}
// TODO(heejong): remove jar_packages experimental flag when
cross-language dependency
