clear query| facets| time Search criteria: .   Results from 1 to 10 from 979 (0.0s).
Loading phrases to help you
refine your search...
[DISCUSS] Committer Guidelines / Hygene before merging PRs - Beam - [mail # dev]
...Wanted to bring this up as reminder as well as opportunity to discusspotential changes to our committer guide. It has been a while since lastrelated discussion and we welcomed several new co...
   Author: Thomas Weise , 2018-09-19, 16:27
[PROPOSAL] [community] A more structured approach to reviews and contributions - Flink - [mail # dev]
...Follow-up regarding the PR template that pops up when opening a PR:I think what we have now is a fairly big blob of text that jumps up a bitunexpectedly for a first time contributor and is a...
   Author: Thomas Weise , 2018-09-19, 14:02
Rethinking Timers as PCollections - Beam - [mail # dev]
...Robert,Thanks for presenting these thoughts. Your attempt to implement the timersupport in the Python runner is the first strong signal we have and it isthe right time to make changes - AFAI...
   Author: Thomas Weise , 2018-09-19, 13:27
[BEAM-5385] Flink jobserver does not honor --flink-master-url - Beam - [issue]
...It will use the external Flink cluster when specified, but only with default port number 8081, because the actual port is not in propagated in FlinkExecutionEnvironments (RestOptions.PORT se...
http://issues.apache.org/jira/browse/BEAM-5385    Author: Thomas Weise , 2018-09-18, 18:56
[FLINK-10074] Allowable number of checkpoint failures - Flink - [issue]
...For intermittent checkpoint failures it is desirable to have a mechanism to avoid restarts. If, for example, a transient S3 error prevents checkpoint completion, the next checkpoint may very...
http://issues.apache.org/jira/browse/FLINK-10074    Author: Thomas Weise , 2018-09-18, 14:54
[BEAM-5396] Flink portable runner savepoint / upgrade support - Beam - [issue]
...The Flink runner overall and the new portable implementation specifically need to support Flink savepoints for production use. Specifically, it should be possible to upgrade a stateful porta...
http://issues.apache.org/jira/browse/BEAM-5396    Author: Thomas Weise , 2018-09-18, 04:02
[expand - 2 more] - [Discuss] Upgrade story for Beam's execution engines - Beam - [mail # user]
...It would be good to engage with the Flink community and attempt to findstable API that the runner can depend on.Thanks,ThomasOn Mon, Sep 17, 2018 at 6:31 AM Maximilian Michels  wrote:&g...
   Author: Thomas Weise , 2018-09-18, 03:07
[VOTE] Donating the Dataflow Worker code to Apache Beam - Beam - [mail # dev]
...+1 (binding)On Mon, Sep 17, 2018 at 3:27 PM Ankur Goenka  wrote:> +1>> On Sun, Sep 16, 2018 at 3:20 AM Maximilian Michels  wrote:>>> +1 (binding)>>>> ...
   Author: Thomas Weise , 2018-09-17, 22:28
[BEAM-5397] Flink portable runner GRPC cleanup failure after user class loader was removed - Beam - [issue]
...Looks like another attempt to perform cleanup after close....
http://issues.apache.org/jira/browse/BEAM-5397    Author: Thomas Weise , 2018-09-17, 11:59
[expand - 2 more] - Discussion: Scheduling across runner and SDKHarness in Portability framework - Beam - [mail # dev]
...That's actually how the Flink runner already works - bundle processingstarts when elements are available (see FlinkExecutableStageFunction forbatch mode).But we still have the possibility of...
   Author: Thomas Weise , 2018-09-14, 13:01