- 19 1月, 2016 5 次提交
-
-
由 Robert Metzger 提交于
-
由 Fabian Hueske 提交于
Clean up several compiler warnings. This closes #1509
-
由 Stephan Ewen 提交于
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
- 18 1月, 2016 4 次提交
-
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Till Rohrmann 提交于
[FLINK-3184] [timeouts] Set default cluster side timeout to 10 s and the client side timeout to 60 s Add missing param descriptions to FlinkYarnCluster, remove implicit timeout from ApplicationClient This closes #1468
-
- 16 1月, 2016 5 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Greg Hogan 提交于
This closes #1462
-
由 Aljoscha Krettek 提交于
-
- 15 1月, 2016 19 次提交
-
-
由 Ufuk Celebi 提交于
[pr-comments] Decrease font size [pr-comments] Remove docker connector section This closes #1499.
-
由 Ufuk Celebi 提交于
This closes #1458.
-
由 Ufuk Celebi 提交于
Removed streaming mode lead to wrong arguments being passed.
-
由 Ufuk Celebi 提交于
-
由 Prez Cannady 提交于
This closes #1511
-
由 Ajay Bhat 提交于
This closes #1494
-
由 Stephan Ewen 提交于
-
由 Greg Hogan 提交于
-
由 Ufuk Celebi 提交于
Adds a flag to the ExecutionGraph's IntermediateResult class indicating whether the result consumers should be deployed eagerly. If true, the consumers are deployed as soon as the partition is registered at the ResultPartitionManager of the task manager. In practice, the deployment boils down to updating unknown input channels of the consumers (because the actual tasks are actually deployed all at once). This behaviour is configured in the JobGraph generator and only activated for streaming programs (StreamingJobGraphGenerator). It only makes sense for pipelined results. The motivation is to get down the latency of the first records passing a pipeline. The initial update of the input channels causes a higher latency. You can see this effect in the StreamingScalabilityAndLatency class (manual test). At the moment, this results in duplicate Akka messages when the first record is produced (the message travels from the task to the job manager and from the job manager to task manager, which then will be ignored at the InputGate). This closes #1503
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
The README was describing non-existing bash scripts removed several versions ago.
-
由 Stephan Ewen 提交于
-
由 Prez Cannady 提交于
Originally, the user code classloader delegates to the system classloader as parent. That works in Flink standalone settings, but not when the Flink core classes themselves are not loaded with the system classloader (certain embedded setups). This patch uses as parent the classloader that was used to load the Flink core classes, specificly "org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager.FlinkUserCodeClassLoader.class.getClassLoader()". This closes #1506 This closes #1507 This closes #1508
-
由 Stephan Ewen 提交于
- Removes Apache Commons HTTP Client - Removes Apache Commons IO - Removes Jettison JSONparser and consolidates tests to use Jackson instead (which is included anyways)
-
由 mjsax 提交于
This closes #1510
-
由 Chiwan Park 提交于
This closes #1504.
-
由 mjsax 提交于
This closes #1495.
-
由 mjsax 提交于
- added BLOCKING flag to FlinkLocalCluster - added NullTerminatingSpout and SpoutOutputCollectorObserver plus tests - reworked test accordingly - set BLOCKING flag for ITCases - make infinite spouts finite using NullTerminatingSpout - removed sleep time to get stable - fixed bug in BoltSplitITCase and SpoutSplitITCase - exception in VerifyAndEnrichBolt is swallowed and test would not fail (replaced by errorFlag) - reduced sleep-time in BoltSplitITCase and SpoutSplitITCase to reduce testing time - fixed WrapperSetupHelperTest - reworked to origianl version with more than two inputs (was limite to two inputs because more the two inputs per bolt was not supported in between, which is now fixed) minor code cleanup (removed unused imports, indenting, etc.) fixed small error in documenation This closes #1502.
-
由 Ufuk Celebi 提交于
-
- 14 1月, 2016 4 次提交
-
-
由 Robert Metzger 提交于
This closes #1492 This closes #1482
-
由 Robert Metzger 提交于
-
由 Stephan Ewen 提交于
[FLINK-3195] [examples] Consolidate batch examples into one project, unify batch and streaming examples under on parent project
-
由 Theodore Vasiloudis 提交于
- Add more tests to `StandardScalerITSuite` - Refactor `StandardScalerITSuite` This closes #899.
-
- 13 1月, 2016 3 次提交
-
-
由 Ufuk Celebi 提交于
Netty versions >= 4.0.28.Final contain an improvement by Netty, which slices a Netty buffer instead of doing a memory copy (https://github.com/netty/netty/issues/3704) in the LengthFieldBasedFrameDecoder. In some situations, this interacts badly with our Netty pipeline leading to OutOfMemory error. To reproduce, run batch WordCount with a range partitioner and reasonably large data.
-
由 Martin Junghanns 提交于
This closes #1471
-
由 gallenvara 提交于
This closes #1477
-