- 23 5月, 2016 1 次提交
-
-
由 zentol 提交于
-
- 21 5月, 2016 2 次提交
-
-
由 Greg Hogan 提交于
The Jaccard Index measures the similarity between vertex neighborhoods. Scores range from 0.0 (no shared neighbors) to 1.0 (all neighbors are shared). This closes #1980
-
由 Greg Hogan 提交于
This closes #2006
-
- 20 5月, 2016 6 次提交
-
-
由 Maximilian Michels 提交于
As of 70978f56, the Yarn tests were not executed anymore. They were moved to the test directory but there was still a Maven configuration in place to change the test directory location. This closes #2012
-
由 Maximilian Michels 提交于
Failures during execution of the integration tests with the Maven Failsafe plugin were silently ignored on Travis with Maven version 3.2.5. The problem is that failures are not passed on correctly from the 'integration-test' phase (where failures are recorded and tolerated) to the 'verify' phase. The cause of the error is most likely SUREFIRE-1127. An exception in the 'integration-test' is sometimes not flushed back to disk where it is evaluated in the 'verify' phase. Bumping the version of the Failsafe plugin from 2.18.1 to 2.19.1 fixes the issue but introduces classpath related problems. We don't have to rely on Failsafe for running integration tests. Surefire offers the same feature set we use from the Failsafe plugin. - replace Failsafe with Surefire - update to latest Surefire version - get rid of duplicate property declaration This closes #2003
-
由 Maximilian Michels 提交于
- increase timeout for task managers to be registered - don't fail if leader retrieval service has not been started yet This closes #2009
-
由 Maximilian Michels 提交于
This fixes a NullPointerException that would occur if the host name could not be resolved. This closes #2008
-
由 Stephan Ewen 提交于
[FLINK-3933] [streaming API] Add AbstractDeserializationSchema that handles produced type extraction. The AbstractDeserializationSchema creates the produced type information automatically from the generic parameters. This closes #2010
-
由 Henry Saputra 提交于
Very simple fix for typo on comment in the task manager.sh file. From `JobManager` to `TaskManager`. Author: Henry Saputra <hsaputra@apache.org> Closes #2001 from hsaputra/simple_text_fix_taskmanager and squashes the following commits: 861cbb4 [Henry Saputra] Simple fix of typo from JobManager to TaskManager in taskmanager.sh file.
-
- 19 5月, 2016 7 次提交
-
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
-
由 Flavio Pompermaier 提交于
- New Input- and OutputFormat use Row instead of Tuple types to support null values. - JdbcInputFormat supports parallel input due to PreparedStatement and binding values for parameters. This closes #1941
-
由 Mark Reddy 提交于
This closes #2000
-
由 Yijie Shen 提交于
This closes #2004
-
- 18 5月, 2016 10 次提交
-
-
由 Robert Metzger 提交于
-
由 Gordon Tai 提交于
This closes #1911
-
由 Yijie Shen 提交于
This closes #1958
-
由 Joshi 提交于
This closes #1994
-
由 Mark Reddy 提交于
This closes #1992
-
由 Steve Cosenza 提交于
Build a test-jar including KafkaTestEnvironmentImpl so that Flink users can write end to end integration tests of their Flink jobs. This closes #1972
-
由 kl0u 提交于
This closes #1977
-
由 markreddy 提交于
- move Job to BatchJob - comment out transformers for the mainClass setting - tidy up SocketTextStreamWordCount - update docs This closes #1982
-
由 Joshi 提交于
This closes #1995
-
由 Joshi 提交于
This closes #1998
-
- 17 5月, 2016 1 次提交
-
-
由 Greg Hogan 提交于
The local clustering coefficient measures the connectedness of each vertex's neighborhood. Scores range from 0.0 (no edges between neighbors) to 1.0 (neighborhood is a clique). This closes #1896
-
- 14 5月, 2016 3 次提交
-
-
This closes #1991
-
由 Maximilian Michels 提交于
Addition to bbd02d24. The java.lang.Date type shouldn't be an automatically Kryo registered anymore.
-
由 Maximilian Michels 提交于
Depending on the context, the ExecutionConfig's type fields may either be deserialized using a custom class loader or the default class loader. It may be explicitly serialized for the Task or shipped inside the PojoSerializer where it is serialized or directly passed in local mode. An ExecutionConfig may be reused and thus its fields can't be set to null after it has been shipped once. The entire ExecutionConfig is now serialized upon setting it on the JobGraph. It is not passed through the JobGraph's constructor but set explicitly on the JobGraph. If no ExecutionConfig has been set, the default is used. Unlike before, no code may modify the ExecutionConfig after it has been set on the JobGraph. This closes #1913
-
- 13 5月, 2016 4 次提交
-
-
由 eastcirclek 提交于
This closes #1945
-
由 Ken Krugler 提交于
This closes #1965
-
由 Tatu Saloranta 提交于
This closes #1952
-
由 twalthr 提交于
This closes #1959
-
- 11 5月, 2016 4 次提交
-
-
由 markreddy 提交于
This closes #1971
-
由 twalthr 提交于
This closes #1974
-
由 Fabian Hueske 提交于
-
由 zentol 提交于
- replaced CharSets with StandardCharsets - added checkElementIndex to Flink Preconditions - replaced Guava Preconditions with Flink Preconditions - removed single usages Ints.max() and Joiner() This closes #1938
-
- 10 5月, 2016 2 次提交
-
-
由 Tony Baines 提交于
* ubuntu trusty->xenial * jdk 7u51 -> 8u91 * flink 0.10.1 -> 1.0.2 This closes #1969
-
由 Maximilian Michels 提交于
This cloes #1976
-