- 25 7月, 2016 1 次提交
-
-
由 zentol 提交于
Prevents the CheckpointCommitter from failing a job, if either commitCheckpoint() or isCheckpointCommitter() failed. Instead, we will try again on the next notify(). This closes #2287
-
- 23 7月, 2016 2 次提交
-
-
由 Greg Hogan 提交于
The user must now specify the ID type as "integer" or "string" when reading a graph from a CSV file. This closes #2250
-
由 Greg Hogan 提交于
This closes #2248
-
- 22 7月, 2016 2 次提交
-
-
由 Ufuk Celebi 提交于
Suspended jobs were leading to shutdown of the checkpoint coordinator and hence removal of checkpoint state. For standalone recovery mode this is OK as no state can be recovered anyways (unchanged in this PR). For HA though this lead to removal of checkpoint state, which we actually want to keep for recovery. We have the following behaviour now: -----------+------------+------------------- | Standalone | High Availability -----------+------------+------------------- SUSPENDED | Discard | Keep -----------+------------+------------------- FINISHED/ | Discard | Discard FAILED/ | | CANCELED | | -----------+------------+------------------- This closes #2276.
-
由 Till Rohrmann 提交于
This closes #2284.
-
- 21 7月, 2016 7 次提交
-
-
由 Aljoscha Krettek 提交于
This closes #2279
-
由 Till Rohrmann 提交于
This PR adds a JM metric which shows the time it took to restart a job. The time is measured between entering the JobStatus.RESTARTING and reaching the JobStatus.RUNNING state. During this time, the restarting time is continuously updated. The metric only shows the time for the last restart attempt. The metric is published in the job metric group under the name of "restartingTime". This closes #2271.
-
由 Aljoscha Krettek 提交于
-
由 Ufuk Celebi 提交于
-
由 Stefan Richter 提交于
-
由 Stefan Richter 提交于
-
由 Aljoscha Krettek 提交于
-
- 20 7月, 2016 6 次提交
-
-
由 kl0u 提交于
Parameters of some input formats that was only possible to be set through the Configuration object now have setter methods that allow the user to do so. Values set by the setters cannot be reset by the configuration object.
-
由 zentol 提交于
This closes #2238.
-
由 Jark Wu 提交于
This closes #2120.
-
由 kl0u 提交于
Integrated PR comments This closes #2259.
-
由 Stefan Richter 提交于
This closes #2249
-
由 Maximilian Michels 提交于
- change CLI message upon cluster retrieval - save JobExecutionResult for interactive executions - only print Collection size in accumulator results - remove unused helper method This closes #2264
-
- 19 7月, 2016 4 次提交
-
-
由 twalthr 提交于
This closes #2221.
-
由 卫乐 提交于
This closes #2182.
-
由 gallenvara 提交于
This closes #2078.
-
由 David Moravek 提交于
This closes #2268
-
- 18 7月, 2016 15 次提交
-
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
-
由 Ufuk Celebi 提交于
Disposing savepoints via the JobManager fails for state handles or descriptors, which contain user classes (for example custom folding state or RocksDB handles). With this change, the user can provide the job JAR when disposing a savepoint in order to use the user code class loader of that job. The JAR is optional, hence not breaking the CLI API. This closes #2083.
-
由 Ismaël Mejía 提交于
-
由 Ismaël Mejía 提交于
-
由 Ismaël Mejía 提交于
-
由 Ismaël Mejía 提交于
-
由 Ismaël Mejía 提交于
This solves issues when a host has multiple IPs
-
由 Aljoscha Krettek 提交于
Before, ValueState.update() was not called after changing the NFA or the priority queue in CEP operators. This means that the operators don't work with state backends such as RocksDB that strictly require that update() be called when state changes. This changes the operators to always call update() and also introduces a test that verifies the changes.
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
Before, these were using StreamRecordSerializer, which does not serialize timestamps. Now it uses MultiplexingStreamRecordSerializer. This also extends the tests in CEPOperatorTest to test that timestamps are correctly checkpointed/restored.
-
由 Aljoscha Krettek 提交于
NFA is Serializable and has readObject()/writeObject() methods. In AbstractKeyedCEPPatternOperator a KryoSerializer was used as the TypeSerializer for the ValueState that holds NFA instances. Kryo does not call readObject()/writeObject() therefore the state of the NFA was invalid after deserialization. This change adds a new TypeSerializer for NFA that uses Java Serialization. In the long run it will be better to get rid of the readObject()/writeObject() methods and instead efficiently serialize using a specialized TypeSerializer.
-
由 Aljoscha Krettek 提交于
-
- 15 7月, 2016 3 次提交
-
-
由 Stephan Ewen 提交于
State handles are cancelable, to make sure long running checkpoint restore operations do finish early on cancallation, even if the code does not properly react to interrupts. This is especially important since HDFS client code is so buggy that it deadlocks when interrupted without closing.
-
由 Stephan Ewen 提交于
-
由 Robert Metzger 提交于
This commit also adds monitoring for the current and committed offset This closes #2236
-