- 27 6月, 2014 1 次提交
-
-
由 Stephan Ewen 提交于
-
- 26 6月, 2014 5 次提交
-
-
由 Aljoscha Krettek 提交于
This adds support in the TypeExtractor and also one can now use field expressions for grouping, join, and co-group.
-
由 Aljoscha Krettek 提交于
This is required because we need state to detect recursive data types. This will become necessary when introducing Pojo Types.
-
由 uce 提交于
-
由 Jonathan 提交于
https://issues.apache.org/jira/browse/FLINK-978 Author: Jonathan <Jonathan@Hasenburg.de> Closes #46 from JonathanH5/fixWebI and squashes the following commits: 13a7d41 [Jonathan] Fixed Bug Flink-978
-
由 Stephan Ewen 提交于
[ci skip]
-
- 25 6月, 2014 16 次提交
-
-
由 uce 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
Change string construction to work around a known JVM performance bug still present in some older JVM versions.
-
由 Stephan Ewen 提交于
-
由 Markus Holzemer 提交于
-
由 uce 提交于
[FLINK-971] Configure PooledByteBufAllocator in NettyConnectionManager instead of using the default allocator Configuration: - 0 heap arenas, - n direct arenas (where n = num incoming + num outgoing network IO threads), and - bufferSize << 1 bytes page size. Additionally, OutboundEnvelopeEncoder directly implements ChannelOutboundHandlerAdapter instead of the MessageToByteEncoder<Envelope> wrapper to have tighter control of memory allocations. This closes #38.
-
由 Sebastian Kunert 提交于
This closes #39.
-
由 Till Rohrmann 提交于
This closes #33.
-
由 uce 提交于
This closes #28.
-
由 Kostas Tzoumas 提交于
This closes #17.
-
由 Stephan Ewen 提交于
[FLINK-973] [FLINK-969] Unify, clean up, and extend all environment logging at JobManager/TaskManager startup This closes #40.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
Add logging for task slots.
-
由 uce 提交于
-
由 uce 提交于
- Set DummyInputFormat and DummyOutputFormat via TaskConfig to respect task hierarchy refactoring. - Run test via main method instead of JUnit test runner (this was originally a test in order to use RecordAPITestBase for JobGraph submission). This closes #41.
-
- 24 6月, 2014 3 次提交
-
-
由 uce 提交于
-
由 uce 提交于
-
由 Robert Metzger 提交于
-
- 23 6月, 2014 11 次提交
-
-
由 Robert Metzger 提交于
-
由 uce 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
Rework Invokable Task Hierarchy
-
由 Till Rohrmann 提交于
Standardized creation of input and output channels in InputGate and OutputGate. Removed linear contains check in InputGate for channels.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Replaced Tarjan's algorithm with a simpler depth-first traversal cycle detection algorithm. By doing so, one gets rid off a possible linear time check whether a node is contained in the stack.
-
由 Till Rohrmann 提交于
New test case: Exception during ExecutionGraph construction in the JobManager Removed checkConfiguration method from AbstractJobVertex because it is not needed anymore
-
由 Till Rohrmann 提交于
Removed RuntimeEnvironment instantiation from execution graph construction. Removed legacy job vertex classes and input/output tasks.
-
由 Stephan Ewen 提交于
-
由 Till Rohrmann 提交于
Squashed commit of the following: - Post merge cleanup - Renamed fractionMemory into memoryFraction. - Removed Local and QueueScheduler and replaced it instead with an unified DefaultScheduler. - Removed Local and ClusterManager and inserted instead an unified DefaultInstanceManager. - Removed connection IDs from execution edges - Removed InstanceType, InstanceRequestMap, InstanceTypeDescription, InstanceTypeDescriptionTypeFactory, PendingRequestsMap - Fixed problems with test cases. - introduced simple slot system for scheduling. - Removed subtasks per instance - Added registerTaskManager to the JobManager RPC calls. RegisterTaskManager is called only once where the hardware description information is sent. Add: Merging cloudmodel remove with new network stack
-
- 21 6月, 2014 4 次提交
-
-
由 twalthr 提交于
Fixes a bug where Thread.currentThread().getContextClassLoader() does not return the user code class loader within object deserialization.
-
由 Robert Metzger 提交于
This closes #32.
-
由 twalthr 提交于
-
由 Jonathan 提交于
https://issues.apache.org/jira/browse/FLINK-946 ![bildschirmfoto 2014-06-20 um 14 43 26](https://cloud.githubusercontent.com/assets/5738978/3340103/82d0485e-f878-11e3-9d15-617102ea40a3.png) Author: Jonathan <Jonathan@Hasenburg.de> Closes #30 from JonathanH5/wi_version and squashes the following commits: f29180a [Jonathan] Added Version and Revision of Stratosphere in Webinterface
-