Messages by Date
-
2015/01/08
[1/5] flink git commit: [FLINK-1266] Properly pass the fs.defaulFS setting when initializing filesystems
rmetzger
-
2015/01/08
[5/5] flink git commit: [FLINK-1266] More dependency exclusions & fixed image in web client
rmetzger
-
2015/01/08
[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
-
2015/01/08
[2/5] flink git commit: [FLINK-1266] Update mongodb link and address pull request comments
rmetzger
-
2015/01/08
[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
-
2015/01/08
[1/2] flink git commit: [FLINK-1245] [Java API] Introduce TypeHints for Java API operators
sewen
-
2015/01/08
[2/2] flink git commit: [FLINK-1245] [Java API] Introduce TypeHints for Java API operators
sewen
-
2015/01/08
[2/3] flink git commit: [streaming] Replaced partitionBy with groupBy + re-added global partitioning
mbalassi
-
2015/01/08
[3/3] flink git commit: [streaming] [scala] scala SocketTextStream added and minor fixes
mbalassi
-
2015/01/08
[1/3] flink git commit: [FLINK-1367] [scala] [streaming] Field aggregations added to streaming scala api
mbalassi
-
2015/01/08
flink git commit: [FLINK-1371] [runtime] Fix KryoSerializer to not swallow EOFExceptions
rmetzger
-
2015/01/08
flink git commit: [FLINK-1371] [runtime] Fix KryoSerializer to not swallow EOFExceptions
sewen
-
2015/01/08
[10/13] flink git commit: [FLINK-1285] Make execution mode configurable
sewen
-
2015/01/08
[07/13] flink git commit: [FLINK-1285] Make execution mode configurable
sewen
-
2015/01/08
[01/13] flink git commit: [FLINK-1285] Make Merge-Join aware of object-reuse setting
sewen
-
2015/01/08
[08/13] flink git commit: [FLINK-1285] Make execution mode configurable
sewen
-
2015/01/08
[09/13] flink git commit: [FLINK-1285] Make execution mode configurable
sewen
-
2015/01/08
[06/13] flink git commit: [FLINK-1285] Make execution mode configurable
sewen
-
2015/01/08
[02/13] flink git commit: [FLINK-1285] Make Merge-Join aware of object-reuse setting
sewen
-
2015/01/08
[13/13] flink git commit: [runtime] Release additional broadcast variable references early
sewen
-
2015/01/08
[11/13] flink git commit: [FLINK-1137] Enhance MutableObjectIterator with non-reuse next()
sewen
-
2015/01/08
[03/13] flink git commit: [FLINK-1285] Make execution mode configurable
sewen
-
2015/01/08
[05/13] flink git commit: [FLINK-1285] Make execution mode configurable
sewen
-
2015/01/08
[12/13] flink git commit: [FLINK-1285] Various cleanup of object reusing and non-reusing code.
sewen
-
2015/01/08
[04/13] flink git commit: [FLINK-1285] Make execution mode configurable
sewen
-
2015/01/07
[2/2] flink git commit: [FLINK-1354] Made test graph for TransitiveClosureITCase smaller
sewen
-
2015/01/07
[1/2] flink git commit: [FLINK-1361] change jobManager log file name back to old value
sewen
-
2015/01/07
flink git commit: Commit for release 0.8.0
mbalassi
-
2015/01/07
[2/2] flink git commit: [FLINK-1366] Enable FastPath in TextValueInputFormat again
aljoscha
-
2015/01/07
[1/2] flink git commit: [FLINK-1365] Fix ValueTypeInfo
aljoscha
-
2015/01/07
[09/36] flink git commit: [scala] [streaming] Temporal join operator added
mbalassi
-
2015/01/07
[29/36] flink git commit: [streaming] Temporal operator windowing syntax update
mbalassi
-
2015/01/07
[36/36] flink git commit: [streaming] Replaced partitionBy with groupBy + re-added global partitioning
mbalassi
-
2015/01/07
[17/36] flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support
mbalassi
-
2015/01/07
[25/36] flink git commit: [streaming] [scala] Restructured streaming scala project and examples
mbalassi
-
2015/01/07
[12/36] flink git commit: [scala] [streaming] Fixed scala formatting
mbalassi
-
2015/01/07
[13/36] flink git commit: [scala] [streaming] Added groupBy support for case class fields
mbalassi
-
2015/01/07
[18/36] flink git commit: [scala] [streaming] Added implicit conversions from java to scala streams
mbalassi
-
2015/01/07
[22/36] flink git commit: [streaming] Source parallelism + connector rework
mbalassi
-
2015/01/07
[20/36] flink git commit: [scala] [streaming] added initial ConnectedDataStream support (no windowing, batching) for the scala api
mbalassi
-
2015/01/07
[34/36] flink git commit: [scala] [streaming] added scala streams as sources in streaming-api scala examples
mbalassi
-
2015/01/07
[05/36] flink git commit: [scala] [streaming] Windowing functionality added to scala api
mbalassi
-
2015/01/07
[32/36] flink git commit: [streaming] Updated streaming guide for recent connector and data source changes
mbalassi
-
2015/01/07
[07/36] flink git commit: [scala] [streaming] Added support for iterative streams for scala api
mbalassi
-
2015/01/07
[26/36] flink git commit: [streaming] [scala] Restructured streaming scala project and examples
mbalassi
-
2015/01/07
[06/36] flink git commit: [scala] [streaming] Added SplitDataStream functionality
mbalassi
-
2015/01/07
[16/36] flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support
mbalassi
-
2015/01/07
[24/36] flink git commit: [streaming] [scala] Restructured streaming scala project and examples
mbalassi
-
2015/01/07
[21/36] flink git commit: [scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams
mbalassi
-
2015/01/07
[01/36] flink git commit: [streaming] Time trigger preNotify fix
mbalassi
-
2015/01/07
[27/36] flink git commit: [docs] Trivial typo in example code: o -> out.
mbalassi
-
2015/01/07
[14/36] flink git commit: [scala] [streaming] WindowJoin scala example added
mbalassi
-
2015/01/07
[31/36] flink git commit: [streaming] Deleted obsolete parts of the connected stream api
mbalassi
-
2015/01/07
[35/36] flink git commit: [streaming] [scala] scala SocketTextStream added and minor fixes
mbalassi
-
2015/01/07
[23/36] flink git commit: [streaming] Updated connector type handling to suport generic classes by GenericSourceFunction interface
mbalassi
-
2015/01/07
[08/36] flink git commit: [streaming] Temporal join and cross rework for consistence and extended features
mbalassi
-
2015/01/07
[33/36] flink git commit: [scala] [streaming] Added package file for streaming scala api typeinfo implicits and conversions
mbalassi
-
2015/01/07
[15/36] flink git commit: [streaming] Streaming API grouping rework to use batch api Keys
mbalassi
-
2015/01/07
[28/36] flink git commit: [docs] Remove files from obolete and unused figures
mbalassi
-
2015/01/07
[02/36] flink git commit: [scala] [streaming] Base functionality added for streaming scala api
mbalassi
-
2015/01/07
[04/36] flink git commit: [scala] [streaming] Finished scala StreamExecutionEnvrionment functionality + DataStream sinks + docs
mbalassi
-
2015/01/07
[10/36] flink git commit: [scala] [streaming] Temporal cross operator added
mbalassi
-
2015/01/07
[11/36] flink git commit: [scala] [streaming] Modified aggregations to work on scala tuples
mbalassi
-
2015/01/07
[03/36] flink git commit: [scala] [streaming] Extended scala data stream functionality to include simple operators
mbalassi
-
2015/01/07
[30/36] flink git commit: [FLINK-1338] [docs] Remove incubator footer from docs
mbalassi
-
2015/01/07
[19/36] flink git commit: [scala] [streaming] added group windowing example with different policy types
mbalassi
-
2015/01/07
flink git commit: [FLINK-1363] [runtime tests] Fix race condition in ExecutionVertexCancelTest.testSendCancelAndReceiveFail
trohrmann
-
2015/01/07
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
-
2015/01/06
svn commit: r1649923 - in /flink/site: doap_flink.rdf index.html
rmetzger
-
2015/01/06
svn commit: r1649922 - /flink/doap_flink.rdf
rmetzger
-
2015/01/06
svn commit: r1649876 - /incubator/flink/
coreyg
-
2015/01/06
svn commit: r1649876 - /flink/
coreyg
-
2015/01/06
[3/3] incubator-flink git commit: [FLINK-1300] [core] Remove unused and redundant files DataInputViewStream and DataOutputViewStream.
sewen
-
2015/01/06
[2/3] incubator-flink git commit: [FLINK-1259] [apis] Added comments to interface and docs that filters must not mutate date elements.
sewen
-
2015/01/06
[1/3] incubator-flink git commit: [FLINK-1169] [apis] Add documentation for join hints.
sewen
-
2015/01/06
[5/5] incubator-flink git commit: [streaming] Deleted obsolete parts of the connected stream api
mbalassi
-
2015/01/06
[2/5] incubator-flink git commit: [streaming] Updated streaming guide for recent connector and data source changes
mbalassi
-
2015/01/06
[3/5] incubator-flink git commit: [streaming] Temporal operator windowing syntax update
mbalassi
-
2015/01/06
[1/5] incubator-flink git commit: [scala] [streaming] added scala streams as sources in streaming-api scala examples
mbalassi
-
2015/01/06
[4/5] incubator-flink git commit: [scala] [streaming] Added package file for streaming scala api typeinfo implicits and conversions
mbalassi
-
2015/01/06
[1/3] incubator-flink git commit: [FLINK-1357] [compiler] Add union between static and dynamic path
sewen
-
2015/01/06
[3/3] incubator-flink git commit: [FLINK-1236] [hadoop compatibility] Add local split assignment support for HadoopInputFormats
sewen
-
2015/01/06
[2/3] incubator-flink git commit: [FLINK-1027] [cli] Added support for '--' and '-' prefixed tokens in CLI program arguments.
sewen
-
2015/01/06
incubator-flink git commit: [FLINK-1335] [docs] Minor fix to README file
sewen
-
2015/01/06
[4/4] incubator-flink git commit: [FLINK-1335] [docs] Add guide how to set up Eclipse, and bring README.md up to speed.
sewen
-
2015/01/06
[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
-
2015/01/06
[1/4] incubator-flink git commit: [FLINK-1349] [runtime] Various cleanups to make scala runtime code interact smoother with java
sewen
-
2015/01/06
[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
-
2015/01/05
incubator-flink git commit: Remove full package name for FlatMapOperatorBase
hsaputra
-
2015/01/05
[4/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling.
sewen
-
2015/01/05
[5/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling.
sewen
-
2015/01/05
[6/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling.
sewen
-
2015/01/05
[3/8] incubator-flink git commit: [FLINK-1346] [docs] Add stubs for Akka documentation
sewen
-
2015/01/05
[7/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling.
sewen
-
2015/01/05
[8/8] incubator-flink git commit: [FLINK-1335] [docs] Update internals with brief description about JobManager data structures and scheduling.
sewen
-
2015/01/05
[1/8] incubator-flink git commit: [docs] Remove files from obolete and unused figures
sewen
-
2015/01/05
[2/8] incubator-flink git commit: [FLINK-1338] [docs] Remove incubator footer from docs
sewen
-
2015/01/04
[04/27] incubator-flink git commit: [scala] [streaming] Modified aggregations to work on scala tuples
mbalassi
-
2015/01/04
[03/27] incubator-flink git commit: [scala] [streaming] Temporal cross operator added
mbalassi
-
2015/01/04
[26/27] incubator-flink git commit: [streaming] [scala] Restructured streaming scala project and examples
mbalassi
-
2015/01/04
[13/27] incubator-flink git commit: [streaming] Streaming API grouping rework to use batch api Keys
mbalassi
-
2015/01/04
[22/27] incubator-flink git commit: [streaming] Source parallelism + connector rework
mbalassi
-
2015/01/04
[09/27] incubator-flink git commit: [scala] [streaming] Finished scala StreamExecutionEnvrionment functionality + DataStream sinks + docs
mbalassi
-
2015/01/04
[05/27] incubator-flink git commit: [scala] [streaming] Base functionality added for streaming scala api
mbalassi
-
2015/01/04
[17/27] incubator-flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support
mbalassi
-
2015/01/04
[25/27] incubator-flink git commit: [streaming] [scala] Restructured streaming scala project and examples
mbalassi
-
2015/01/04
[18/27] incubator-flink git commit: [scala] [streaming] Added implicit conversions from java to scala streams
mbalassi
-
2015/01/04
[02/27] incubator-flink git commit: [scala] [streaming] Fixed scala formatting
mbalassi
-
2015/01/04
[06/27] incubator-flink git commit: [scala] [streaming] Temporal join operator added
mbalassi
-
2015/01/04
[23/27] incubator-flink git commit: [streaming] Updated connector type handling to suport generic classes by GenericSourceFunction interface
mbalassi
-
2015/01/04
[11/27] incubator-flink git commit: [streaming] Temporal join and cross rework for consistence and extended features
mbalassi
-
2015/01/04
[21/27] incubator-flink git commit: [scala] [streaming] Added connect op to DataStream and implicit conversion for ConnectedDataStreams
mbalassi
-
2015/01/04
[24/27] incubator-flink git commit: [streaming] [scala] Restructured streaming scala project and examples
mbalassi
-
2015/01/04
[07/27] incubator-flink git commit: [scala] [streaming] Windowing functionality added to scala api
mbalassi
-
2015/01/04
[14/27] incubator-flink git commit: [scala] [streaming] Added groupBy support for case class fields
mbalassi
-
2015/01/04
[27/27] incubator-flink git commit: [docs] Trivial typo in example code: o -> out.
mbalassi
-
2015/01/04
[08/27] incubator-flink git commit: [scala] [streaming] Extended scala data stream functionality to include simple operators
mbalassi
-
2015/01/04
[20/27] incubator-flink git commit: [scala] [streaming] added initial ConnectedDataStream support (no windowing, batching) for the scala api
mbalassi
-
2015/01/04
[12/27] incubator-flink git commit: [scala] [streaming] Added support for iterative streams for scala api
mbalassi
-
2015/01/04
[15/27] incubator-flink git commit: [scala] [streaming] WindowJoin scala example added
mbalassi
-
2015/01/04
[01/27] incubator-flink git commit: [streaming] Time trigger preNotify fix
mbalassi
-
2015/01/04
[19/27] incubator-flink git commit: [scala] [streaming] added group windowing example with different policy types
mbalassi
-
2015/01/04
[10/27] incubator-flink git commit: [scala] [streaming] Added SplitDataStream functionality
mbalassi
-
2015/01/04
[16/27] incubator-flink git commit: [scala] [streaming] Added scala window helpers + timestamp rework for lambda support
mbalassi
-
2014/12/26
[1/2] incubator-flink git commit: [FLINK-1225] Fix for quickstart packaging
mbalassi
-
2014/12/26
[2/2] incubator-flink git commit: [streaming] Temporal fix for streaming source parallelism
mbalassi
-
2014/12/20
incubator-flink git commit: [FLINK-1338] Updates necessary due to Apache graduation
mbalassi
-
2014/12/20
incubator-flink git commit: [FLINK-1338] Updates necessary due to Apache graduation
mbalassi
-
2014/12/19
incubator-flink git commit: [streaming] Streaming local execution fix to create proper jobclient for minicluster
mbalassi
-
2014/12/18
[4/5] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use
mbalassi
-
2014/12/18
[5/5] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use
mbalassi
-
2014/12/18
[2/5] incubator-flink git commit: [dist] Updated the assembly of the examples subdirectory
mbalassi
-
2014/12/18
[3/5] incubator-flink git commit: [streaming] Added immutability for window and filter operators
mbalassi
-
2014/12/18
[1/5] incubator-flink git commit: [streaming] Make windowed data stream aware of time based trigger/eviction in tumbling window situations.
mbalassi
-
2014/12/18
[1/6] incubator-flink git commit: [FLINK-1336] [core] Fix bug in StringValue binary copy method
mbalassi
-
2014/12/18
[2/6] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use
mbalassi
-
2014/12/18
[5/6] incubator-flink git commit: [streaming] Added immutability for window and filter operators
mbalassi
-
2014/12/18
[3/6] incubator-flink git commit: [streaming] StreamInvokable rework for simpler logic and easier use
mbalassi
-
2014/12/18
[4/6] incubator-flink git commit: [dist] Updated the assembly of the examples subdirectory
mbalassi
-
2014/12/18
[6/6] incubator-flink git commit: [streaming] Make windowed data stream aware of time based trigger/eviction in tumbling window situations.
mbalassi
-
2014/12/18
[41/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
-
2014/12/18
[34/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
-
2014/12/18
[72/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time.
trohrmann
-
2014/12/18
[06/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
-
2014/12/18
[61/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
-
2014/12/18
[79/82] [abbrv] incubator-flink git commit: Exclude netty dependency from hadoop-mapreduce-client-core to resolve dependency conflict
trohrmann
-
2014/12/18
[42/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
-
2014/12/18
[76/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time.
trohrmann
-
2014/12/18
[70/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time.
trohrmann
-
2014/12/18
[38/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
-
2014/12/18
[54/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify.
trohrmann
-
2014/12/18
[30/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
-
2014/12/18
[50/82] [abbrv] incubator-flink git commit: Made ExecutionGraph, Execution, ExecutionJobVertex, ExecutionVertex, AllocatedSlot, Instance, CoLocationConstraint, SharedSlot and SlotSharingGroupAssignment serializable. Integrated Kryo to be used to serializ
trohrmann
-
2014/12/18
[26/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
-
2014/12/18
[35/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
-
2014/12/18
[17/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
-
2014/12/18
[09/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
-
2014/12/18
[74/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time.
trohrmann
-
2014/12/18
[05/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
-
2014/12/18
[02/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
-
2014/12/18
[82/82] [abbrv] incubator-flink git commit: Remove experimental KryoSerialization for Akka
trohrmann
-
2014/12/18
[25/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
-
2014/12/18
[71/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time.
trohrmann
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[52/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify.
trohrmann
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[53/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify.
trohrmann
-
2014/12/18
[51/82] [abbrv] incubator-flink git commit: Add debug guardians to suppress string generation which caused a significant performance loss.
trohrmann
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[55/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify.
trohrmann
-
2014/12/18
[80/82] [abbrv] incubator-flink git commit: Add proper task resource removal in case that a task submission fails
trohrmann
-
2014/12/18
[60/82] [abbrv] incubator-flink git commit: Adapted test cases to actor model after rebasing.
trohrmann
-
2014/12/18
[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
-
2014/12/18
[75/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time.
trohrmann
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[68/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time.
trohrmann
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[47/82] [abbrv] incubator-flink git commit: Adding timefactor to make up for slow travis tests.
trohrmann
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[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
-
2014/12/18
[46/82] [abbrv] incubator-flink git commit: Updated DEPENDENCIES, NOTICE and LICENSE files.
trohrmann
-
2014/12/18
[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
-
2014/12/18
[57/82] [abbrv] incubator-flink git commit: Removed JobStatusListener and ExecutionListener. Fixed LocalExecutor output for maven verify.
trohrmann