- 07 5月, 2017 9 次提交
-
-
由 shuai.xus 提交于
-
由 shuai.xus 提交于
[FLINK-5867] [flip-1] Support restarting only pipelined sub-regions of the ExecutionGraph on task failure
-
由 David Anderson 提交于
This closes #3822
-
由 David Anderson 提交于
This closes #3828
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
This preserves old config keys as deprecated keys where the key was already present in an earlier release. This also re-arranges config options to form logical sections in the file and harmonized JavaDoc formatting style.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
'lshift(...)' is not defined by default in some commonly used awk versions.
-
由 Nico Kruber 提交于
Instead, allow the configuration with the following three new (more flexible) parameters: * "taskmanager.network.memory.fraction": fraction of JVM memory to use for network buffers (default: 0.1) * "taskmanager.network.memory.min": minimum memory size for network buffers (default: 64 MB) * "taskmanager.network.memory.max": maximum memory size for network buffers (default: 1 GB) This closes #3721
-
- 06 5月, 2017 11 次提交
-
-
由 Nico Kruber 提交于
-
由 Nico Kruber 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Fabian Hueske 提交于
-
由 Hequn Cheng 提交于
-
由 Hequn Cheng 提交于
-
由 hequn.chq 提交于
-
由 shaoxuan-wang 提交于
This closes #3646.
-
由 Fabian Hueske 提交于
-
由 twalthr 提交于
This closes #3808.
-
- 05 5月, 2017 13 次提交
-
-
由 kl0u 提交于
-
由 Stefan Richter 提交于
-
由 xiaogang.sxg 提交于
-
由 Dawid Wysakowicz 提交于
NOT patterns are not yet supported when an OPTIONAL pattern directly preceeds a NOT. In these cases, an exception is thrown that proposes an alternative (but not the most efficient) way to support these patterns.
-
由 Till Rohrmann 提交于
-
由 Vijay Srinivasaraghavan 提交于
This closes #3692.
-
由 Till Rohrmann 提交于
-
由 Haohui Mai 提交于
This closes #3648.
-
由 Till Rohrmann 提交于
The AsyncWaitOperator should not only react to orderly completed StreamElementQueueEntries but also to those completed with a user exception or those which timed out. This PR fixes the problem by calling the onComplete function passed to StreamElementQueueEntry#onComplete also in the exceptional case. This closes #3814.
-
由 Till Rohrmann 提交于
Remove client less factory methods from ZooKeeperUtils Introduce default job id This closes #3781.
-
由 Till Rohrmann 提交于
This PR introduces a standalone high availability services implementation which can be used in a distributed setting with no HA guarantees. Additionally, it introduces a common base class which is also used by the EmbeddedHaServices. This base class instantiates the standalone variants of the checkpoint recovery factory, submitted job graphs store, running jobs registry and blob store. The StandaloneHaServices are instantiated with a fixed address for the Job- and ResourceManager. This address and the HighAvailability.DEFAULT_LEADER_ID is returned by the corresponding LeaderRetrievalServices when being started. This closes #3622.
-
由 Haohui Mai 提交于
This closes #3604
-
由 shaoxuan-wang 提交于
This closes #3809.
-
- 04 5月, 2017 7 次提交
-
-
由 kl0u 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
由 Zohar Mizrahi 提交于
This closes #3741.
-
由 shijinkui 提交于
This closes #3769.
-
由 WangTaoTheTonic 提交于
This closes #3709.
-