[
https://issues.apache.org/jira/browse/BEAM-186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15233186#comment-15233186
]
ASF GitHub Bot commented on BEAM-186:
-------------------------------------
GitHub user herohde opened a pull request:
https://github.com/apache/incubator-beam/pull/156
[BEAM-186] Fix pubsub injector for streaming examples
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/herohde/incubator-beam master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-beam/pull/156.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #156
----
commit 2ea17a4f1959838ef955abbe27b4b914f4169006
Author: Henning Rohde <hero...@google.com>
Date: 2016-04-09T00:06:18Z
[BEAM-186] Fix pubsub injector for streaming examples
----
> The streaming WindowedWordCount example is broken on Dataflow
> -------------------------------------------------------------
>
> Key: BEAM-186
> URL: https://issues.apache.org/jira/browse/BEAM-186
> Project: Beam
> Issue Type: Bug
> Components: examples-java
> Reporter: Henning Korsholm Rohde
> Assignee: Henning Korsholm Rohde
> Priority: Minor
>
> The streaming version of WindowedWordCount example is broken on Dataflow.
> Currently, the injector cannot start up and emits the error
> "java.lang.RuntimeException: DataflowWorkerHarness should not be used for
> non-streaming pipelines". This in turn means that no messages are generated
> for the streaming pipeline to process.
> The problem is that DataflowExampleUtils uses a batch workflow to inject
> Google PubSub messages. This workflow reuses the real options and modifies
> them to be batch, setting isStreaming to false etc. However, with versioned
> containers, the option for workerHarnessContainerImage must now also be
> changed to use the batch image.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
