[
https://issues.apache.org/jira/browse/BEAM-6676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16768918#comment-16768918
]
Thomas Weise commented on BEAM-6676:
------------------------------------
Here is the error:
{code:java}
timer.set(1000)
File
"/Users/tweise/python-ve/beam/lib/python2.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 324, in set
dict(timestamp=timestamp.Timestamp.of(ts)))))
File
"/Users/tweise/python-ve/beam/lib/python2.7/site-packages/apache_beam/runners/worker/operations.py",
line 88, in receive
self.update_counters_start(windowed_value)
File
"/Users/tweise/python-ve/beam/lib/python2.7/site-packages/apache_beam/runners/worker/operations.py",
line 94, in update_counters_start
self.opcounter.update_from(windowed_value)
File
"/Users/tweise/python-ve/beam/lib/python2.7/site-packages/apache_beam/runners/worker/opcounters.py",
line 195, in update_from
self.do_sample(windowed_value)
File
"/Users/tweise/python-ve/beam/lib/python2.7/site-packages/apache_beam/runners/worker/opcounters.py",
line 213, in do_sample
self.coder_impl.get_estimated_size_and_observables(windowed_value))
File
"/Users/tweise/python-ve/beam/lib/python2.7/site-packages/apache_beam/coders/coder_impl.py",
line 996, in get_estimated_size_and_observables
self._windows_coder.estimate_size(value.windows, nested=True))
File
"/Users/tweise/python-ve/beam/lib/python2.7/site-packages/apache_beam/coders/coder_impl.py",
line 780, in estimate_size
self.get_estimated_size_and_observables(value))
File
"/Users/tweise/python-ve/beam/lib/python2.7/site-packages/apache_beam/coders/coder_impl.py",
line 795, in get_estimated_size_and_observables
elem, nested=True))
File
"/Users/tweise/python-ve/beam/lib/python2.7/site-packages/apache_beam/coders/coder_impl.py",
line 134, in get_estimated_size_and_observables
return self.estimate_size(value, nested), []
File
"/Users/tweise/python-ve/beam/lib/python2.7/site-packages/apache_beam/coders/coder_impl.py",
line 477, in estimate_size
span_millis = (typed_value._end_micros // 1000
AttributeError: 'GlobalWindow' object has no attribute '_end_micros' [while
running 'statefulCount']
at
org.apache.beam.runners.fnexecution.control.FnApiControlClient$ResponseStreamObserver.onNext(FnApiControlClient.java:157)
at
org.apache.beam.runners.fnexecution.control.FnApiControlClient$ResponseStreamObserver.onNext(FnApiControlClient.java:140)
at
org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onMessage(ServerCalls.java:248)
at
org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener.onMessage(ForwardingServerCallListener.java:33)
at
org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Contexts$ContextualizedServerCallListener.onMessage(Contexts.java:76)
at
org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:263)
at
org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:683)
at
org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at
org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
... 1 more{code}
> Python timers only working with GlobalWindow
> --------------------------------------------
>
> Key: BEAM-6676
> URL: https://issues.apache.org/jira/browse/BEAM-6676
> Project: Beam
> Issue Type: Bug
> Components: sdk-py-harness
> Affects Versions: 2.10.0
> Reporter: Thomas Weise
> Priority: Major
>
> Setting a timer with the Py SDK fails with fixed window (portable runner).
> Test case attached.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
