[
https://issues.apache.org/jira/browse/BEAM-7074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817350#comment-16817350
]
Thomas Weise commented on BEAM-7074:
------------------------------------
{code:java}
File "/Users/tweise/src/beam/sdks/python/apache_beam/pipeline.py", line 419, in
run
return self.runner.run_pipeline(self, self._options)
File
"/Users/tweise/src/beam/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
line 276, in run_pipeline
default_environment=self._default_environment))
File
"/Users/tweise/src/beam/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
line 280, in run_via_runner_api
return self.run_stages(*self.create_stages(pipeline_proto))
File
"/Users/tweise/src/beam/sdks/python/apache_beam/runners/portability/fn_api_runner.py",
line 339, in create_stages
use_state_iterables=self._use_state_iterables)
File
"/Users/tweise/src/beam/sdks/python/apache_beam/runners/portability/fn_api_runner_transforms.py",
line 471, in create_and_optimize_stages
stages = list(phase(stages, pipeline_context))
File
"/Users/tweise/src/beam/sdks/python/apache_beam/runners/portability/fn_api_runner_transforms.py",
line 1133, in inject_timer_pcollections
raise NotImplementedError('Timers and side inputs.')
NotImplementedError: Timers and side inputs.{code}
> FnApiRunner fails to wire multiple timer specs in single pardo
> --------------------------------------------------------------
>
> Key: BEAM-7074
> URL: https://issues.apache.org/jira/browse/BEAM-7074
> Project: Beam
> Issue Type: Bug
> Components: sdk-py-harness
> Affects Versions: 2.11.0
> Reporter: Thomas Weise
> Priority: Major
>
> Multiple timer specs in a ParDo yield "NotImplementedError: Timers and side
> inputs."
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
