clear query| facets| time Search criteria: .   Results from 1 to 10 from 601 (0.0s).
Loading phrases to help you
refine your search...
Python question about save_main_session - Beam - [mail # dev]
...I suggest re-writing the test to avoid save_main_session.On Fri, Aug 23, 2019 at 11:57 AM Udi Meiri  wrote:> Hi,> I'm trying to get pytest with the xdist plugin to run Beam tests....
   Author: Robert Bradshaw , 2019-08-23, 22:17
[expand - 3 more] - Brief of interactive Beam - Beam - [mail # dev]
...Cool, sounds like we're getting closer to the same page. Some more repliesbelow.On Fri, Aug 23, 2019 at 1:47 PM Ning Kang  wrote:> Thanks for the feedback, Robert! I think I got your...
   Author: Robert Bradshaw , 2019-08-23, 22:09
[BEAM-5428] Implement cross-bundle state caching. - Beam - [issue]
...Tech spec: https://docs.google.com/document/d/1BOozW0bzBuz4oHJEuZNDOHdzaV5Y56ix58Ozrqm2jFg/edit#heading=h.7ghoih5aig5mRelevant document: https://docs.google.com/document/d/1ltVqIW0XxUXI6grp1...
http://issues.apache.org/jira/browse/BEAM-5428    Author: Robert Bradshaw , 2019-08-23, 16:33
[BEAM-7722] Simplify running of Beam Python on Flink - Beam - [issue]
...Currently this requires building and running several processes. We should be able to automate most of this away. ...
http://issues.apache.org/jira/browse/BEAM-7722    Author: Robert Bradshaw , 2019-08-21, 21:59
Try to understand "Output timestamps must be no earlier than the timestamp of the current input" - Beam - [mail # user]
...The original timestamps are probably being assigned in thewatchForNewFiles transform, which is also setting the watermark:https://github.com/apache/beam/blob/release-2.15.0/sdks/java/core/sr...
   Author: Robert Bradshaw , 2019-08-20, 20:53
[expand - 2 more] - [PROPOSAL] An initial Schema API in Python - Beam - [mail # dev]
...On Mon, Aug 19, 2019 at 5:44 PM Ahmet Altay  wrote:>>>> On Mon, Aug 19, 2019 at 9:56 AM Brian Hulette  wrote:>>>>>>>> On Fri, Aug 16, 2019 at 5:...
   Author: Robert Bradshaw , 2019-08-20, 20:41
[expand - 3 more] - (mini-doc) Beam (Flink) portable job templates - Beam - [mail # dev]
...The point of expansion services is to run at pipeline constructiontime so that the caller can build on top of the outputs. E.g. we'rehoping to expose Beam's SQL transforms to other languages...
   Author: Robert Bradshaw , 2019-08-20, 20:24
[BEAM-3713] Consider moving away from nose to nose2 or pytest. - Beam - [issue]
...Per https://nose.readthedocs.io/en/latest/ , nose is in maintenance mode....
http://issues.apache.org/jira/browse/BEAM-3713    Author: Robert Bradshaw , 2019-08-17, 00:22
[BEAM-7840] Create MapTuple and FlatMapTuple to ease migration to Python 3. - Beam - [issue]
...These are like Map and FlatMap but expand out tuple input elements acrossseveral arguments. This will be useful as tuple argument unpacking has beenremoved in Python 3. Instead of having to ...
http://issues.apache.org/jira/browse/BEAM-7840    Author: Robert Bradshaw , 2019-08-14, 00:00
[BEAM-5468] Allow runner to set worker log level in Python SDK harness. - Beam - [issue]
http://issues.apache.org/jira/browse/BEAM-5468    Author: Robert Bradshaw , 2019-08-12, 12:14