- 21 11月, 2015 3 次提交
-
-
由 Robert Metzger 提交于
-
由 Jun Aoki 提交于
This is not to fulfill what FLINK-3009 is originally asking, but I'm piggybacking to contribute a docker environment with jekyll so that users won't have to deal with environment versions. Author: Jun Aoki <jaoki@apache.org> Author: jaoki <jaoki@apache.org> Closes #1363 from jaoki/dockerized-docgen and squashes the following commits: 7bf3661 [Jun Aoki] Added apache label 36869e7 [jaoki] [FLINK-3009] Add dockerized jekyll environment
-
由 Chiwan Park 提交于
This closes #1310.
-
- 20 11月, 2015 12 次提交
-
-
由 smarthi 提交于
This closes #1389.
-
由 Robert Metzger 提交于
This closes #1341
-
由 Till Rohrmann 提交于
When a candidate for a bulk iteration is instantiated, then the optimizer creates candidates for the step function. It is then checked that there exists a candidate solution for the step function whose properties met the properties of the input to the bulk iteration. Sometimes it is necessary to add a no-op plan node to the end of the step function to generate the correct properties. These new candidates have to be added to the final set of the accepted candidates. This commit adds that these new candidates are properly added to the set of accepted candidates. Fix test and add new iteration tests Add predecessor operator and dynamic path information to no op operator in bulk iterations This closes #1388.
-
由 Till Rohrmann 提交于
Streaming sources were directly assigned their InputFormat in the StreamingJobGraphGenerator. As a consequence, the input formats were directly serialized/deserialized by Akka when the JobGraph was sent to the JobManager. In cases where the user provided a custom input format or an input format with custom types, this could lead to a ClassDefNotFoundException, because the system class loader instead of the user code class loader is used by Akka for the deserialization. The problem was fixed by wrapping the InputFormat into a UserCodeObjectWrapper which is shipped ot the JobManager via the JobVertex's configuration. By instantiating stream sources as InputFormatVertices, the corresponding InputFormat is retrieved from the Configuration in the initializeOnMaster method call. This closes #1368.
-
由 Stephan Ewen 提交于
-
由 qingmeng.wyh 提交于
This closes #1345
-
由 Ufuk Celebi 提交于
This closes #1369
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 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 提交于
-