[BEAM-186] Fix pubsub injector for streaming examples · walternate/DataflowJavaSDK@08d8bb8 · GitHub

1. walternate
2. DataflowJavaSDK

Repository navigation

• Code
• Pull requests
• Actions
• Projects
• Security and quality
• Insights

Commit 08d8bb8

Browse filesBrowse the repository at this point in the historyBrowse files

herohde

committed

[BEAM-186] Fix pubsub injector for streaming examples

1 parent 44cde1d commit 08d8bb8
Copy full SHA for 08d8bb8

1 file changed

+2Lines changed: 2 additions & 0 deletions

File tree

Expand file treeCollapse file tree

Open diff view settings

Filter options

• examples/src/main/java/com/google/cloud/dataflow/examples/common
  • DataflowExampleUtils.java

Expand file treeCollapse file tree

Open diff view settings

Collapse file

‎examples/src/main/java/com/google/cloud/dataflow/examples/common/DataflowExampleUtils.java‎

Copy file name to clipboardExpand all lines: examples/src/main/java/com/google/cloud/dataflow/examples/common/DataflowExampleUtils.java

+2Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
@@ -354,6 +354,8 @@ public void runInjectorPipeline(PTransform<? super PBegin, PCollection<String>>
354	354	copiedOptions.setServiceAccountKeyfile(options.getServiceAccountKeyfile());
355	355	}
356	356	copiedOptions.setStreaming(false);
	357	+ copiedOptions.setWorkerHarnessContainerImage(
	358	+ DataflowPipelineRunner.BATCH_WORKER_HARNESS_CONTAINER_IMAGE);
357	359	copiedOptions.setNumWorkers(options.as(DataflowExampleOptions.class).getInjectorNumWorkers());
358	360	copiedOptions.setJobName(options.getJobName() + "-injector");
359	361	Pipeline injectorPipeline = Pipeline.create(copiedOptions);

0 commit comments

Comments

0 (0)