- 20 11月, 2015 2 次提交
-
-
由 Ufuk Celebi 提交于
Removes the possibility to go from FAILED state back to RESTARTING. This was only used in a test case. It was a breaking the terminal state semantics of the FAILED state.
-
由 Robert Metzger 提交于
This commit is also changing how we build the "flink-shaded-hadoop" artifact. In the past, we were including all Hadoop dependencies into a fat jar, without relocating all of them. Maven was not able to see Hadoop's dependencies and classes ended up in the classpath multiple times. With this change, only shaded Hadoop dependencies are included into the jar. The shade plugin will also remove only the shaded dependencies from the pom file.
-
- 19 11月, 2015 21 次提交
-
-
由 Stephan Ewen 提交于
-
由 tedyu 提交于
This closes #1353
-
由 Stephan Ewen 提交于
This also adds to the deprecated classes pointers forward to the designated classes. This closes #1380
-
由 tedyu 提交于
[FLINK-3005] [core] Bump commons-collections version to fix object deserialization remote command execution vulnerability This closes #1381
-
由 vasia 提交于
This closes #1371
-
由 Maximilian Michels 提交于
-
由 Maximilian Michels 提交于
-
由 smarthi 提交于
FLINK-3041: Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal' This closes #1379.
-
由 zentol 提交于
This closes #1376
-
由 Ufuk Celebi 提交于
-
由 Aljoscha Krettek 提交于
This fixes a problem that would occur if a Trigger registers a new processing-time trigger in the onProcessingTime method. The problem is that onProcessingTime() is called while traversing the set of active triggers. If onProcessingTime() tries to register a new processing-time trigger this leads to a concurrent modification exception.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 chengxiang li 提交于
-
由 Maximilian Michels 提交于
- replace deprecated tool which prevents uploading of snapshot binaries - remove Java 6 jar check
-
由 zentol 提交于
This closes #1266
-
由 Piotr Godek 提交于
This closes #1346
-
由 Maximilian Michels 提交于
In addition to the REST-compliant "DELETE /jobs/<jobid>", allows cancellation also via a special GET request of the form "GET /jobs/<jobid>/yarn-cancel". That enables us to cancel jobs from the web frontend on YARN while keeping a REST-compliant DELETE alternative. This closes #1344.
-
由 zentol 提交于
This closes #1373
-
由 zentol 提交于
This closes #2233.
-
由 Martin Liesenberg 提交于
This closes #1367.
-
- 18 11月, 2015 4 次提交
-
-
由 Till Rohrmann 提交于
The Graph.fromCsvReader in Gelly's Scala API returns a wrongly typed Graph instance because the implementation contains code paths with return types which are not compatible. This lead to a bad user experience. This commit fixes this. However, it also introduces a slightly different behaviour and is thus API breaking. Before there were parameters hasEdgeValues and readVertices which controlled whether edge values and vertices shall be read. This is now implicitly controlled by the types of the vertex and edge value. If the type is NullValue for the edge values then the edge value won't be read from the given csv file. If the vertex value type is NullValue, then all vertices will have a value of a NullValue instance. If the pathVertices is not specified and the vertex value type is unequal to NullValue, then the vertexValueInitializer is used for the initialization. Add documentation for Gelly's Scala API method Graph.fromCsvReader This closes #1370.
-
由 smarthi 提交于
This closes #1356.
-
由 zentol 提交于
This closes #1352.
-
由 Robert Metzger 提交于
-
- 17 11月, 2015 8 次提交
-
-
由 Robert Metzger 提交于
[FLINK-2967] Increase timeout for LOCAL_HOST address detection strategy, give the local host address a higher priority This closes #1391
-
由 andralungu 提交于
This closes #1348
-
由 zentol 提交于
This closes #1359
-
由 jaoki 提交于
This closes #1358 JobExecutionVertices should be ExecutionJobVertices? I found it while I have been drawing a Flink local execution diagram. It is still a half way but let me know if you have any feedback. https://docs.google.com/drawings/d/1lZg8LkhAlI5lMc2EGCPlYArBmv7cCj-By-phuG6rGE8/edit
-
由 smarthi 提交于
[hotfix] [utils] Change the parameter 'numSample' in DataSetUtils.sampleWithSize() to 'numSamples', remove redundant Java 6 code This closes #1362
-
由 Stephan Ewen 提交于
This closes #1365
-
由 Aljoscha Krettek 提交于
Previously the internal currentWatermark would be updated even if the value returned from getCurrentWatermark was lower than the current watermark. This can lead to problems with chaining because the watermark is directly forwarded without going through the watermark logic that ensures correct behaviour (monotonically increasing). This adds a test that verifies that the timestamp extractor does not emit decreasing watermarks.
-
由 smarthi 提交于
-
- 16 11月, 2015 2 次提交
-
-
由 Niels Basjes 提交于
This closes #1342
-
由 smarthi 提交于
This closes #1357
-
- 14 11月, 2015 1 次提交
-
-
由 Maximilian Michels 提交于
-
- 13 11月, 2015 2 次提交
-
-
由 Sachin Goel 提交于
This disallows the following types of interactive programs in detached mode: 1. More than one call to execute 2. Accessing job execution results like accumulators, net runtime, etc. This effectively disables eager execution functions such as count, print, collect, etc. too
-
由 Sachin Goel 提交于
This closes #1214.
-