提交 · 98da559d0ff3d1a66b49ce1cbacf463eef7cccbe · doujutun3207 / flink

23 2月, 2015 3 次提交
- A
  
  Add methods to CompositeType for querying field types and names · 98da559d
  由 Aljoscha Krettek 提交于 10月 23, 2014
  
  98da559d
- A
  Change translateToDataflow to return Operator · 86ca6927
  由 Aljoscha Krettek 提交于 10月 03, 2014
```
Before, translateToDataflow of SingleInputOperator could only return
a single input operator of the lower layer, same for TwoInputOperator.

This change allows translateToDataflow to return more kinds of
operators.
```
  86ca6927
- U
  [FLINK-1505] [distributed runtime] Separate reader API from result consumption · 5232c56b
  由 Ufuk Celebi 提交于 2月 10, 2015
```
This closes #428.
```
  5232c56b
21 2月, 2015 1 次提交
- G
  
  [FLINK-1592] [streaming] StreamGraph refactor to store vertex IDs as Integers · a911559a
  由 Gyula Fora 提交于 2月 21, 2015
  
  a911559a
20 2月, 2015 22 次提交
- F
  [FLINK-1466] Add support for complex types in Flink tuples for HCatInputFormats. · bed3da4a
  由 Fabian Hueske 提交于 2月 18, 2015
```
This closes #411
```
  bed3da4a
- F
  
  [FLINK-1466] Adds HCatInputFormats to read from HCatalog tables. · a6acd2e4
  由 Fabian Hueske 提交于 1月 29, 2015
  
  a6acd2e4
- F
  [FLINK-1461][api-extending] Add SortPartition operator to Java and Scala APIs. · 3d849703
  由 Fabian Hueske 提交于 2月 10, 2015
```
This closes #381
```
  3d849703
- F
  [FLINK-1444][api-extending] Add support for attaching data properties to data sources · f0a28bf5
  由 Fabian Hueske 提交于 2月 06, 2015
```
This closes #379
```
  f0a28bf5
- G
  
  [FLINK-1451] [streaming] Parallel file source fix + minor windowing fix · c56e3f10
  由 Gyula Fora 提交于 2月 20, 2015
  
  c56e3f10
- S
  
  [tests] Flix flakey SimpleRecoveryITCase · 1f49926b
  由 Stephan Ewen 提交于 2月 20, 2015
  
  1f49926b
- R
  
  Update references in master to 0.8.1 release · c46bdff0
  由 Robert Metzger 提交于 2月 20, 2015
  
  c46bdff0
- S
  
  [tests] Cleanup style and timeouts in recovery restart tests · a51c02f6
  由 Stephan Ewen 提交于 2月 19, 2015
  
  a51c02f6
- T
  [FLINK-1499] [runtime] TaskManager sends explicit disconnect message to... · 665e6012
  由 Till Rohrmann 提交于 2月 17, 2015
```
[FLINK-1499] [runtime] TaskManager sends explicit disconnect message to JobManager in case of shutdown

This closes #423
```
  665e6012
- T
  [Flink-1484] [runtime] JobManager sends an explicit disconnect message to the... · 5ac1911a
  由 Till Rohrmann 提交于 2月 17, 2015
```
[Flink-1484] [runtime] JobManager sends an explicit disconnect message to the registered TaskManagers in case of a graceful shutdown.
```
  5ac1911a
- T
  [FLINK-1556] [runtime] Fails jobs properly in case of a job submission exception · 4ff91cd7
  由 Till Rohrmann 提交于 2月 19, 2015
```
This closes #422
```
  4ff91cd7
- S
  
  [FLINK-1584] [tests] Move logic for failure detection test cluster into test classes · dbf589ad
  由 Stephan Ewen 提交于 2月 19, 2015
  
  dbf589ad
- T
  [FLINK-1584] [runtime][tests] Fixes TaskManagerFailsITCase by replacing the... · 52b40deb
  由 Till Rohrmann 提交于 2月 19, 2015
```
[FLINK-1584] [runtime][tests] Fixes TaskManagerFailsITCase by replacing the TestingCluster with a ForkableFlinkMiniCluster

This closes #419
```
  52b40deb
- C
  [web frontend] Small UI css class fix · 5424be4c
  由 Carsten Brandt 提交于 2月 19, 2015
```
Height of information bullets was not equal due to text break.

This closes #425
```
  5424be4c
- S
  
  [tests] Add integration test for restart recovery · 7d80711d
  由 Stephan Ewen 提交于 2月 16, 2015
  
  7d80711d
- S
  [FLINK-1585] [tests] Fix mini clusters to respect memory and buffer... · a1104491
  由 Stephan Ewen 提交于 2月 19, 2015
```
[FLINK-1585] [tests] Fix mini clusters to respect memory and buffer configurations and improve relative memory computation.
```
  a1104491
- G
  
  [streaming] Moved WindowingOptimizer to its own class + several minor fixes · 8111177c
  由 Gyula Fora 提交于 2月 19, 2015
  
  8111177c
- J
  
  [streaming] Added cloneable versions of MultiEvictionPolicy and MultiTriggerPolicy · 962db92a
  由 Jonas Traub (powibol) 提交于 2月 19, 2015
  
  962db92a
- J
  [streaming] Add MultiEvictionPolicy: It wraps around multiple eviction... · 09490c4b
  由 Jonas Traub (powibol) 提交于 2月 19, 2015
```
[streaming] Add MultiEvictionPolicy: It wraps around multiple eviction policies and allows to use them at the same time. It supports both, active and not active policies at the same time. Additionally it introduces different eviction strategies the user can choose from.
```
  09490c4b
- J
  [streaming] Add MultiTriggerPolicy: It wraps around multiple triggers and... · 64f7bf7d
  由 Jonas Traub (powibol) 提交于 2月 19, 2015
```
[streaming] Add MultiTriggerPolicy: It wraps around multiple triggers and allows to use them at the same time. It supports both, active and not active policies at the same time.
```
  64f7bf7d
- G
  
  [streaming] Discretizer sharing added with further window optimzations for better chaining · ca7f36e1
  由 Gyula Fora 提交于 2月 19, 2015
  
  ca7f36e1
- G
  [streaming] WindowBuffer separated from Discretizer for operator sharing +... · e5528a25
  由 Gyula Fora 提交于 2月 19, 2015
```
[streaming] WindowBuffer separated from Discretizer for operator sharing + equality checks added for windowing objects
```
  e5528a25
19 2月, 2015 8 次提交
- U
  [builds] Allow to upload build artifacts to S3 · 6c01598a
  由 Ufuk Celebi 提交于 2月 16, 2015
```
This closes #407.
```
  6c01598a
- U
  
  [builds] Add logger layout to prefix log output with Maven fork number · 6b082b55
  由 Ufuk Celebi 提交于 2月 16, 2015
  
  6b082b55
- U
  
  [builds] Print Java process stack traces of stalled builds · 341c859c
  由 Ufuk Celebi 提交于 2月 12, 2015
  
  341c859c
- M
  
  [FLINK-1560][streaming] streaming WordCount ITCases · a673e7ba
  由 mbalassi 提交于 2月 18, 2015
  
  a673e7ba
- M
  
  [FLINK-1560] [streaming] StreamExecutionEnvironment enhancement for ITCases · 6049398d
  由 mbalassi 提交于 2月 18, 2015
  
  6049398d
- S
  [FLINK-1483] IOManager puts temp files in dedicated directory and removes that on shutdown · c1a334e1
  由 Stephan Ewen 提交于 2月 18, 2015
```
This closes #417
```
  c1a334e1
- H
  Remove extra space after open parenthesis in InstanceConnectionInfo#toString. · 681ea06f
  由 Henry Saputra 提交于 2月 18, 2015
```
This closes #416
```
  681ea06f
- S
  
  [blob manager] Fix flakey test. · 42578b67
  由 Stephan Ewen 提交于 2月 18, 2015
  
  42578b67
18 2月, 2015 6 次提交
- R
  [FLINK-1567] Add option to switch between Avro and Kryo serialization · e6754a6d
  由 Robert Metzger 提交于 2月 17, 2015
```
This closes #393
```
  e6754a6d
- R
  
  [FLINK-1417] Automatically register types with Kryo · 354efec0
  由 Robert Metzger 提交于 1月 26, 2015
  
  354efec0
- A
  [FLINK-1395] Add support for JodaTime in KryoSerializer · 5015ab49
  由 Aljoscha Krettek 提交于 1月 13, 2015
```
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
```
  5015ab49
- R
  [FLINK-1392] Add Kryo serializer for Protobuf · 77c45484
  由 Robert Metzger 提交于 1月 13, 2015
```
Conflicts:
	flink-java/pom.xml
	flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java
```
  77c45484
- R
  [FLINK-1391] Add support for using Avro-POJOs and Avro types with Kryo · 7e39bc67
  由 Robert Metzger 提交于 1月 12, 2015
```
Conflicts:
	flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
	flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java
```
  7e39bc67
- S
  
  [FLINK-1578] [BLOB manager] Improve failure handling and add more failure tests. · cfce493f
  由 Stephan Ewen 提交于 2月 18, 2015
  
  cfce493f

doujutun3207 / flink 与 Fork 源项目一致

doujutun3207 / flink
与 Fork 源项目一致