- 20 2月, 2015 12 次提交
-
-
由 Till Rohrmann 提交于
This closes #422
-
由 Stephan Ewen 提交于
-
由 Till Rohrmann 提交于
[FLINK-1584] [runtime][tests] Fixes TaskManagerFailsITCase by replacing the TestingCluster with a ForkableFlinkMiniCluster This closes #419
-
由 Carsten Brandt 提交于
Height of information bullets was not equal due to text break. This closes #425
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-1585] [tests] Fix mini clusters to respect memory and buffer configurations and improve relative memory computation.
-
由 Gyula Fora 提交于
-
由 Jonas Traub (powibol) 提交于
-
由 Jonas Traub (powibol) 提交于
[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.
-
由 Jonas Traub (powibol) 提交于
[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.
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
[streaming] WindowBuffer separated from Discretizer for operator sharing + equality checks added for windowing objects
-
- 19 2月, 2015 8 次提交
-
-
由 Ufuk Celebi 提交于
This closes #407.
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 mbalassi 提交于
-
由 mbalassi 提交于
-
由 Stephan Ewen 提交于
This closes #417
-
由 Henry Saputra 提交于
This closes #416
-
由 Stephan Ewen 提交于
-
- 18 2月, 2015 9 次提交
-
-
由 Robert Metzger 提交于
This closes #393
-
由 Robert Metzger 提交于
-
由 Aljoscha Krettek 提交于
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
-
由 Robert Metzger 提交于
Conflicts: flink-java/pom.xml flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java
-
由 Robert Metzger 提交于
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
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
This closes #412
-
由 Fabian Hueske 提交于
Move RuntimeContext initialization to begin of RegularPactTask.invoke().
-
由 Gyula Fora 提交于
-
- 17 2月, 2015 8 次提交
-
-
由 Till Rohrmann 提交于
Fixes unhandled FailsIntermediateResultPartitions message. Changes JobResultFailed and JobResultCanceled to send the cause as a throwable instead of a string. Fixes NullPointerException if an execution has already been prepared for archiving and sendPartitionInfos is called asynchronously This closes #406.
-
由 Till Rohrmann 提交于
[FLINK-1554] [runtime] Allows the LocalFlinkMiniCluster to start multiple TaskManager in the same ActorSystem. This closes #403.
-
由 Till Rohrmann 提交于
This closes #397.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Henry Saputra 提交于
[FLINK-1542] Test case at BlobUtilsTest should not assume user could not create new item in root directory Sometimes, user that run tests could have write access to root dir such as creating /cannot-create-this is possible, hence to exception thrown. Need to construct a Flink test directory under directory specified under "java.io.tmpdir" and change the permission to not allow create new directory. This closes #396
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
- 16 2月, 2015 3 次提交
-
-
由 Stephan Ewen 提交于
[FLINK-1454] [job client] Improve error handling for failed connections between JobClient and JobManager
-
由 mbalassi 提交于
This closes #395
-
由 Gyula Fora 提交于
-