- 26 5月, 2017 6 次提交
-
-
由 Till Rohrmann 提交于
Before the YarnClusterClient decided when to delete the Yarn application files. This is problematic because the client does not know whether a Yarn application is being restarted or terminated. Due to this the files where always deleted. This prevents Yarn from restarting a failed ApplicationMaster, effectively thwarting Flink's HA capabilities. The PR changes the behaviour such that the YarnJobManager deletes the Yarn files if it receives a StopCluster message. That way, we can be sure that the yarn files are deleted only iff the cluster is intended to be shut down.
-
由 Tzu-Li (Gordon) Tai 提交于
This closes #3987.
-
由 zentol 提交于
This closes #3989.
-
由 Dawid Wysakowicz 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
- 25 5月, 2017 10 次提交
-
-
由 zentol 提交于
This closes #3842.
-
由 zentol 提交于
This closes #2633.
-
由 zentol 提交于
This closes #3956.
-
由 zentol 提交于
This closes #3988.
-
由 zentol 提交于
This closes #3985.
-
由 Nico Kruber 提交于
This test was disabled in Dec 2015 due to its instability and never made it back again. It is probably outdated and may not even work anymore due to the changes since then. Since it doesn't make sense to keep it in its current form, let's remove it. This closes #3980.
-
由 Greg Hogan 提交于
This closes #3986.
-
由 Greg Hogan 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
- 24 5月, 2017 12 次提交
-
-
由 lingjinjiang 提交于
-
由 zentol 提交于
This closes #3948.
-
由 Nico Kruber 提交于
This closes #3966.
-
由 Nico Kruber 提交于
-> use a JUnit '@Rule' that does the cleanup This closes #3962.
-
由 Nico Kruber 提交于
-> use a JUnit '@Rule' that does the cleanup
-
由 zentol 提交于
This closes #3970.
-
由 zentol 提交于
This closes #3969.
-
由 zentol 提交于
This closes #3968.
-
由 sunjincheng121 提交于
This closes #3958.
-
由 Stefan Richter 提交于
-
由 Stefan Richter 提交于
[FLINK-6685] Prevent that SafetyNetCloseableRegistry is closed prematurely in Task::triggerCheckpointBarrier
-
由 Till Rohrmann 提交于
When recovering state from a ZooKeeperStateHandleStore it can happen that the deserialization fails, because one tries to recover state from an old Flink version which is not compatible. In this case we should output a better error message such that the user can easily spot the problem. This closes #3972.
-
- 23 5月, 2017 12 次提交
-
-
由 David Anderson 提交于
This closes #3964.
-
由 huafengw 提交于
This closes #3898.
-
由 Till Rohrmann 提交于
Let first the snapshotting thread completely finish before checking the test condition. This prevents race conditions between the checkpointing thread and the verification.
-
由 kkloudas 提交于
This is to leverage the fact that RocksDB already returns the keys sorted. So now elements, instead of being stores in a PQ and all of them being deserialized and serialized at each incoming element, the are stored in a MapState with the key being the timestamp and the value, a List of elements that refer to the same timestamp.
-
由 Till Rohrmann 提交于
The lifecycle of savepoints is not managed by the CheckpointCoordinator and fully in the hand of the user. Therefore, the CheckpointCoordinator cannot rely on them when trying to recover from failures. E.g. a user moving a savepoint shortly before a failure could completely break Flink's recovery mechanism because Flink cannot skip failed checkpoints when recovering. Therefore, until Flink is able to skip failed checkpoints when recovering, we should not add savepoints to the CompletedCheckpointStore which is used to retrieve checkpoint for recovery. The distinction of a savepoint is done on the basis of the CheckpointProperties (CheckpointProperties.STANDARD_SAVEPOINT). This closes #3965.
-
由 Greg Hogan 提交于
Updates / reverts the import order by sections: - org.apache.flink.* - all other imports - javax.* - java.* - static imports Adds EmptyLineSeparator to enforce an extra newline (not enforced between field or local variable declarations). This closes #3941
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
This closes #3947.
-