- 19 11月, 2015 5 次提交
-
-
由 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 6 次提交
-
-
由 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.
-
由 zentol 提交于
This closes #962
-
由 Ufuk Celebi 提交于
-
由 Jun Aoki 提交于
This closes #1325
-
由 zentol 提交于
This closes #1257
-
- 12 11月, 2015 1 次提交
-
-
由 Maximilian Michels 提交于
In addition to dd66e61e, removes the left-over source files.
-
- 11 11月, 2015 7 次提交
-
-
由 tedyu 提交于
[FLINK-2826] [runtime] Fix race condition and locking in BroadcastVariableMaterialization#decrementReferenceInternal This closes #1339
-
由 Stephan Ewen 提交于
For jobs that do not switch to FAILED, but rather RESTARTING, this now prints the error cause as well. Also minor improvement to exception printing in CliFrontend.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
Previously, this fiel pointed to the different versions of the LICENSE and NOTICE files (source version, bin version). Since we dropped the convenience binary distribution LICENSE and NOTICE files and only ship the source release related ones, this is no longer necessary.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
- 10 11月, 2015 6 次提交
-
-
由 Sachin Goel 提交于
This closes #1327.
-
由 Robert Metzger 提交于
This closes #1343
-
由 Robert Metzger 提交于
-
由 Robert Metzger 提交于
[FLINK-2987] Remove jersey-core and jersey-client dependency exclusion to make Flink on Hadoop 2.6.0+ work This closes #1340
-
由 Robert Metzger 提交于
-
由 Sachin Goel 提交于
This closes #1334.
-