[
https://issues.apache.org/jira/browse/BEAM-186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15235322#comment-15235322
]
Henning Korsholm Rohde commented on BEAM-186:
---------------------------------------------
The example code is present in both.
> 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)
