commits@flink.apache.org, 2015-08

You are viewing a plain text version of this content. The canonical link for it is here.

- [1/8] flink git commit: [FLINK-2461] [tests] Guard tests that rely on unresolvable host names with the appropriate assumption. - posted by se...@apache.org on 2015/08/02 17:14:29 UTC, 0 replies.
- [2/8] flink git commit: [hotfix] Fix SourceStreamTaskTest to switch source to running before checkpointing - posted by se...@apache.org on 2015/08/02 17:14:30 UTC, 0 replies.
- [3/8] flink git commit: [runtime] Cleanup channel events. Add comments and move some classes to test scope. - posted by se...@apache.org on 2015/08/02 17:14:31 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-2438] [runtime] Improve channel event serialization performance. - posted by se...@apache.org on 2015/08/02 17:14:32 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-2438] [runtime] Improve channel event serialization performance. - posted by se...@apache.org on 2015/08/02 17:14:33 UTC, 0 replies.
- [6/8] flink git commit: [hotfix] [streaming] Fix race in stream tasks when canceling tasks early. - posted by se...@apache.org on 2015/08/02 17:14:34 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-2427] [streaming] Make the BarrierBuffer more robust against lost/missing checkpoint barriers. - posted by se...@apache.org on 2015/08/02 17:14:35 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-2427] [streaming] Make the BarrierBuffer more robust against lost/missing checkpoint barriers. - posted by se...@apache.org on 2015/08/02 17:14:36 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-2459] [cli] Cli API and doc fixes. - posted by se...@apache.org on 2015/08/02 20:38:35 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-2463] [web dashboard] Shows job configuration in new dashboard - posted by se...@apache.org on 2015/08/02 20:38:36 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-2463] [web dashboard] Shows job configuration in new dashboard - posted by se...@apache.org on 2015/08/02 20:38:37 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-2463] [web dashboard] Shows job configuration in new dashboard - posted by se...@apache.org on 2015/08/02 20:38:38 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-2434] [pom] Fix pattern for exclusion of org.apache.hadoop:hadoop-yarn-common:jersey-test-framework-grizzly2 - posted by se...@apache.org on 2015/08/02 20:38:39 UTC, 0 replies.
- flink git commit: [FLINK-2436] [streaming] Make ByteStreamStateHandles more robust - posted by gy...@apache.org on 2015/08/02 21:14:46 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2433] [docs] Add script to build local documentation on windows - posted by se...@apache.org on 2015/08/03 00:55:42 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2464][tests] Add logging to BufferSpillerTest to help debug spurious failures. - posted by se...@apache.org on 2015/08/03 00:55:43 UTC, 0 replies.
- buildbot failure in ASF Buildbot on flink-docs-release-0.9 - posted by bu...@apache.org on 2015/08/03 03:00:02 UTC, 2 replies.
- flink git commit: Revert API-breaking change: "[FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable)" - posted by fh...@apache.org on 2015/08/03 12:06:56 UTC, 0 replies.
- flink git commit: [FLINK-2409] [webserver] Replaces ActorRefs with ActorGateways in the web server to automatically decorate messages with a leader session ID. - posted by tr...@apache.org on 2015/08/03 14:59:02 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-2426] [core] Cleanup/improve unmodifiable configuration. - posted by se...@apache.org on 2015/08/03 20:50:21 UTC, 0 replies.
- [2/8] flink git commit: [hotfix] Remove unused (and broken) TraversableOnceIterable. - posted by se...@apache.org on 2015/08/03 20:50:22 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-2465] [streaming] SocketClientSink closes connection early - posted by se...@apache.org on 2015/08/03 20:50:23 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-2425] [FLINK-2426] [runtime] Add an unmodifiable config and provide access to task manager configuration and hostname inside RuntimeEnvironment - posted by se...@apache.org on 2015/08/03 20:50:24 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-2322] [streaming] Close file streams to release resources early. - posted by se...@apache.org on 2015/08/03 20:50:25 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-2425] [runtime] Cleanup code for forwarding config and hostname into TaskManager's RuntimeEnvironment - posted by se...@apache.org on 2015/08/03 20:50:26 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-2473] [core] Add a timeout to akka actorsystem shutdown. - posted by se...@apache.org on 2015/08/03 20:50:27 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-2464] [tests] Change log level of BufferSpillerTest to "info" to let statements occur in CI logs. - posted by se...@apache.org on 2015/08/03 20:50:28 UTC, 0 replies.
- flink git commit: [FLINK-2456] [hbase] Add a repository ID for hadoop2 in flink-hbase module - posted by se...@apache.org on 2015/08/03 22:37:06 UTC, 0 replies.
- flink git commit: [FLINK-2095][docs] Added missing screenshots to webclient documentation - posted by fh...@apache.org on 2015/08/04 00:28:42 UTC, 0 replies.
- flink git commit: [FLINK-2422] [web client] Added explicit link in case browser is not redirecting properly - posted by fh...@apache.org on 2015/08/04 00:44:45 UTC, 1 replies.
- buildbot failure in ASF Buildbot on flink-docs-master - posted by bu...@apache.org on 2015/08/04 02:00:03 UTC, 1 replies.
- buildbot success in ASF Buildbot on flink-docs-release-0.9 - posted by bu...@apache.org on 2015/08/04 03:19:49 UTC, 4 replies.
- flink git commit: [docs] Fixes broken link in FlinkML docs - posted by tr...@apache.org on 2015/08/04 09:42:07 UTC, 0 replies.
- flink git commit: Remove unwanted check null of input1 in ConnectedDataStream - posted by gy...@apache.org on 2015/08/04 10:13:22 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-2005] Remove Record API from jdbc module - posted by fh...@apache.org on 2015/08/04 20:59:59 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2205] Fix confusing entries in JobManager WebUI JobConfig section. - posted by fh...@apache.org on 2015/08/04 21:00:00 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2442] [fix] FieldPositionKeys support Pojo fields - posted by fh...@apache.org on 2015/08/04 21:00:01 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2205] Fix confusing entries in JobManager WebUI JobConfig section. - posted by fh...@apache.org on 2015/08/04 21:10:59 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2442] [fix] FieldPositionKeys support Pojo fields - posted by fh...@apache.org on 2015/08/04 21:11:00 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-2105] Extract abstract superclass, interface from MergeMatchIterators, KeyGroupedIterators - posted by fh...@apache.org on 2015/08/05 00:41:06 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-2105] Add support for sorted but sparse test data generation - posted by fh...@apache.org on 2015/08/05 00:41:07 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-2105] [tests] Move duplicate utility classes to testutil package - posted by fh...@apache.org on 2015/08/05 00:41:08 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-2105] [tests] Move duplicate utility classes to testutil package - posted by fh...@apache.org on 2015/08/05 00:41:09 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-2105] Implement Sort-Merge Outer Join algorithm - posted by fh...@apache.org on 2015/08/05 00:41:10 UTC, 0 replies.
- buildbot success in ASF Buildbot on flink-docs-master - posted by bu...@apache.org on 2015/08/05 02:21:30 UTC, 3 replies.
- [1/4] flink git commit: [FLINK-2447] [java api] TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type - posted by fh...@apache.org on 2015/08/05 16:24:35 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-1882] Removed RemotedCollector classes - posted by fh...@apache.org on 2015/08/05 16:24:36 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-1680] Remove Tachyon test and rename Maven module to "flink-fs-tests" - posted by fh...@apache.org on 2015/08/05 16:24:37 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-2467] Example WordCountStorm.jar is not packaged correctly - fixed assembly xml file - posted by fh...@apache.org on 2015/08/05 16:24:38 UTC, 0 replies.
- flink git commit: [FLINK-2447] [java api] TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type - posted by fh...@apache.org on 2015/08/05 16:48:27 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2484] [streaming] BarrierBuffer releases temp files properly. - posted by se...@apache.org on 2015/08/05 20:20:15 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2464] [tests] Make buffer spilling test robust to Java 6. - posted by se...@apache.org on 2015/08/05 20:20:16 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] Remove unused and outdated HashFunctionCollisionBenchmark - posted by se...@apache.org on 2015/08/05 22:06:16 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1916] [FLINK-2361] [runtime] Fix EOFException and entry loss in CompactingHashTable - posted by se...@apache.org on 2015/08/05 22:06:17 UTC, 0 replies.
- flink git commit: [FLINK-1916] [FLINK-2361] [runtime] Fix EOFException and entry loss in CompactingHashTable - posted by se...@apache.org on 2015/08/05 22:16:24 UTC, 0 replies.
- buildbot exception in ASF Buildbot on flink-docs-master - posted by bu...@apache.org on 2015/08/06 02:00:00 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-2453] [pom] Move Java source and target version to 1.7 - posted by se...@apache.org on 2015/08/06 16:23:31 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2454] [buikd] Update Travis to drop JDK6 for tests - posted by se...@apache.org on 2015/08/06 16:23:32 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-2492] [runtime] Rename former 'match' classes to 'join' to reflect consistent naming scheme. - posted by se...@apache.org on 2015/08/06 18:52:15 UTC, 0 replies.
- [2/5] flink git commit: [hotfix] Increase timeout for YARN tests to 180 seconds to prevent occasional CI failures. - posted by se...@apache.org on 2015/08/06 18:52:16 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-2240] Add bloom filter to filter probe records during hash join. - posted by se...@apache.org on 2015/08/06 18:52:17 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-2240] [runtime] Pass flag to configure use of bloom filters through runtime configuration. - posted by se...@apache.org on 2015/08/06 18:52:18 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-2240] [runtime] Pass flag to configure use of bloom filters through runtime configuration. - posted by se...@apache.org on 2015/08/06 18:52:19 UTC, 0 replies.
- flink git commit: [hotfix] Fix TEZ task contect to reflect updated interface. - posted by se...@apache.org on 2015/08/06 19:36:31 UTC, 0 replies.
- flink git commit: [FLINK-2452] [Gelly] adds a playcount threshold to the MusicProfiles example - posted by va...@apache.org on 2015/08/07 11:59:44 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2243] [storm-compat] Demonstrating finite Storm spout functionality on exclamation example -minor renaming -improving JavaDocs - posted by mb...@apache.org on 2015/08/07 14:51:02 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2243] [storm-compat] Added finite spout functionality to Storm compatibility layer - posted by mb...@apache.org on 2015/08/07 14:51:03 UTC, 0 replies.
- buildbot exception in ASF Buildbot on flink-docs-release-0.9 - posted by bu...@apache.org on 2015/08/10 03:00:00 UTC, 4 replies.
- flink-web git commit: [FLINK-2365] Improves How to contribute page - posted by mx...@apache.org on 2015/08/10 08:59:45 UTC, 0 replies.
- flink-web git commit: correct role in committer table - posted by mx...@apache.org on 2015/08/10 09:08:39 UTC, 0 replies.
- flink-web git commit: regenerate website files - posted by mx...@apache.org on 2015/08/10 09:18:29 UTC, 0 replies.
- flink git commit: [FLINK-2387] add streaming test case for live accumulators - posted by mx...@apache.org on 2015/08/10 15:50:13 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2453] [docs] Update README and setup docs to reflect requirement for Java 7+ - posted by se...@apache.org on 2015/08/10 16:37:28 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-705] [license] Add license reference for TPC-H sample data in tests. - posted by se...@apache.org on 2015/08/10 16:37:29 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-1177] [docs] Mark HDFS setup instructions as option in cluster setup docs - posted by se...@apache.org on 2015/08/10 16:37:30 UTC, 0 replies.
- [4/4] flink git commit: [hotfix] Fix repository language statistics by adjusting .gitattributes - posted by se...@apache.org on 2015/08/10 16:37:31 UTC, 0 replies.
- flink git commit: [FLINK-2498] [tests] Clean up GroupReduceITCase and make it more robust by avoiding temp files - posted by se...@apache.org on 2015/08/10 20:48:07 UTC, 0 replies.
- flink git commit: [FLINK-2483] [runtime] Add default branch of switch(scheduleMode) in scheduleForExecution function - posted by se...@apache.org on 2015/08/10 21:33:29 UTC, 0 replies.
- flink git commit: [travis tools] Adds $HOME/bin/artifacts to $PATH of watchdog script - posted by tr...@apache.org on 2015/08/11 11:08:21 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2357] [web dashboard] Update Node.js installation instructions - posted by se...@apache.org on 2015/08/11 13:14:19 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2502] [storm compatibility] Fix FiniteStormSpout documenation rendering - added missing empty lines - additional minor improvements - posted by se...@apache.org on 2015/08/11 13:14:20 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-2500] [streaming] Code cleanup in DataStream - posted by se...@apache.org on 2015/08/11 13:14:21 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-2277] [scala api] Add flag to set delta iteration solution set to unmanaged - posted by se...@apache.org on 2015/08/11 13:14:22 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2423] [streaming] ITCase for checkpoint notifications - posted by mb...@apache.org on 2015/08/11 15:53:35 UTC, 0 replies.
- [2/2] flink git commit: [streaming] [tests] Checkpointing tests refactor & cleanup - posted by mb...@apache.org on 2015/08/11 15:53:36 UTC, 0 replies.
- flink git commit: [FLINK-2511] [runtime] Make sure to close FileInputStream in FlinkZooKeeperQuorumPeer - posted by uc...@apache.org on 2015/08/11 22:44:57 UTC, 0 replies.
- flink git commit: [FLINK-2509] [runtime] Add class loader info into the exception message when user code classes are not found. - posted by se...@apache.org on 2015/08/12 10:06:02 UTC, 0 replies.
- flink git commit: [FLINK-2507] [storm-compat] Rename the function tansformAndEmit - posted by mb...@apache.org on 2015/08/12 11:33:26 UTC, 0 replies.
- flink git commit: [FLINK-2437] handle the case of a non-public default ctor in TypeExtractor.analyzePojo - posted by mx...@apache.org on 2015/08/12 12:29:31 UTC, 1 replies.
- flink git commit: [hotfix] read from old and new parallelism config key - posted by mx...@apache.org on 2015/08/12 18:50:24 UTC, 1 replies.
- flink git commit: [CLEANUP] Add space between quotes and plus sign in String concat for readability in flink-yarn module - posted by hs...@apache.org on 2015/08/12 22:47:02 UTC, 0 replies.
- flink git commit: [FLINK-1819][core] allow access to RuntimeContext from Input and OutputFormats - posted by mx...@apache.org on 2015/08/13 15:45:32 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2509] [hotfix] Address pull request comments for ClassLoaderUtils - posted by se...@apache.org on 2015/08/14 13:26:09 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2515] [job manager] Checkpoint coordinator triggers checkpoints only when tasks are running. - posted by se...@apache.org on 2015/08/14 13:26:10 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-2519] [streaming] Make checkpoint alignment aware of finished partitions. - posted by se...@apache.org on 2015/08/14 13:26:11 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-2517] [docs] Minor fix to streaming guide - posted by se...@apache.org on 2015/08/14 13:26:12 UTC, 0 replies.
- flink git commit: [FLINK-2393] [docs] Updates docs to describe switch between exactly-once and at-least-once - posted by se...@apache.org on 2015/08/14 16:59:48 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2523] [taskmanager] Increase interrupt timeout in TaskManager task. - posted by se...@apache.org on 2015/08/14 20:37:59 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2457] [core] Integrate Tuple0 - extended TupleType helper classes to handle Tuple0 - extended TupleSerializer to handle Tuple0 - included Tuple0 into JUnit tests - simplified Receiver.createTuple(int) - posted by se...@apache.org on 2015/08/14 20:38:00 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-2457] [core] Slight adjustedments to Tuple0 singleton names to match naming scheme. - posted by se...@apache.org on 2015/08/14 20:38:01 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-2431] [python] Refactor PlanBinder/OperationInfo - posted by se...@apache.org on 2015/08/14 20:38:02 UTC, 0 replies.
- flink git commit: [FLINK-2512] [storm compatibility] Make sure client is properly closed in FlinkSubmitter - posted by se...@apache.org on 2015/08/15 20:31:03 UTC, 0 replies.
- [1/3] flink git commit: [docs] Fix some errors in programming_guide.md - posted by se...@apache.org on 2015/08/16 19:44:35 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2487] [ml] In cosine distance, check that datapoints are of same cardinality - posted by se...@apache.org on 2015/08/16 19:44:36 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2458] [FLINK-2449] [runtime] Access distributed cache entries from Iteration contexts & use of distributed cache from Collection Environments - posted by se...@apache.org on 2015/08/16 19:44:37 UTC, 0 replies.
- flink git commit: [tests] Make timeout discarding checks in CheckpointCoordinatorTest more robust. - posted by se...@apache.org on 2015/08/17 00:06:17 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-2527] [gelly] Ensure that VertexUpdateFunction.setNewVertexValue is called at most once per updateVertex - posted by se...@apache.org on 2015/08/17 14:14:49 UTC, 0 replies.
- [2/6] flink git commit: [docs] Minor addition to the cluster execution docs. - posted by se...@apache.org on 2015/08/17 14:14:50 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-2534] [runtime] Some improvements in CompactingHashTable - posted by se...@apache.org on 2015/08/17 14:14:51 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-2462] [streaming] Major cleanup of operator structure for exception handling and code simplication - posted by se...@apache.org on 2015/08/17 14:14:52 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-2462] [streaming] Major cleanup of operator structure for exception handling and code simplication - posted by se...@apache.org on 2015/08/17 14:14:53 UTC, 0 replies.
- [6/6] flink git commit: [tests] Reinforce StateCheckpoinedITCase to make sure actual checkpointing has happened before a failure. - posted by se...@apache.org on 2015/08/17 14:14:54 UTC, 0 replies.
- flink git commit: [FLINK-2527] [gelly] Ensure that VertexUpdateFunction.setNewVertexValue is called at most once per updateVertex - posted by se...@apache.org on 2015/08/17 14:18:47 UTC, 0 replies.
- flink git commit: [FLINK-2521] [tests] Adds TestLogger class which automatically logs the currently executed test names and the reasons for a failure. - posted by tr...@apache.org on 2015/08/18 13:35:26 UTC, 0 replies.
- [1/3] flink git commit: [flink-2532] [streaming] fix variable name in StreamWindow - posted by mb...@apache.org on 2015/08/18 15:35:43 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2286] [streaming] ITCase for ParallelMerge behavior - posted by mb...@apache.org on 2015/08/18 15:35:44 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2286] [streaming] Wrapped ParallelMerge into stream operator - posted by mb...@apache.org on 2015/08/18 15:35:45 UTC, 0 replies.
- flink git commit: [tests] Hardens TaskManagerRegistrationTest.testTaskManagerResumesConnectAfterJobManagerFailure test case by checking testing actor's complete mailbox for a Terminated message - posted by tr...@apache.org on 2015/08/18 16:36:41 UTC, 0 replies.
- [1/7] flink git commit: [tests] Minor cleanup removing duplicate mock invokables in various tests. - posted by se...@apache.org on 2015/08/18 16:38:15 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-1962] Add Gelly Scala API - posted by se...@apache.org on 2015/08/18 16:38:16 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-1962] Add Gelly Scala API - posted by se...@apache.org on 2015/08/18 16:38:17 UTC, 0 replies.
- [4/7] flink git commit: [tests] Rename 'compiler' tests to 'optimizer' tests for consistent naming - posted by se...@apache.org on 2015/08/18 16:38:18 UTC, 0 replies.
- [5/7] flink git commit: [tests] Rename 'compiler' tests to 'optimizer' tests for consistent naming - posted by se...@apache.org on 2015/08/18 16:38:19 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-2529] [runtime] Remove some unused code in Execution - posted by se...@apache.org on 2015/08/18 16:38:20 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-2477] [streaming] Add tests for SocketClientSink - posted by se...@apache.org on 2015/08/18 16:38:21 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2286] [streaming] Wrapped ParallelMerge into stream operator - posted by mb...@apache.org on 2015/08/19 15:36:06 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2286] [streaming] ITCase for ParallelMerge behavior - posted by mb...@apache.org on 2015/08/19 15:36:07 UTC, 0 replies.
- flink git commit: [tests] Replaces Scala mixins for the Job/TaskManager with classes which extend the respective classes. Adds proper logger registration for sub-classes of FlinkUntypedActor. - posted by tr...@apache.org on 2015/08/19 17:33:40 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator - posted by al...@apache.org on 2015/08/19 18:42:10 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator - posted by al...@apache.org on 2015/08/19 18:42:11 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator - posted by al...@apache.org on 2015/08/19 18:42:12 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator - posted by al...@apache.org on 2015/08/19 18:42:13 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator - posted by al...@apache.org on 2015/08/19 18:42:14 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator - posted by al...@apache.org on 2015/08/19 18:42:15 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] Some Java 7 cleanups in InstantiationUtil - posted by se...@apache.org on 2015/08/21 13:35:42 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2540] [optimizer] [runtime] Propagate union batch exchanges to union inputs - posted by se...@apache.org on 2015/08/21 13:35:43 UTC, 0 replies.
- flink git commit: [FLINK-1901] [core] Create sample operator for Dataset. - posted by tr...@apache.org on 2015/08/21 15:41:53 UTC, 0 replies.
- flink git commit: [FLINK-2540] [optimizer] [runtime] Propagate union batch exchanges to union inputs - posted by se...@apache.org on 2015/08/21 17:55:55 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2306] Add support for named streams in Storm compatibility layer - enabled .declareStream() and connect via stream name - enabled multiplt output streams - added .split() / .select() / strip pattern - added helpers in n - posted by se...@apache.org on 2015/08/21 19:36:04 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2306] Add support for named streams in Storm compatibility layer - enabled .declareStream() and connect via stream name - enabled multiplt output streams - added .split() / .select() / strip pattern - added helpers in n - posted by se...@apache.org on 2015/08/21 19:36:05 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-2306] Add support for named streams in Storm compatibility layer - enabled .declareStream() and connect via stream name - enabled multiplt output streams - added .split() / .select() / strip pattern - added helpers in n - posted by se...@apache.org on 2015/08/21 19:36:06 UTC, 0 replies.
- [4/4] flink git commit: [tests] Move UnionClosedBranchingTest to optimizer tests - posted by se...@apache.org on 2015/08/21 19:36:07 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2451] [gelly] library methods cleanup - posted by va...@apache.org on 2015/08/22 21:39:32 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2451] [gelly] removed redundant examples; added comments describing which gelly method each example illustrates. - posted by va...@apache.org on 2015/08/22 21:39:33 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-2451] [gelly] re-organized tests; compare with collect() instead of temp files where possible - posted by va...@apache.org on 2015/08/22 21:39:34 UTC, 0 replies.
- [4/4] flink git commit: [gelly] made the number of vertices an optional parameter of PageRank; added the edge weight initialization to the library methods - posted by va...@apache.org on 2015/08/22 21:39:35 UTC, 0 replies.
- flink git commit: [FLINK-2560] Flink-Avro Plugin cannot be handled by Eclipse - disabled avro-maven-plugin within Eclipse via ... - posted by ch...@apache.org on 2015/08/23 18:51:20 UTC, 0 replies.
- [1/6] flink-web git commit: add color scheme to Material web page - posted by mx...@apache.org on 2015/08/24 17:53:35 UTC, 0 replies.
- [2/6] flink-web git commit: add color scheme to Material web page - posted by mx...@apache.org on 2015/08/24 17:53:36 UTC, 0 replies.
- [3/6] flink-web git commit: add color scheme to Material web page - posted by mx...@apache.org on 2015/08/24 17:53:37 UTC, 0 replies.
- [4/6] flink-web git commit: rebuild website after changes - posted by mx...@apache.org on 2015/08/24 17:53:38 UTC, 0 replies.
- [5/6] flink-web git commit: rebuild website after changes - posted by mx...@apache.org on 2015/08/24 17:53:39 UTC, 0 replies.
- [6/6] flink-web git commit: rebuild website after changes - posted by mx...@apache.org on 2015/08/24 17:53:40 UTC, 0 replies.
- flink git commit: [FLINK-2468] [tests] Make sure StateCheckpoinedITCase tolerates errors before first checkpoint - posted by se...@apache.org on 2015/08/24 18:31:16 UTC, 0 replies.
- flink git commit: [FLINK-2563] [gelly] extended the run() method of GraphAlgorithm interface to return an arbitrary type - posted by an...@apache.org on 2015/08/25 10:14:45 UTC, 1 replies.
- Git Push Summary - posted by an...@apache.org on 2015/08/25 10:22:47 UTC, 5 replies.
- flink git commit: [FLINK-2558] Add Streaming Connector for Elasticsearch - posted by al...@apache.org on 2015/08/25 10:37:25 UTC, 0 replies.
- flink git commit: [FLINK-2564] [core] Improve stability of RandomSamplerTest - posted by ch...@apache.org on 2015/08/25 10:55:28 UTC, 0 replies.
- [1/4] flink-web git commit: [posts] Add Gelly blog post - posted by uc...@apache.org on 2015/08/25 15:34:35 UTC, 0 replies.
- [2/4] flink-web git commit: [posts] Fix Gelly post markup - posted by uc...@apache.org on 2015/08/25 15:34:36 UTC, 0 replies.
- [3/4] flink-web git commit: [post] Publish Gelly blog post - posted by uc...@apache.org on 2015/08/25 15:34:37 UTC, 0 replies.
- [4/4] flink-web git commit: [post] Publish Gelly blog post - posted by uc...@apache.org on 2015/08/25 15:34:38 UTC, 0 replies.
- flink git commit: [FLINK-2528] [tests] Increase robustness and error reporting of MatchTaskTest - posted by se...@apache.org on 2015/08/25 16:06:16 UTC, 0 replies.
- flink git commit: [FLINK-2089] [runtime] Fix illegal state in RecordWriter after partition write failure - posted by uc...@apache.org on 2015/08/26 10:11:23 UTC, 1 replies.
- flink git commit: [FLINK-2538] Close created JarFile in ClassLoaderUtil - posted by uc...@apache.org on 2015/08/26 10:39:36 UTC, 0 replies.
- flink git commit: [FLINK-2270] [docs] Fix typo in docs (enableMonitoring => enableCheckpointing) - posted by uc...@apache.org on 2015/08/26 10:55:47 UTC, 0 replies.
- flink git commit: [FLINK-2460] [runtime] Check parent state in isReleased() check of partition view - posted by uc...@apache.org on 2015/08/26 11:08:02 UTC, 1 replies.
- flink git commit: [hotfix] Fixes auto type registration settings in ExecutionConfig - posted by tr...@apache.org on 2015/08/26 11:58:25 UTC, 0 replies.
- flink git commit: [hotfix] Allow setting FLINK_CONF_DIR by hand - posted by al...@apache.org on 2015/08/26 12:14:40 UTC, 0 replies.
- flink git commit: [hotfix] Add notice about using FLINK_CONF_DIR in Yarn Setup - posted by al...@apache.org on 2015/08/26 12:27:44 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2270] [docs] Fix typo in docs (enableMonitoring => enableCheckpointing) - posted by uc...@apache.org on 2015/08/26 12:40:43 UTC, 0 replies.
- [2/4] flink git commit: [hotfix] Fixes auto type registration settings in ExecutionConfig - posted by uc...@apache.org on 2015/08/26 12:40:44 UTC, 0 replies.
- [3/4] flink git commit: [hotfix] Add notice about using FLINK_CONF_DIR in Yarn Setup - posted by uc...@apache.org on 2015/08/26 12:40:45 UTC, 0 replies.
- [4/4] flink git commit: [hotfix] Allow setting FLINK_CONF_DIR by hand - posted by uc...@apache.org on 2015/08/26 12:40:46 UTC, 0 replies.
- flink git commit: [FLINK-2394] HadoopOutputFormats use correct OutputCommitters. - posted by uc...@apache.org on 2015/08/26 14:25:39 UTC, 1 replies.
- flink git commit: [FLINK-2555] Properly pass security credentials in the Hadoop Input/Output format wrappers - posted by uc...@apache.org on 2015/08/26 15:47:20 UTC, 1 replies.
- flink git commit: [scripts] resolve base path of symlinked executable - posted by uc...@apache.org on 2015/08/26 17:37:48 UTC, 1 replies.
- flink git commit: [FLINK-2189] [runtime] Fix various issues in hash table - check for memory availability before probing - correctly compute memory required for recursive build fast path - remove all temp files properly - posted by se...@apache.org on 2015/08/26 19:22:07 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2189] [runtime] Fix various issues in hash table - check for memory availability before probing - correctly compute memory required for recursive build fast path - remove all temp files properly - posted by se...@apache.org on 2015/08/26 19:24:39 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2575] [runtime] Deactivate join bloom filters by default - posted by se...@apache.org on 2015/08/26 19:24:40 UTC, 0 replies.
- flink git commit: [FLINK-2356] Add shutdown hook to CheckpointCoordinator to prevent resource leaks - posted by uc...@apache.org on 2015/08/26 19:57:24 UTC, 1 replies.
- [01/10] flink git commit: [FLINK-2386] [kafka] Add new Kafka Consumer for Flink - posted by se...@apache.org on 2015/08/26 21:13:51 UTC, 0 replies.
- [02/10] flink git commit: [FLINK-2386] [kafka] Add new Kafka Consumer for Flink - posted by se...@apache.org on 2015/08/26 21:13:52 UTC, 0 replies.
- [03/10] flink git commit: [FLINK-2386] [kafka] Add new Kafka Consumer for Flink - posted by se...@apache.org on 2015/08/26 21:13:53 UTC, 0 replies.
- [04/10] flink git commit: [FLINK-2386] [kafka] Add new Kafka Consumer for Flink - posted by se...@apache.org on 2015/08/26 21:13:54 UTC, 0 replies.
- [05/10] flink git commit: [FLINK-2386] [kafka] Add new Kafka Consumer for Flink - posted by se...@apache.org on 2015/08/26 21:13:55 UTC, 0 replies.
- [06/10] flink git commit: [FLINK-2386] [kafka] Move Kafka connectors to 'org.apache.flink.streaming.connectors.kafka' - posted by se...@apache.org on 2015/08/26 21:13:56 UTC, 0 replies.
- [07/10] flink git commit: [FLINK-2386] [kafka] Move Kafka connectors to 'org.apache.flink.streaming.connectors.kafka' - posted by se...@apache.org on 2015/08/26 21:13:57 UTC, 0 replies.
- [08/10] flink git commit: [FLINK-2386] [kafka] Move Kafka connectors to 'org.apache.flink.streaming.connectors.kafka' - posted by se...@apache.org on 2015/08/26 21:13:58 UTC, 0 replies.
- [09/10] flink git commit: [FLINK-2386] [kafka] Move Kafka connectors to 'org.apache.flink.streaming.connectors.kafka' - posted by se...@apache.org on 2015/08/26 21:13:59 UTC, 0 replies.
- [10/10] flink git commit: [FLINK-2386] [kafka] Move Kafka connectors to 'org.apache.flink.streaming.connectors.kafka' - posted by se...@apache.org on 2015/08/26 21:14:00 UTC, 0 replies.
- flink git commit: [scripts] Sync release script with master - posted by uc...@apache.org on 2015/08/27 09:41:19 UTC, 0 replies.
- flink git commit: [docs] Bump docs to 0.9.1 - posted by uc...@apache.org on 2015/08/27 10:27:31 UTC, 0 replies.
- flink git commit: [FLINK-2480][test] add test for PrintSinkFunction - posted by mx...@apache.org on 2015/08/27 11:21:31 UTC, 0 replies.
- flink git commit: Commit for release 0.9.1 - posted by uc...@apache.org on 2015/08/27 13:21:44 UTC, 1 replies.
- [01/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:18 UTC, 0 replies.
- [02/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:19 UTC, 0 replies.
- [03/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:20 UTC, 0 replies.
- [04/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:21 UTC, 0 replies.
- [05/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:22 UTC, 0 replies.
- [06/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:23 UTC, 0 replies.
- [07/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:24 UTC, 0 replies.
- [08/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:25 UTC, 0 replies.
- [09/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:26 UTC, 0 replies.
- [10/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:27 UTC, 0 replies.
- [11/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:28 UTC, 0 replies.
- [12/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:29 UTC, 0 replies.
- [13/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:30 UTC, 0 replies.
- [14/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:31 UTC, 0 replies.
- [15/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:32 UTC, 0 replies.
- [16/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:33 UTC, 0 replies.
- [17/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:34 UTC, 0 replies.
- [18/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:35 UTC, 0 replies.
- [19/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:36 UTC, 0 replies.
- [20/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:37 UTC, 0 replies.
- [21/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:38 UTC, 0 replies.
- [22/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:39 UTC, 0 replies.
- [23/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:40 UTC, 0 replies.
- [24/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport' - posted by se...@apache.org on 2015/08/27 13:25:41 UTC, 0 replies.
- [25/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Refactor, cleanup, and fix kafka consumers - posted by se...@apache.org on 2015/08/27 13:25:42 UTC, 0 replies.
- [26/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Refactor, cleanup, and fix kafka consumers - posted by se...@apache.org on 2015/08/27 13:25:43 UTC, 0 replies.
- [27/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Refactor, cleanup, and fix kafka consumers - posted by se...@apache.org on 2015/08/27 13:25:44 UTC, 0 replies.
- [28/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Refactor, cleanup, and fix kafka consumers - posted by se...@apache.org on 2015/08/27 13:25:45 UTC, 0 replies.
- [29/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Refactor, cleanup, and fix kafka consumers - posted by se...@apache.org on 2015/08/27 13:25:46 UTC, 0 replies.
- [30/51] [abbrv] flink git commit: [hotfix] Determing native byte order via ByteOrder.nativeOrder() - posted by se...@apache.org on 2015/08/27 13:25:47 UTC, 0 replies.
- [31/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:48 UTC, 0 replies.
- [32/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:49 UTC, 0 replies.
- [33/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:50 UTC, 0 replies.
- [34/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:51 UTC, 0 replies.
- [35/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:52 UTC, 0 replies.
- [36/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:53 UTC, 0 replies.
- [37/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:54 UTC, 0 replies.
- [38/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:55 UTC, 0 replies.
- [39/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:56 UTC, 0 replies.
- [40/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:57 UTC, 0 replies.
- [41/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:58 UTC, 0 replies.
- [42/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:25:59 UTC, 0 replies.
- [43/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:26:00 UTC, 0 replies.
- [44/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:26:01 UTC, 0 replies.
- [45/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:26:02 UTC, 0 replies.
- [46/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:26:03 UTC, 0 replies.
- [47/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:26:04 UTC, 0 replies.
- [48/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:26:05 UTC, 0 replies.
- [49/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:26:06 UTC, 0 replies.
- [50/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - posted by se...@apache.org on 2015/08/27 13:26:07 UTC, 0 replies.
- [51/51] [abbrv] flink git commit: [FLINK-2569] [core] Add CsvReader support for Value types - posted by se...@apache.org on 2015/08/27 13:26:08 UTC, 0 replies.
- flink git commit: [FLINK-2553] Example Jars not build correctly - reworked package structure of utils and wordcount.stormoperators package - reword class hierarchy of *FileSpout and *InMemorySpout - fixed pom.xml to assembly jars correctly - simp - posted by se...@apache.org on 2015/08/27 15:17:37 UTC, 0 replies.
- flink git commit: [build] Revert javakaffee dependency to version 0.27 to play well with ASM shading - posted by se...@apache.org on 2015/08/27 17:35:11 UTC, 0 replies.
- [1/2] flink git commit: [tests] Move manual test 'RecordsAndWidthsCombinationCheck' to proper tests scope - posted by se...@apache.org on 2015/08/27 19:42:49 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2584] [java api] Downgrade version of javakaffee kryo serializers, for compatibility with kryo 2.4 - posted by se...@apache.org on 2015/08/27 19:42:50 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-2587] [streaming] Make sure that close() is not called while checkpoint methods are in progress. - posted by se...@apache.org on 2015/08/27 23:37:29 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-2326] [yarn] Write yarn properties file to temp directory - posted by se...@apache.org on 2015/08/27 23:37:30 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-2582] [docs] Add documentation how to build Flink against different Scala versions - posted by se...@apache.org on 2015/08/27 23:37:31 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-2556] [core] Refactor/fix pre-flight key validation - posted by se...@apache.org on 2015/08/27 23:37:32 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-2565] Support primitive arrays as keys - posted by se...@apache.org on 2015/08/27 23:37:33 UTC, 0 replies.
- flink git commit: [FLINK-2499] [scripts] Warning message for hosts starting multiple daemons - posted by mb...@apache.org on 2015/08/28 00:16:32 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] fix missing decorations for accumulator messages - posted by mx...@apache.org on 2015/08/28 12:36:31 UTC, 1 replies.
- [2/2] flink git commit: [hotfix] disable object reuse in merging of accumulators - posted by mx...@apache.org on 2015/08/28 12:36:32 UTC, 1 replies.
- flink git commit: [scripts] Fixes path for taskmanager.sh in the start-cluster.sh script - posted by tr...@apache.org on 2015/08/28 15:18:31 UTC, 0 replies.
- flink git commit: [scripts] Fixes path for taskmanager.sh in start-cluster.sh script - posted by tr...@apache.org on 2015/08/28 15:21:23 UTC, 0 replies.
- flink git commit: [FLINK-2594][client] implement a method to retrieve the accumulators of a job - posted by mx...@apache.org on 2015/08/28 19:34:02 UTC, 0 replies.
- flink git commit: [hotfix] Include Hadoop version into EnvironmentInformation - posted by rm...@apache.org on 2015/08/30 13:29:00 UTC, 1 replies.
- [1/4] flink git commit: [FLINK-2543] [core] Make exception communication and result/failure notifications consistent with respect to serialization of exceptions - posted by se...@apache.org on 2015/08/30 20:45:47 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2543] [core] Make exception communication and result/failure notifications consistent with respect to serialization of exceptions - posted by se...@apache.org on 2015/08/30 20:45:48 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-2543] [core] Fix user object deserialization for file-based state handles. - posted by se...@apache.org on 2015/08/30 20:45:49 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-2543] [core] Fix user object deserialization for file-based state handles. - posted by se...@apache.org on 2015/08/30 20:45:50 UTC, 0 replies.
- [1/5] flink git commit: [tests] Improve and combine iteration tests with aggregators (less static sharing, collect(), parallel execution) - posted by se...@apache.org on 2015/08/30 23:44:36 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-1681] [tests] Remove outdated 'nephele' iteration tests. - posted by se...@apache.org on 2015/08/30 23:44:37 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-1681] [tests] Remove outdated 'nephele' iteration tests. - posted by se...@apache.org on 2015/08/30 23:44:38 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-1681] [tests] Remove outdated 'nephele' iteration tests. - posted by se...@apache.org on 2015/08/30 23:44:39 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-1681] [tests] Remove outdated 'nephele' iteration tests. - posted by se...@apache.org on 2015/08/30 23:44:40 UTC, 0 replies.
- [01/10] flink git commit: [FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers. - posted by tr...@apache.org on 2015/08/31 12:31:37 UTC, 0 replies.
- [02/10] flink git commit: [FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers. - posted by tr...@apache.org on 2015/08/31 12:31:38 UTC, 0 replies.
- [03/10] flink git commit: [FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers. - posted by tr...@apache.org on 2015/08/31 12:31:39 UTC, 0 replies.
- [04/10] flink git commit: [FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers. - posted by tr...@apache.org on 2015/08/31 12:31:40 UTC, 0 replies.
- [05/10] flink git commit: [FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers. - posted by tr...@apache.org on 2015/08/31 12:31:41 UTC, 0 replies.
- [06/10] flink git commit: [FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers. - posted by tr...@apache.org on 2015/08/31 12:31:42 UTC, 0 replies.
- [07/10] flink git commit: [FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers. - posted by tr...@apache.org on 2015/08/31 12:31:43 UTC, 0 replies.
- [08/10] flink git commit: [FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers. - posted by tr...@apache.org on 2015/08/31 12:31:44 UTC, 0 replies.
- [09/10] flink git commit: [FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers. - posted by tr...@apache.org on 2015/08/31 12:31:45 UTC, 0 replies.
- [10/10] flink git commit: [FLINK-2291] [runtime] Add ZooKeeper support to elect a leader from a set of JobManager. The leader will then be retrieved from ZooKeeper by the TaskManagers. - posted by tr...@apache.org on 2015/08/31 12:31:46 UTC, 0 replies.
- flink git commit: [jobmanager] fix warning about non-exhaustive case matching - posted by mx...@apache.org on 2015/08/31 13:53:52 UTC, 0 replies.
- flink git commit: [FLINK-2599] [test-stability] Fix possible NPE in SlotCountExceedingParallelismTest - posted by uc...@apache.org on 2015/08/31 13:59:12 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-2594][client] implement a method to retrieve the accumulators of a job - posted by se...@apache.org on 2015/08/31 14:13:54 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-2543] [core] Fix user object deserialization for file-based state handles. - posted by se...@apache.org on 2015/08/31 14:13:55 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-2543] [core] Fix user object deserialization for file-based state handles. - posted by se...@apache.org on 2015/08/31 14:13:56 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-2543] [core] Make exception communication and result/failure notifications consistent with respect to serialization of exceptions - posted by se...@apache.org on 2015/08/31 14:13:57 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-2543] [core] Make exception communication and result/failure notifications consistent with respect to serialization of exceptions - posted by se...@apache.org on 2015/08/31 14:13:58 UTC, 0 replies.
- flink git commit: [core][runtime] move SerializedValueTest from runtime to core - posted by mx...@apache.org on 2015/08/31 15:30:08 UTC, 0 replies.
- flink git commit: [scripts] Fixes correct Flink bin path usage in scripts - posted by tr...@apache.org on 2015/08/31 15:36:43 UTC, 1 replies.
- flink git commit: [FLINK-2584] Check for unshaded classes in fat jar and shade curator - posted by se...@apache.org on 2015/08/31 16:14:21 UTC, 0 replies.
- svn commit: r10361 - /release/flink/flink-0.9.1/ - posted by uc...@apache.org on 2015/08/31 16:28:58 UTC, 0 replies.
- flink git commit: [scripts] Adds example settings for zookeeper ha to default flink-conf.yaml - posted by tr...@apache.org on 2015/08/31 17:16:31 UTC, 0 replies.