- 27 5月, 2015 2 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
- 26 5月, 2015 2 次提交
-
-
由 Stephan Ewen 提交于
- Streaming mode sets the memory manager to lazy memory allocation to ensure heap is not blocked by batch memory manager
-
由 Robert Metzger 提交于
This closes #689
-
- 22 5月, 2015 2 次提交
-
-
由 Till Rohrmann 提交于
Adds pipeline comments Adds pipeline IT case
-
由 Till Rohrmann 提交于
[FLINK-2050] [ml] Introduces new pipelining mechanism using implicit classes to wrap the algorithm logic This closes #704.
-
- 20 5月, 2015 1 次提交
-
-
由 Gyula Fora 提交于
Closes #676
-
- 29 4月, 2015 2 次提交
-
-
由 elbehery 提交于
This closes #621 This closes #442
-
由 Till Rohrmann 提交于
[FLINK-1923] [runtime] Replaces asynchronous logging with synchronous logging using grizzled-slf4j wrapper for Scala. This closes #628
-
- 21 4月, 2015 2 次提交
- 15 4月, 2015 1 次提交
-
-
由 Robert Metzger 提交于
-
- 13 4月, 2015 1 次提交
-
-
由 Aljoscha Krettek 提交于
This greatly reduces compile time while still supporting the same feature set.
-
- 08 4月, 2015 4 次提交
-
-
由 Till Rohrmann 提交于
-
由 Fabian Hueske 提交于
This closes #575
-
由 Maximilian Michels 提交于
-
由 Stephan Ewen 提交于
[licences] Updated LICENSE and NOTICE file of the binary distribution to contain dependencies of 'flink-dist'. This means that the LICENSE and NOTICE files reflect all dependencies that we include in the binary distribution, but not those of artifacts pulled only through maven.
-
- 01 4月, 2015 1 次提交
-
-
由 Till Rohrmann 提交于
[ml] Adds breeze to flink-dist LICENSE file [ml] Optimizes sanity checks in vector/matrix accessors [ml] Fixes scala check style error with missing whitespaces before and after + [ml] Fixes DenseMatrixTest
-
- 31 3月, 2015 1 次提交
-
-
由 Robert Metzger 提交于
With this change, users can submit a Flink job to a YARN cluster without having a local client monitoring the Application Master or job. You can basically fire and forget a Flink job to YARN. For supporting this, the ApplicationMaster can now monitor the status of a job and shutdown itself once it is in a terminal state. The change also verifies that various ways of setting the parallelism on YARN are passed through the system correctly (per job, session). There was a bug in YARN container creation which made the configuration values for the heap offset useless. This change fixes this error. All mentioned features and bugs are covered by the flink-yarn-tests. This closes #542
-
- 23 3月, 2015 1 次提交
-
-
由 Maximilian Michels 提交于
* rename occurrences of degree of parallelism to parallelism * [Dd]egree[ -]of[ -]parallelism -> [pP]arallelism * (DOP|dop) -> [pP]arallelism * paraDegree -> parallelism * degree-of-parallelism -> parallelism * DEGREE_OF_PARALLELISM -> PARALLELISM
-
- 20 3月, 2015 1 次提交
-
-
由 Stephan Ewen 提交于
-
- 18 3月, 2015 1 次提交
-
-
由 Till Rohrmann 提交于
[FLINK-1697] [ml] Adds web documentation for alternating least squares. Adds web documentation for polynomial base feature mapper. [ml] Adds comments [ml] Set degree of parallelism of test suites to 2 [ml] Replaces FlatSpec tests with JUnit integration test cases in order to suppress the sysout output. [ml] Adds missing clients-test jar [docs] Sets jekyll's baseurl to http://ci.apache.org/projects/flink/flink-docs-master [ml] Replaces JBlas by java netlib to avoid license issues of included fortran libraries [ml] Adds com.github.fommil.netlib:core to license file [ml] Adds Scala docs to FlinkTools [ml] Adds comments to LabeledVector and the math package object This closes #479.
-
- 13 3月, 2015 1 次提交
-
-
由 Robert Metzger 提交于
-
- 11 3月, 2015 1 次提交
-
-
由 Robert Metzger 提交于
This closes #454
-
- 09 3月, 2015 1 次提交
-
-
由 Robert Metzger 提交于
This closes #450
-
- 05 3月, 2015 2 次提交
-
-
由 Stephan Ewen 提交于
This closes #455
-
由 Stephan Ewen 提交于
- Fix bugs with non-serializable messages - Separate parser and action logic - Clean up tests - Vastly improve logging in CLI client - Additional tests for parsing / config setup in the command line client
-
- 04 3月, 2015 1 次提交
-
-
由 Stephan Ewen 提交于
-
- 18 2月, 2015 2 次提交
-
-
由 Robert Metzger 提交于
-
由 Aljoscha Krettek 提交于
Also fix tests for JodaTime. Conflicts: flink-dist/src/main/flink-bin/LICENSE flink-java/pom.xml flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/KryoGenericTypeSerializerTest.scala flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleSerializerTest.scala
-
- 12 2月, 2015 2 次提交
-
-
由 Stephan Ewen 提交于
-
由 Max 提交于
This closes #383
-
- 07 2月, 2015 1 次提交
-
-
由 mbalassi 提交于
Also dumped the stable release version in the docs config
-
- 05 2月, 2015 1 次提交
-
-
由 Robert Metzger 提交于
-
- 04 2月, 2015 4 次提交
-
-
由 Robert Metzger 提交于
load log4j-cli.properties and do not set 'default' as default queue This closes #358
-
由 Max 提交于
-
由 Ufuk Celebi 提交于
Addresses comments here: https://github.com/apache/flink/commit/2bea79341eb0f2fafd1537b15ca212eb5792f950
-
由 Ufuk Celebi 提交于
Print a warning message if misconfigured.
-
- 03 2月, 2015 2 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Stephan Ewen 提交于
This closes #333
-