提交 · 26ce47f52e7d533f069b18d13e2e01aa9e56a483 · doujutun3207 / flink

17 4月, 2015 6 次提交
- F
  
  [FLINK-1900] add missing ' · 26ce47f5
  由 FelixNeutatz 提交于 4月 17, 2015
  
  26ce47f5
- R
  
  [FLINK-1902] Show jobmanager address/port in configuration · 10fc1d8d
  由 Robert Metzger 提交于 4月 17, 2015
  
  10fc1d8d
- T
  
  [docs] Corrects combineGroup documentation example · 32a04e42
  由 Till Rohrmann 提交于 4月 17, 2015
  
  32a04e42
- R
  [streaming][connectors] Add more configuration options to PersistentKafkaSource · ea710204
  由 Robert Metzger 提交于 4月 16, 2015
```
This closes #607
```
  ea710204
- A
  
  [FLINK-1856][doc] Add notice about implicit TypeInformation · c2faa6fe
  由 Aljoscha Krettek 提交于 4月 13, 2015
  
  c2faa6fe
- A
  
  [FLINK-1900] Fix Scala Table API Example in doc · 8c5cd973
  由 Aljoscha Krettek 提交于 4月 17, 2015
  
  8c5cd973
16 4月, 2015 1 次提交
- R
  [FLINK-1753] Extend KafkaITCase with large messages test + rework PersistentKafkaSource. · 354922be
  由 Robert Metzger 提交于 4月 13, 2015
```
This closes #603
```
  354922be
15 4月, 2015 4 次提交
- G
  [streaming] Major internal renaming and restructure · 4754a97b
  由 Gyula Fora 提交于 4月 13, 2015
```
Closes #594
```
  4754a97b
- G
  
  [FLINK-1876] [streaming] StreamGraph refactor · f1b445b0
  由 Gyula Fora 提交于 4月 13, 2015
  
  f1b445b0
- S
  
  [hotfix] Fix invalid timeout in JobClient · 56e9f1a8
  由 Stephan Ewen 提交于 4月 15, 2015
  
  56e9f1a8
- R
  
  [scripts] Update error message for missing commands of the jobmanager.sh script · 51a583ad
  由 Robert Metzger 提交于 4月 14, 2015
  
  51a583ad
14 4月, 2015 6 次提交
- G
  [FLINK-1753] [streaming] Added Kafka broker failure test · cb34e976
  由 Gábor Hermann 提交于 3月 23, 2015
```
This closes #589
```
  cb34e976
- U
  [FLINK-1660] [streaming] [tests] Fix MultiTriggerPolicyTest race · e5a3b95a
  由 Ufuk Celebi 提交于 4月 13, 2015
```
Closes #590
```
  e5a3b95a
- G
  
  [FLINK-1866] [streaming] StreamConfig key bugfix · 54d5662f
  由 Gyula Fora 提交于 4月 13, 2015
  
  54d5662f
- R
  [build system] Exclude log4j.properties files from uberjar and module jars · f50d7541
  由 Robert Metzger 提交于 4月 10, 2015
```
This closes #586
```
  f50d7541
- R
  [runtime] Avoid IllegalStateException when TaskManager is killed during startup · c910300e
  由 Robert Metzger 提交于 4月 10, 2015
```
This closes #587
```
  c910300e
- R
  
  [docs][yarn] Use SNAPSHOT flink version in SNAPSHOT documentation · 322782c8
  由 Robert Metzger 提交于 4月 13, 2015
  
  322782c8
13 4月, 2015 8 次提交
- S
  
  [tests] Cleanup sysout logging in tests · 69a400fa
  由 Stephan Ewen 提交于 4月 13, 2015
  
  69a400fa
- S
  
  [FLINK-1878] [APIs] Environments accept a flag that controls sysout logging during execution. · e79813bf
  由 Stephan Ewen 提交于 4月 13, 2015
  
  e79813bf
- S
  
  [FLINK-1868] [tests] Fix corner case of EnvironmentInformationTest · 0e6c9d4b
  由 Stephan Ewen 提交于 4月 13, 2015
  
  0e6c9d4b
- S
  [FLINK-1879] [client] Simplify JobClient. Hide actorRefs behind method calls where possible. · ad637077
  由 Stephan Ewen 提交于 4月 13, 2015
```
 - Drop redundant routing actor
 - Consistently set the flag to subscribe to updates or not.
 - Scala style cleanups: Drop default values for some method parameters.
```
  ad637077
- A
  [FLINK-1710] [table] Switch compile backend to Janino · f81d9f02
  由 Aljoscha Krettek 提交于 4月 07, 2015
```
This greatly reduces compile time while still supporting the same
feature set.
```
  f81d9f02
- R
  
  [docs] Remove skeleton page from navigation, add links to ML pages · 92e0c774
  由 Robert Metzger 提交于 4月 13, 2015
  
  92e0c774
- R
  
  [flink-yarn-tests] Make error messages verbose for debugging · f89e1365
  由 Robert Metzger 提交于 4月 13, 2015
  
  f89e1365
- M
  
  [streaming] Cancellation update in connectors · 2d13c21f
  由 mbalassi 提交于 4月 12, 2015
  
  2d13c21f
11 4月, 2015 3 次提交
- G
  
  [streaming] Removed unnecessary BatchIterator class · 46573a6a
  由 Gyula Fora 提交于 4月 10, 2015
  
  46573a6a
- G
  
  [FLINK-1838] [doc] Streaming programming guide update · e01894c4
  由 Gyula Fora 提交于 4月 07, 2015
  
  e01894c4
- M
  
  [streaming] ITCase for WindowWordCount · 71b2d664
  由 mbalassi 提交于 4月 09, 2015
  
  71b2d664
10 4月, 2015 12 次提交
- S
  
  [tests] Increase robustness of SimpleRecoveryITCase · 36fcdae5
  由 Stephan Ewen 提交于 4月 10, 2015
  
  36fcdae5
- S
  [FLINK-1862] [apis] Add support for non-serializable types for collect() by... · 211d0bdb
  由 Stephan Ewen 提交于 4月 10, 2015
```
[FLINK-1862] [apis] Add support for non-serializable types for collect() by switching from Java serialization to Flink serialization
```
  211d0bdb
- R
  
  [FLINK-1835] Stabilize YARN tests · 3246255b
  由 Robert Metzger 提交于 4月 09, 2015
  
  3246255b
- U
  
  [runtime] [tests] Remove RemoteInputChannelTest timeout · 830dab25
  由 Ufuk Celebi 提交于 4月 10, 2015
  
  830dab25
- U
  
  [FLINK-1850] Fix version on startpage · 9cd38f0b
  由 Ufuk Celebi 提交于 4月 10, 2015
  
  9cd38f0b
- S
  
  [tests] Revert accidentally committed log level change for tests · 499790c1
  由 Stephan Ewen 提交于 4月 10, 2015
  
  499790c1
- S
  [FLINK-1535] [tests] Add custom acumulators and custom type collect() to classloading tests · 922db790
  由 Stephan Ewen 提交于 4月 09, 2015
```
Consolidate class loading tests into one cluster execution to validate repeated different class loaders
```
  922db790
- S
  [FLINK-1535] [core] Rework accumulators · 6774054a
  由 Stephan Ewen 提交于 4月 07, 2015
```
  - Accumulators rely consistently on java serialization
  - Fix accumulator transport to support custom classes
  - Fix collect() accumulator to use correct class loader
```
  6774054a
- S
  [runtime] Accumulators are reported through the RuntimeEnvironment, not... · 201bea3f
  由 Stephan Ewen 提交于 4月 08, 2015
```
[runtime] Accumulators are reported through the RuntimeEnvironment, not directly sent as an actor message
```
  201bea3f
- U
  [docs] Add clickable stack figure on overview page · 9ffcdf36
  由 Ufuk Celebi 提交于 4月 09, 2015
```
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.
```
  9ffcdf36
- U
  [docs] Add custom search · a4794631
  由 Ufuk Celebi 提交于 4月 02, 2015
```
This closes #563.
```
  a4794631
- R
  [quickstarts] Set different default groupid for quickstarts to avoid exclusion... · 0e3e6a3c
  由 Robert Metzger 提交于 4月 10, 2015
```
[quickstarts] Set different default groupid for quickstarts to avoid exclusion by the assembly plugin
```
  0e3e6a3c

doujutun3207 / flink 与 Fork 源项目一致

doujutun3207 / flink
与 Fork 源项目一致