| 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... |
|
|
|
|
|
|
|
[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... |
|
|
|
|
|
|
|
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... |
|
|
|
|
|
|
|
[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... |
|
|
|
|
|
|
|
[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... |
|
|
|
|
|
|
|
[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... |
|
|
|
|
|
|
|
[expand - 2 more]
[collapse]
-
[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... |
|
|
|
|
| |
|
[Discuss] Upgrade story for Beam's execution engines - Beam - [mail # dev]
|
| ...On Thu, Sep 13, 2018 at 9:49 AM Maximilian Michels wrote:> Thank you for your comments. Let me try to summarize what has been> discussed so far:>> 1. The Beam LTS version w... |
|
|
|
|
|
[Discuss] Upgrade story for Beam's execution engines - Beam - [mail # dev]
|
| ...The main problem here is that users are forced to upgrade infrastructure toobtain new features in Beam, even when those features actually don'trequire such changes. As an example, another up... |
|
|
|
|
|
|
|
[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)>>>> ... |
|
|
|
|
|
|
|
[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.... |
|
|
|
|
|
|
|
[expand - 2 more]
[collapse]
-
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... |
|
|
|
|
|
|
|
|