Added registerTaskManager to the JobManager RPC calls. RegisterTaskManager is called only once where the hardware description information is sent.
Testcase for filter with broadcast variable
Add test for StringSerializer for #589
Mixed key types for join
Minor error checks and message cleanups
Old Java Api now also uses the binary Union Operator and cleaned the common.api/optimizer level from input operator lists. Also added PropertyPropagationTest for new java api union
Comments and cleanup for (delta) iterations.
Clean up common api operators and marked var arg inputs as implicit unions as deprecated.
Record API builder pattern suppoerts the model still. The common api uses an explicit union model.
Post merge cleanup of Union operator.
Unify delta iteration methods on DataSet.
Fix documentation errors.
Add support for multiple joins with the solution set.
Add test to verify that distinct probers are used in the case of performing multiple concurrent hash joins with teh same hash table.
Various minor fixes:
- better exceptions for faulty temporary directories
- better exception if client can not connect to JobManager
Add distributed cache to stratosphere
change codestyles and clean up
add test for delete process of tmp file and tested in cluster
Cleanup and simplification in the taskmanager and the local instances and mini cluster.
Fixed log levels, code cleanups and restore the thread interruption states for JobManager and TaskManager
Fixed heartbeat thread and startup/shutdown races in TaskManager