提交 · 0ce757fd72446a60d5b79ea970dfb545406e3544 · doujutun3207 / flink

10 8月, 2015 5 次提交
- S
  
  [hotfix] Fix repository language statistics by adjusting .gitattributes · 0ce757fd
  由 Stephan Ewen 提交于 8月 10, 2015
  
  0ce757fd
- S
  
  [FLINK-1177] [docs] Mark HDFS setup instructions as option in cluster setup docs · 27044b41
  由 Stephan Ewen 提交于 8月 06, 2015
  
  27044b41
- S
  
  [FLINK-2453] [docs] Update README and setup docs to reflect requirement for Java 7+ · e503ebcf
  由 Stephan Ewen 提交于 8月 06, 2015
  
  e503ebcf
- S
  
  [FLINK-705] [license] Add license reference for TPC-H sample data in tests. · 368d7aee
  由 Stephan Ewen 提交于 8月 06, 2015
  
  368d7aee
- M
  [FLINK-2387] add streaming test case for live accumulators · fdebcb83
  由 Maximilian Michels 提交于 7月 21, 2015
```
This closes #926.
```
  fdebcb83
07 8月, 2015 5 次提交
- S
  [FLINK-2243] [storm-compat] Demonstrating finite Storm spout functionality on exclamation example · dba2946f
  由 szape 提交于 6月 19, 2015
```
-minor renaming
-improving JavaDocs

Closes #853
```
  dba2946f
- S
  
  [FLINK-2243] [storm-compat] Added finite spout functionality to Storm compatibility layer · 6d9eeb55
  由 szape 提交于 6月 19, 2015
  
  6d9eeb55
- V
  [FLINK-2452] [Gelly] adds a playcount threshold to the MusicProfiles example · f1dd914d
  由 vasia 提交于 7月 31, 2015
```
This closes #968
```
  f1dd914d
- S
  
  [hotfix] Fix TEZ task contect to reflect updated interface. · 441ebf1f
  由 Stephan Ewen 提交于 8月 06, 2015
  
  441ebf1f
- S
  [FLINK-2240] [runtime] Pass flag to configure use of bloom filters through runtime configuration. · 0b73b438
  由 Stephan Ewen 提交于 8月 06, 2015
```
Also make sure that most tests run with enabled bloom filters, to increase test coverage.
```
  0b73b438
06 8月, 2015 6 次提交
- C
  
  [FLINK-2240] Add bloom filter to filter probe records during hash join. · 61dcae39
  由 chengxiang li 提交于 7月 03, 2015
  
  61dcae39
- S
  
  [FLINK-2492] [runtime] Rename former 'match' classes to 'join' to reflect consistent naming scheme. · 685086a3
  由 Stephan Ewen 提交于 8月 06, 2015
  
  685086a3
- S
  
  [hotfix] Increase timeout for YARN tests to 180 seconds to prevent occasional CI failures. · a5b84b2b
  由 Stephan Ewen 提交于 8月 06, 2015
  
  a5b84b2b
- S
  
  [FLINK-2453] [pom] Move Java source and target version to 1.7 · 5a788ec2
  由 Stephan Ewen 提交于 8月 06, 2015
  
  5a788ec2
- S
  
  [FLINK-2454] [buikd] Update Travis to drop JDK6 for tests · 249fa2bc
  由 Stephan Ewen 提交于 8月 06, 2015
  
  249fa2bc
- S
  [FLINK-1916] [FLINK-2361] [runtime] Fix EOFException and entry loss in CompactingHashTable · 925ac1f7
  由 Stephan Ewen 提交于 8月 03, 2015
```
Also a lot of code cleanups in CompactingHashTable
```
  925ac1f7
05 8月, 2015 14 次提交
- S
  
  [hotfix] Remove unused and outdated HashFunctionCollisionBenchmark · 5226f0b4
  由 Stephan Ewen 提交于 8月 04, 2015
  
  5226f0b4
- S
  
  [FLINK-2464] [tests] Make buffer spilling test robust to Java 6. · 3e73496c
  由 Stephan Ewen 提交于 8月 05, 2015
  
  3e73496c
- S
  
  [FLINK-2484] [streaming] BarrierBuffer releases temp files properly. · d738430c
  由 Stephan Ewen 提交于 8月 04, 2015
  
  d738430c
- R
  [FLINK-1680] Remove Tachyon test and rename Maven module to "flink-fs-tests" · fb7e6342
  由 Robert Metzger 提交于 8月 04, 2015
```
This closes #987
```
  fb7e6342
- M
  [FLINK-2467] Example WordCountStorm.jar is not packaged correctly · 0aa6f0cb
  由 mjsax 提交于 8月 03, 2015
```
 - fixed assembly xml file

This closes #974
```
  0aa6f0cb
- Z
  [FLINK-1882] Removed RemotedCollector classes · 100e8c5f
  由 zentol 提交于 7月 25, 2015
```
This closes #985
```
  100e8c5f
- T
  [FLINK-2447] [java api] TypeExtractor returns wrong type info when a Tuple has... · 5546a1ef
  由 twalthr 提交于 8月 04, 2015
```
[FLINK-2447] [java api] TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type

This closes #986
```
  5546a1ef
- R
  [FLINK-2105] Implement Sort-Merge Outer Join algorithm · 941ac6df
  由 r-pogalz 提交于 8月 03, 2015
```
This closes #907
```
  941ac6df
- R
  
  [FLINK-2105] [tests] Move duplicate utility classes to testutil package · df9f4819
  由 r-pogalz 提交于 8月 03, 2015
  
  df9f4819
- J
  
  [FLINK-2105] Add support for sorted but sparse test data generation · db0b0087
  由 Johann Kovacs 提交于 7月 10, 2015
  
  db0b0087
- J
  
  [FLINK-2105] Extract abstract superclass, interface from MergeMatchIterators, KeyGroupedIterators · 0dc6849a
  由 Johann Kovacs 提交于 7月 10, 2015
  
  0dc6849a
- F
  [FLINK-2442] [fix] FieldPositionKeys support Pojo fields · 30761572
  由 Fabian Hueske 提交于 7月 30, 2015
```
This closes #963
```
  30761572
- E
  [FLINK-2205] Fix confusing entries in JobManager WebUI JobConfig section. · b2d8c40a
  由 Enrique Bautista 提交于 7月 21, 2015
```
Default display for 'Number of execution retries' is now 'deactivated'
and for 'Job parallelism' is 'auto', as suggested in JIRA.

This closes #927
```
  b2d8c40a
- Z
  [FLINK-2005] Remove Record API from jdbc module · 06b37bf5
  由 zentol 提交于 8月 04, 2015
```
This closes #982
```
  06b37bf5
04 8月, 2015 10 次提交
- F
  Remove unwanted check null of input1 in ConnectedDataStream · d570d078
  由 ffbin 提交于 8月 04, 2015
```
Closes #978
```
  d570d078
- T
  
  [docs] Fixes broken link in FlinkML docs · 77b74715
  由 Till Rohrmann 提交于 8月 04, 2015
  
  77b74715
- B
  [FLINK-2422] [web client] Added explicit link in case browser is not redirecting properly · bb5e61d2
  由 buzdin 提交于 7月 28, 2015
```
This closes #946
```
  bb5e61d2
- M
  [FLINK-2095][docs] Added missing screenshots to webclient documentation · 2859f59f
  由 mjsax 提交于 8月 03, 2015
```
This closes #976
```
  2859f59f
- F
  [FLINK-2456] [hbase] Add a repository ID for hadoop2 in flink-hbase module · 949ff8da
  由 ffbin 提交于 8月 01, 2015
```
This closes #969
```
  949ff8da
- S
  [FLINK-2464] [tests] Change log level of BufferSpillerTest to "info" to let... · d0cd1c7d
  由 Stephan Ewen 提交于 8月 03, 2015
```
[FLINK-2464] [tests] Change log level of BufferSpillerTest to "info" to let statements occur in CI logs.
```
  d0cd1c7d
- S
  [FLINK-2473] [core] Add a timeout to akka actorsystem shutdown. · 2cff89ed
  由 Stephan Ewen 提交于 8月 03, 2015
```
This works around a bug in akka where the "awaitTermination()" call freezes indefinitely.
```
  2cff89ed
- S
  [FLINK-2425] [runtime] Cleanup code for forwarding config and hostname into... · c3ef61de
  由 Stephan Ewen 提交于 8月 03, 2015
```
[FLINK-2425] [runtime] Cleanup code for forwarding config and hostname into TaskManager's RuntimeEnvironment
```
  c3ef61de
- S
  
  [FLINK-2426] [core] Cleanup/improve unmodifiable configuration. · 5bf2197b
  由 Stephan Ewen 提交于 8月 03, 2015
  
  5bf2197b
- S
  [FLINK-2425] [FLINK-2426] [runtime] Add an unmodifiable config and provide... · 8eb9cbf8
  由 Sachin Goel 提交于 7月 29, 2015
```
[FLINK-2425] [FLINK-2426] [runtime] Add an unmodifiable config and provide access to task manager configuration and hostname inside RuntimeEnvironment
```
  8eb9cbf8

doujutun3207 / flink 与 Fork 源项目一致

doujutun3207 / flink
与 Fork 源项目一致