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...    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...    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...    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....    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
[BEAM-5197] Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest - Beam - [issue] at org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService$ at org.apache.flink.streaming.runtime.tasks....    Author: Thomas Weise , 2018-09-12, 17:48
Spotless broken on master - Beam - [mail # dev]
...The equivalent target to run should be "check" - see Wed, Sep 12, 2018 at 6:01 AM Ismaël Mejía  wrote:> Thanks for pointing this out Andrew (and ...
   Author: Thomas Weise , 2018-09-12, 10:35
[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...
   Author: Thomas Weise , 2018-09-11, 14:08