| clear
query|
facets|
time |
Search criteria: .
Results from 1 to 10 from
976 (0.0s).
|
|
|
Loading phrases to help you
refine your search...
|
|
[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... |
|
|
|
|
|
|
|
[BEAM-5197] Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest -
Beam - [issue]
|
| ...java.lang.NullPointerException at org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService$1.compare(TestProcessingTimeService.java:52) at org.apache.flink.streaming.runtime.tasks.... |
|
|
|
|
|
|
|
Spotless broken on master -
Beam - [mail # dev]
|
| ...The equivalent target to run should be "check" - seehttps://beam.apache.org/contribute/On Wed, Sep 12, 2018 at 6:01 AM Ismaël Mejía wrote:> Thanks for pointing this out Andrew (and ... |
|
|
|
|
|
|
|
[DISCUSS] Unification of Hadoop related IO modules -
Beam - [mail # dev]
|
| ...I'm in favor of a combination of 2) and 3): New module"hadoop-mapreduce-format" ("hadoop-format" does not sufficiently qualifywhat it is). Turn existing " hadoop-input-format" into a proxy f... |
|
|
|
|
|
|
|
|