- 10 4月, 2015 17 次提交
-
-
由 Robert Metzger 提交于
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
Consolidate class loading tests into one cluster execution to validate repeated different class loaders
-
由 Stephan Ewen 提交于
- Accumulators rely consistently on java serialization - Fix accumulator transport to support custom classes - Fix collect() accumulator to use correct class loader
-
由 Stephan Ewen 提交于
[runtime] Accumulators are reported through the RuntimeEnvironment, not directly sent as an actor message
-
由 Ufuk Celebi 提交于
This commit adds a figure giving an overview of Flink's stack. Users can click on components to go to the respective component docs. This closes #585.
-
由 Ufuk Celebi 提交于
This closes #563.
-
由 Robert Metzger 提交于
[quickstarts] Set different default groupid for quickstarts to avoid exclusion by the assembly plugin
-
由 vasia 提交于
-
由 andralungu 提交于
This closes #544
-
由 vasia 提交于
This closes #547
-
由 vasia 提交于
-
由 Till Rohrmann 提交于
[FLINK-1847] [Scala API] Changes the return type of Scala API's collect method to Seq[T] and adds parentheses to collect and count methods. - Updates existing test cases using Scala API's collect/count method. This closes #583
-
由 Alexander Alexandrov 提交于
[FLINK-1845] [runtime] Fixup ReusingKeyGroupedIterator value iterators in NonReusingSortMergeCoGroupIterator. This closes #559
-
由 Stephan Ewen 提交于
-
- 09 4月, 2015 3 次提交
-
-
由 Robert Metzger 提交于
This closes #555.
-
由 Aljoscha Krettek 提交于
-
由 Gyula Fora 提交于
-
- 08 4月, 2015 17 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Ufuk Celebi 提交于
-
由 mbalassi 提交于
-
由 Gyula Fora 提交于
Closes #577
-
由 Aljoscha Krettek 提交于
-
由 mbalassi 提交于
Instead of a checking against a concrete output it only determines well-formedness.
-
由 Till Rohrmann 提交于
-
由 mbalassi 提交于
The job is now commutative and associative and thus testable in parallel.
-
由 Fabian Hueske 提交于
This closes #578
-
由 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.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
- 07 4月, 2015 3 次提交
-
-
由 Ufuk Celebi 提交于
Running package locally resulted in the following error: [ERROR] Failed to execute goal ... on project flink-streaming-connectors: Compilation failure [ERROR] .../KafkaTopicUtils.java:[57,25] cannot access org.apache.zookeeper.Watcher [ERROR] class file for org.apache.zookeeper.Watcher not found Mysteriously, this does not happen on Travis.
-
由 mbalassi 提交于
Checkpointing currently does not support this special case
-
由 mbalassi 提交于
This closes #519
-