commits  

Messages by Thread

• [1/5] flink git commit: [FLINK-1266] Properly pass the fs.defaulFS setting when initializing filesystems rmetzger
  • [4/5] flink git commit: [FLINK-1266] Generalize DistributedFileSystem implementation to HadoopFileSystem wrapper, which supports all subclasses of org.apache.hadoop.fs.FileSystem. This allows us to let users use all file systems with support for HDFS. Th rmetzger
  • [2/5] flink git commit: [FLINK-1266] Update mongodb link and address pull request comments rmetzger
  • [3/5] flink git commit: [FLINK-1266] Generalize DistributedFileSystem implementation to HadoopFileSystem wrapper, which supports all subclasses of org.apache.hadoop.fs.FileSystem. This allows us to let users use all file systems with support for HDFS. Th rmetzger
  • [5/5] flink git commit: [FLINK-1266] More dependency exclusions & fixed image in web client rmetzger
• [1/2] flink git commit: [FLINK-1245] [Java API] Introduce TypeHints for Java API operators sewen
  • [2/2] flink git commit: [FLINK-1245] [Java API] Introduce TypeHints for Java API operators sewen
• [1/3] flink git commit: [FLINK-1367] [scala] [streaming] Field aggregations added to streaming scala api mbalassi
  • [3/3] flink git commit: [streaming] [scala] scala SocketTextStream added and minor fixes mbalassi
  • [2/3] flink git commit: [streaming] Replaced partitionBy with groupBy + re-added global partitioning mbalassi
• flink git commit: [FLINK-1371] [runtime] Fix KryoSerializer to not swallow EOFExceptions sewen
  • flink git commit: [FLINK-1371] [runtime] Fix KryoSerializer to not swallow EOFExceptions rmetzger
• [01/13] flink git commit: [FLINK-1285] Make Merge-Join aware of object-reuse setting sewen
  • [04/13] flink git commit: [FLINK-1285] Make execution mode configurable sewen
  • [12/13] flink git commit: [FLINK-1285] Various cleanup of object reusing and non-reusing code. sewen
  • [05/13] flink git commit: [FLINK-1285] Make execution mode configurable sewen
  • [03/13] flink git commit: [FLINK-1285] Make execution mode configurable sewen
  • [11/13] flink git commit: [FLINK-1137] Enhance MutableObjectIterator with non-reuse next() sewen
  • [13/13] flink git commit: [runtime] Release additional broadcast variable references early sewen
  • [02/13] flink git commit: [FLINK-1285] Make Merge-Join aware of object-reuse setting sewen
  • [06/13] flink git commit: [FLINK-1285] Make execution mode configurable sewen
  • [09/13] flink git commit: [FLINK-1285] Make execution mode configurable sewen
  • [08/13] flink git commit: [FLINK-1285] Make execution mode configurable sewen
  • [07/13] flink git commit: [FLINK-1285] Make execution mode configurable sewen
  • [10/13] flink git commit: [FLINK-1285] Make execution mode configurable sewen
• [1/2] flink git commit: [FLINK-1361] change jobManager log file name back to old value sewen
  • [2/2] flink git commit: [FLINK-1354] Made test graph for TransitiveClosureITCase smaller sewen
• flink git commit: Commit for release 0.8.0 mbalassi
• [1/2] flink git commit: [FLINK-1365] Fix ValueTypeInfo aljoscha
  • [2/2] flink git commit: [FLINK-1366] Enable FastPath in TextValueInputFormat again aljoscha
• [01/36] flink git commit: [streaming] Time trigger preNotify fix mbalassi
  • [19/36] flink git commit: [scala] [streaming] added group windowing example with different policy types mbalassi
  • [30/36] flink git commit: [FLINK-1338] [docs] Remove incubator footer from docs mbalassi
  • [03/36] flink git commit: [scala] [streaming] Extended scala data stream functionality to include simple operators mbalassi
  • [11/36] flink git commit: [scala] [streaming] Modified aggregations to work on scala tuples mbalassi
  • [10/36] flink git commit: [scala] [streaming] Temporal cross operator added mbalassi
  • [04/36] flink git commit: [scala] [streaming] Finished scala StreamExecutionEnvrionment functionality + DataStream sinks + docs mbalassi
  • [02/36] flink git commit: [scala] [streaming] Base functionality added for streaming scala api mbalassi
  • [28/36] flink git commit: [docs] Remove files from obolete and unused figures mbalassi
  • [15/36] flink git commit: [streaming] Streaming API grouping rework to use batch api Keys mbalassi
  • [33/36] flink git commit: [scala] [streaming] Added package file for streaming scala api typeinfo implicits and conversions mbalassi
  • [08/36] flink git commit: [streaming] Temporal join and cross rework for consistence and extended features mbalassi
  • [23/36] flink git commit: [streaming] Updated connector type handling to suport generic classes by GenericSourceFunction interface mbalassi
  • [35/36] flink git commit: [streaming] [scala] scala SocketTextStream added and minor fixes mbalassi
  • [31/36] flink git commit: [streaming] Deleted obsolete parts of the connected stream api mbalassi
  • [14/36] flink git commit: [scala] [streaming] WindowJoin scala example added mbalassi
  • [27/36] flink git commit: [docs] Trivial typo in example code: o -> out. mbalassi
  • [21/36] flink git commit: [scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams mbalassi
  • [24/36] flink git commit: [streaming] [scala] Restructured streaming scala project and examples mbalassi
  • [16/36] flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support mbalassi
  • [06/36] flink git commit: [scala] [streaming] Added SplitDataStream functionality mbalassi
  • [26/36] flink git commit: [streaming] [scala] Restructured streaming scala project and examples mbalassi
  • [07/36] flink git commit: [scala] [streaming] Added support for iterative streams for scala api mbalassi
  • [32/36] flink git commit: [streaming] Updated streaming guide for recent connector and data source changes mbalassi
  • [05/36] flink git commit: [scala] [streaming] Windowing functionality added to scala api mbalassi
  • [34/36] flink git commit: [scala] [streaming] added scala streams as sources in streaming-api scala examples mbalassi
  • [20/36] flink git commit: [scala] [streaming] added initial ConnectedDataStream support (no windowing, batching) for the scala api mbalassi
  • [22/36] flink git commit: [streaming] Source parallelism + connector rework mbalassi
  • [18/36] flink git commit: [scala] [streaming] Added implicit conversions from java to scala streams mbalassi
  • [13/36] flink git commit: [scala] [streaming] Added groupBy support for case class fields mbalassi
  • [12/36] flink git commit: [scala] [streaming] Fixed scala formatting mbalassi
  • [25/36] flink git commit: [streaming] [scala] Restructured streaming scala project and examples mbalassi
  • [17/36] flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support mbalassi
  • [36/36] flink git commit: [streaming] Replaced partitionBy with groupBy + re-added global partitioning mbalassi
  • [29/36] flink git commit: [streaming] Temporal operator windowing syntax update mbalassi
  • [09/36] flink git commit: [scala] [streaming] Temporal join operator added mbalassi
• flink git commit: [FLINK-1363] [runtime tests] Fix race condition in ExecutionVertexCancelTest.testSendCancelAndReceiveFail trohrmann
• svn commit: r1650029 - in /flink: _posts/2015-01-06-december-in-flink.md site/blog/index.html site/blog/page2/index.html site/blog/page3/index.html site/news/2015/ site/news/2015/01/ site/news/2015/01/06/ site/news/2015/01/06/december-in-flink.html ktzoumas
• svn commit: r1649923 - in /flink/site: doap_flink.rdf index.html rmetzger
• svn commit: r1649922 - /flink/doap_flink.rdf rmetzger
• svn commit: r1649876 - /incubator/flink/ coreyg
• svn commit: r1649876 - /flink/ coreyg
• [1/3] incubator-flink git commit: [FLINK-1169] [apis] Add documentation for join hints. sewen
  • [2/3] incubator-flink git commit: [FLINK-1259] [apis] Added comments to interface and docs that filters must not mutate date elements. sewen
  • [3/3] incubator-flink git commit: [FLINK-1300] [core] Remove unused and redundant files DataInputViewStream and DataOutputViewStream. sewen
• [1/5] incubator-flink git commit: [scala] [streaming] added scala streams as sources in streaming-api scala examples mbalassi
  • [4/5] incubator-flink git commit: [scala] [streaming] Added package file for streaming scala api typeinfo implicits and conversions mbalassi
  • [3/5] incubator-flink git commit: [streaming] Temporal operator windowing syntax update mbalassi
  • [2/5] incubator-flink git commit: [streaming] Updated streaming guide for recent connector and data source changes mbalassi
  • [5/5] incubator-flink git commit: [streaming] Deleted obsolete parts of the connected stream api mbalassi
• [1/3] incubator-flink git commit: [FLINK-1357] [compiler] Add union between static and dynamic path sewen
  • [2/3] incubator-flink git commit: [FLINK-1027] [cli] Added support for '--' and '-' prefixed tokens in CLI program arguments. sewen
  • [3/3] incubator-flink git commit: [FLINK-1236] [hadoop compatibility] Add local split assignment support for HadoopInputFormats sewen
• incubator-flink git commit: [FLINK-1335] [docs] Minor fix to README file sewen
• [1/4] incubator-flink git commit: [FLINK-1349] [runtime] Various cleanups to make scala runtime code interact smoother with java sewen
  • [2/4] incubator-flink git commit: [FLINK-1349] [runtime] Various fixes concerning Akka - Remove obsolete code from old IPC net utils - Smaller Writable/IOReadableWritable serialzation buffer start size (most messages are rather small) - For message lo sewen
  • [3/4] incubator-flink git commit: [FLINK-1349] [runtime] Various fixes concerning Akka - Remove obsolete code from old IPC net utils - Smaller Writable/IOReadableWritable serialzation buffer start size (most messages are rather small) - For message lo sewen
  • [4/4] incubator-flink git commit: [FLINK-1335] [docs] Add guide how to set up Eclipse, and bring README.md up to speed. sewen
• incubator-flink git commit: Remove full package name for FlatMapOperatorBase hsaputra
• [1/8] incubator-flink git commit: [docs] Remove files from obolete and unused figures sewen
  • [2/8] incubator-flink git commit: [FLINK-1338] [docs] Remove incubator footer from docs sewen
  • [8/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. sewen
  • [7/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. sewen
  • [3/8] incubator-flink git commit: [FLINK-1346] [docs] Add stubs for Akka documentation sewen
  • [6/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. sewen
  • [5/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. sewen
  • [4/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling. sewen
• [01/27] incubator-flink git commit: [streaming] Time trigger preNotify fix mbalassi
  • [16/27] incubator-flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support mbalassi
  • [10/27] incubator-flink git commit: [scala] [streaming] Added SplitDataStream functionality mbalassi
  • [19/27] incubator-flink git commit: [scala] [streaming] added group windowing example with different policy types mbalassi
  • [15/27] incubator-flink git commit: [scala] [streaming] WindowJoin scala example added mbalassi
  • [12/27] incubator-flink git commit: [scala] [streaming] Added support for iterative streams for scala api mbalassi
  • [20/27] incubator-flink git commit: [scala] [streaming] added initial ConnectedDataStream support (no windowing, batching) for the scala api mbalassi
  • [08/27] incubator-flink git commit: [scala] [streaming] Extended scala data stream functionality to include simple operators mbalassi
  • [27/27] incubator-flink git commit: [docs] Trivial typo in example code: o -> out. mbalassi
  • [14/27] incubator-flink git commit: [scala] [streaming] Added groupBy support for case class fields mbalassi
  • [07/27] incubator-flink git commit: [scala] [streaming] Windowing functionality added to scala api mbalassi
  • [24/27] incubator-flink git commit: [streaming] [scala] Restructured streaming scala project and examples mbalassi
  • [21/27] incubator-flink git commit: [scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams mbalassi
  • [11/27] incubator-flink git commit: [streaming] Temporal join and cross rework for consistence and extended features mbalassi
  • [23/27] incubator-flink git commit: [streaming] Updated connector type handling to suport generic classes by GenericSourceFunction interface mbalassi
  • [06/27] incubator-flink git commit: [scala] [streaming] Temporal join operator added mbalassi
  • [02/27] incubator-flink git commit: [scala] [streaming] Fixed scala formatting mbalassi
  • [18/27] incubator-flink git commit: [scala] [streaming] Added implicit conversions from java to scala streams mbalassi
  • [25/27] incubator-flink git commit: [streaming] [scala] Restructured streaming scala project and examples mbalassi
  • [17/27] incubator-flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support mbalassi
  • [05/27] incubator-flink git commit: [scala] [streaming] Base functionality added for streaming scala api mbalassi
  • [09/27] incubator-flink git commit: [scala] [streaming] Finished scala StreamExecutionEnvrionment functionality + DataStream sinks + docs mbalassi
  • [22/27] incubator-flink git commit: [streaming] Source parallelism + connector rework mbalassi
  • [13/27] incubator-flink git commit: [streaming] Streaming API grouping rework to use batch api Keys mbalassi
  • [26/27] incubator-flink git commit: [streaming] [scala] Restructured streaming scala project and examples mbalassi
  • [03/27] incubator-flink git commit: [scala] [streaming] Temporal cross operator added mbalassi
  • [04/27] incubator-flink git commit: [scala] [streaming] Modified aggregations to work on scala tuples mbalassi
• [1/2] incubator-flink git commit: [FLINK-1225] Fix for quickstart packaging mbalassi
  • [2/2] incubator-flink git commit: [streaming] Temporal fix for streaming source parallelism mbalassi
• incubator-flink git commit: [FLINK-1338] Updates necessary due to Apache graduation mbalassi
  • incubator-flink git commit: [FLINK-1338] Updates necessary due to Apache graduation mbalassi
• incubator-flink git commit: [streaming] Streaming local execution fix to create proper jobclient for minicluster mbalassi
• [1/5] incubator-flink git commit: [streaming] Make windowed data stream aware of time based trigger/eviction in tumbling window situations. mbalassi
  • [3/5] incubator-flink git commit: [streaming] Added immutability for window and filter operators mbalassi
  • [2/5] incubator-flink git commit: [dist] Updated the assembly of the examples subdirectory mbalassi
  • [5/5] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use mbalassi
  • [4/5] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use mbalassi
• [1/6] incubator-flink git commit: [FLINK-1336] [core] Fix bug in StringValue binary copy method mbalassi
  • [6/6] incubator-flink git commit: [streaming] Make windowed data stream aware of time based trigger/eviction in tumbling window situations. mbalassi
  • [4/6] incubator-flink git commit: [dist] Updated the assembly of the examples subdirectory mbalassi
  • [3/6] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use mbalassi
  • [5/6] incubator-flink git commit: [streaming] Added immutability for window and filter operators mbalassi
  • [2/6] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use mbalassi
• [01/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [32/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [10/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [04/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [65/82] [abbrv] incubator-flink git commit: Add startup timeout config parameter. Increase akka ask timeouts for integration tests. Increase akka logger startup timeout. trohrmann
  • [16/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [20/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [48/82] [abbrv] incubator-flink git commit: Removed blocking call in Execution.deploySlot trohrmann
  • [67/82] [abbrv] incubator-flink git commit: Use container based builds in travis. Enable caching for travis. Set travis fork count to 2. trohrmann
  • [33/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [56/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. trohrmann
  • [37/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [73/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. trohrmann
  • [64/82] [abbrv] incubator-flink git commit: Execute lookupConnectionInformation and UpdateTaskExecutionState concurrently within futures trohrmann
  • [69/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. trohrmann
  • [66/82] [abbrv] incubator-flink git commit: Exclude netty and protobuf dependency from hadoop-commons-2.0.0-alpha trohrmann
  • [27/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [13/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [19/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [63/82] [abbrv] incubator-flink git commit: Add option to use single actor system for local execution. Use local connection manager if a single task manager is used for local execution. Remove synchronized blcok in getReceiverList of ChannelManager which trohrmann
  • [59/82] [abbrv] incubator-flink git commit: Adapted test cases to actor model after rebasing. trohrmann
  • [43/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [57/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. trohrmann
  • [40/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [46/82] [abbrv] incubator-flink git commit: Updated DEPENDENCIES, NOTICE and LICENSE files. trohrmann
  • [12/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [03/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [07/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [11/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [47/82] [abbrv] incubator-flink git commit: Adding timefactor to make up for slow travis tests. trohrmann
  • [21/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [23/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [78/82] [abbrv] incubator-flink git commit: Let the submitJobAndWait method check continuously whether the job manager is still alive. Terminate waiting for a response in case of a job manager outage. trohrmann
  • [77/82] [abbrv] incubator-flink git commit: Use Akka version 2.2.1 for hadoop version 2.0.0-alpha to resolve dependency conflicts. Adjust code to comply to respective Akka API. Remove obsolete TODO. trohrmann
  • [68/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. trohrmann
  • [08/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [31/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [15/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [75/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. trohrmann
  • [28/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [60/82] [abbrv] incubator-flink git commit: Adapted test cases to actor model after rebasing. trohrmann
  • [80/82] [abbrv] incubator-flink git commit: Add proper task resource removal in case that a task submission fails trohrmann
  • [55/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. trohrmann
  • [45/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [39/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [24/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [14/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [51/82] [abbrv] incubator-flink git commit: Add debug guardians to suppress string generation which caused a significant performance loss. trohrmann
  • [53/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. trohrmann
  • [36/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [22/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [44/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [52/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify. trohrmann
  • [81/82] [abbrv] incubator-flink git commit: Fix race condition in ExecutionGraph which made the job finish before all vertices have called the finalizeOnMaster method. trohrmann
  • [58/82] [abbrv] incubator-flink git commit: Reworked local cluster start. TaskManager watches JobManager and tries reregistration in case of disconnect. Introduced akka.ask.timeout config parameter to configure akka timeouts. trohrmann
  • [18/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [29/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. trohrmann
  • [62/82] [abbrv] incubator-flink git commit: Fixed JobManagerITCase to properly wait for task managers to deregister their tasks. Replaced the scheduler's execution service with akka's futures. Introduced TestStreamEnvironment to use ForkableFlinkMiniClus trohrmann
  • [49/82] [abbrv] incubator-flink git commit: Removed dead instance cleanup from InstanceManager so that Akka's watch mechanism is the current mean to detect dead instances. trohrmann
  • [71/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. trohrmann

• Earlier messages