commits@flink.apache.org, 2015-09

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

- [1/2] flink-web git commit: Update stable release to 0.9.1 - posted by uc...@apache.org on 2015/09/01 08:01:42 UTC, 0 replies.
- [2/2] flink-web git commit: Build updated site - posted by uc...@apache.org on 2015/09/01 08:01:43 UTC, 0 replies.
- flink-web git commit: Add release announcement blog post - posted by uc...@apache.org on 2015/09/01 08:21:01 UTC, 0 replies.
- flink-web git commit: Build update website - posted by uc...@apache.org on 2015/09/01 08:23:01 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2584] Check for unshaded classes in fat jar and shade curator - posted by se...@apache.org on 2015/09/01 11:53:29 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2596] Remove non-transitive comparator in random sampler test. - posted by se...@apache.org on 2015/09/01 11:53:30 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2590] Fixes Scala's DataSetUtilsITCase - posted by tr...@apache.org on 2015/09/01 13:50:17 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2590] fixing DataSetUtils.zipWithUniqueId() and DataSetUtils.zipWithIndex() - posted by tr...@apache.org on 2015/09/01 13:50:18 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2590] fixing DataSetUtils.zipWithUniqueId() and DataSetUtils.zipWithIndex() - posted by tr...@apache.org on 2015/09/01 14:17:17 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2590] Fixes Scala's DataSetUtilsITCase - posted by tr...@apache.org on 2015/09/01 14:17:18 UTC, 0 replies.
- flink git commit: [FLINK-2604] [runtime] Adds synchronization to stop method of ZooKeeperLeaderElectionService - posted by tr...@apache.org on 2015/09/02 09:44:15 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2601] [runtime] Install shutdown hook at the end of I/O manager initialization - posted by se...@apache.org on 2015/09/02 15:54:37 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2545] add bucket member verification while build bloom filter. - posted by se...@apache.org on 2015/09/02 15:54:38 UTC, 0 replies.
- [3/4] flink git commit: [hotfix] [gelly] Remove unintended calls to getExecutionEnvironment in VertexCentricIteration and GatherSumApplyIteration - posted by se...@apache.org on 2015/09/02 15:54:39 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-2448] [tests] Create new Test Environments on every call to getExecutionEnvironment and allow sharing of job execution results - posted by se...@apache.org on 2015/09/02 15:54:40 UTC, 0 replies.
- flink git commit: [hotfix][docs] Update Kafka section in streaming guide to match the renamed class names - posted by rm...@apache.org on 2015/09/02 16:07:41 UTC, 0 replies.
- flink git commit: [FLINK-2607][quickstart] ignore signature files when creating fat jar - posted by mx...@apache.org on 2015/09/02 18:25:52 UTC, 1 replies.
- flink-web git commit: Added mjsax to the people list of community page - posted by mj...@apache.org on 2015/09/02 18:32:43 UTC, 0 replies.
- buildbot failure in ASF Buildbot on flink-docs-release-0.9 - posted by bu...@apache.org on 2015/09/03 03:00:02 UTC, 0 replies.
- flink git commit: [FLINK-2614][scala-shell] scala shell's default execution mode is broken - posted by mx...@apache.org on 2015/09/03 11:37:53 UTC, 0 replies.
- flink git commit: [FLINK-2235] fix calculation of free memory for local execution - posted by mx...@apache.org on 2015/09/03 12:01:18 UTC, 0 replies.
- flink git commit: [FLINK-2475] Rename Flink Client log file - posted by mj...@apache.org on 2015/09/03 12:47:40 UTC, 0 replies.
- flink git commit: [FLINK-2161] [scala shell] Modify start script to take additional argument (-a or --addclasspath ) for external libraries - posted by se...@apache.org on 2015/09/04 16:59:58 UTC, 0 replies.
- flink git commit: [FLINK-2605] [runtime] Unclosed RandomAccessFile may leak resource in StaticFileServerHandler - posted by ch...@apache.org on 2015/09/05 09:19:33 UTC, 0 replies.
- flink-web git commit: Blog post announcing Flink Forward 2015 - posted by kt...@apache.org on 2015/09/07 11:45:34 UTC, 0 replies.
- flink git commit: [FLINK-2625] Pass configuration properly to JobGraphGenerator - posted by se...@apache.org on 2015/09/07 15:19:21 UTC, 1 replies.
- [1/5] flink git commit: [FLINK-2628] [tests] CoStreamCheckpointingITCase prints a warning when test is inconclusive - posted by se...@apache.org on 2015/09/07 17:35:16 UTC, 0 replies.
- [2/5] flink git commit: [hotfix] [tests] Increase zookeeper session timeouts in tests them more robust - posted by se...@apache.org on 2015/09/07 17:35:17 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-2626] [core] Add an average accumulator - posted by se...@apache.org on 2015/09/07 17:35:18 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-2626] [core] Minor cleanups in AverageAccumulator and AverageAccumulatorTest - posted by se...@apache.org on 2015/09/07 17:35:19 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-2372] Add new FlinkKafkaProducer bases on the new producer API - posted by se...@apache.org on 2015/09/07 17:35:20 UTC, 0 replies.
- flink git commit: [FLINK-2567] [core] Allow quoted strings in CSV fields to contain quotation character inside of the field, as long as its escaped Ex: 'Hi my name is \'Flink\'' - posted by se...@apache.org on 2015/09/08 11:21:05 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2372] Add new FlinkKafkaProducer bases on the new producer API - posted by se...@apache.org on 2015/09/08 11:45:45 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2372] Add new FlinkKafkaProducer bases on the new producer API - posted by se...@apache.org on 2015/09/08 11:45:46 UTC, 0 replies.
- flink git commit: [FLINK-2570] [gelly] Added a Triangle Count Library Method - posted by an...@apache.org on 2015/09/08 11:52:02 UTC, 0 replies.
- flink git commit: [FLINK-2480][test] add a prefix test for PrintSinkFunction - posted by mx...@apache.org on 2015/09/08 16:43:36 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-2106] [runtime] Rename DriverStrategy.MERGE to DriverStrategy.INNER_MERGE - posted by fh...@apache.org on 2015/09/08 16:58:50 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2106] [runtime] Add Outer Join drivers and Outer Merge strategies to Runtime - posted by fh...@apache.org on 2015/09/08 16:58:51 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2106] [runtime] Add Outer Join drivers and Outer Merge strategies to Runtime - posted by fh...@apache.org on 2015/09/08 16:58:52 UTC, 0 replies.
- flink git commit: [FLINK-2616] [tests] Increases timeout of ZooKeeperLeaderElectionTest to 60s - posted by tr...@apache.org on 2015/09/08 17:12:03 UTC, 0 replies.
- flink git commit: [FLINK-2490][streaming] fix retryForever check in SocketStreamFunction - posted by mx...@apache.org on 2015/09/08 18:01:29 UTC, 0 replies.
- [01/15] flink git commit: [FLINK-2580] [runtime] Expose more methods form Hadoop output streams and exposes wrapped input and output streams. - posted by se...@apache.org on 2015/09/08 20:58:51 UTC, 0 replies.
- [02/15] flink git commit: [FLINK-2636] [streaming] Create common type StreamElement for StreamRecord and Watermark - posted by se...@apache.org on 2015/09/08 20:58:52 UTC, 0 replies.
- [03/15] flink git commit: [FLINK-2635] [streaming] Make input processors independent of batch reader interface. - posted by se...@apache.org on 2015/09/08 20:58:53 UTC, 0 replies.
- [04/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:58:54 UTC, 0 replies.
- [05/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:58:55 UTC, 0 replies.
- [06/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:58:56 UTC, 0 replies.
- [07/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:58:57 UTC, 0 replies.
- [08/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:58:58 UTC, 0 replies.
- [09/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:58:59 UTC, 0 replies.
- [10/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:59:00 UTC, 0 replies.
- [11/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:59:01 UTC, 0 replies.
- [12/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:59:02 UTC, 0 replies.
- [13/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:59:03 UTC, 0 replies.
- [14/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:59:04 UTC, 0 replies.
- [15/15] flink git commit: [FLINK-1320] [core] Add an off-heap variant of the managed memory - posted by se...@apache.org on 2015/09/08 20:59:05 UTC, 0 replies.
- flink git commit: [FLINK-2392] Improve YARN test stability - posted by rm...@apache.org on 2015/09/09 10:02:09 UTC, 0 replies.
- flink git commit: [FLINK-2321] [ml] Set seed for SVM to be random - posted by tr...@apache.org on 2015/09/09 10:23:08 UTC, 0 replies.
- flink git commit: [FLINK-2600] Enable test rerun for Elasticsearch Tests - posted by al...@apache.org on 2015/09/09 10:26:22 UTC, 0 replies.
- flink git commit: [FLINK-1674] Modified test cases for nested avro type - posted by fh...@apache.org on 2015/09/09 16:10:51 UTC, 0 replies.
- flink git commit: [FLINK-2493] Simplify names of example program JARs - posted by fh...@apache.org on 2015/09/09 16:53:32 UTC, 0 replies.
- flink git commit: [FLINK-1297] add accumulator called OperatorStatsAccumulator - posted by mx...@apache.org on 2015/09/09 16:58:42 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-2619] [tests] Fix for some unexecuted Scala tests - posted by se...@apache.org on 2015/09/09 20:16:40 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-2638] [core] Add @SafeVarargs to the ExecutionEnvironment's "fromElements(...)" method. - posted by se...@apache.org on 2015/09/09 20:16:41 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-2003] [docs] Added instructions for encrypted filesystems - posted by se...@apache.org on 2015/09/09 20:16:42 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-2648] [tests] Fix flaky CombineTaskTest and improve cancelling in GroupReduceCombineDriver - posted by se...@apache.org on 2015/09/09 20:16:43 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-2619] [tests] Fix failing ExecutionGraphRestartTest and JobManagerRegistrationTest - posted by se...@apache.org on 2015/09/09 20:16:44 UTC, 0 replies.
- buildbot exception in ASF Buildbot on flink-docs-master - posted by bu...@apache.org on 2015/09/10 02:00:00 UTC, 1 replies.
- flink git commit: [FLINK-2650] Fix broken Links in Table API doc - posted by al...@apache.org on 2015/09/10 10:17:49 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-2631] [streaming] Fixes the StreamFold operator and adds OutputTypeConfigurable interface to support type injection at StreamGraph creation. - posted by fh...@apache.org on 2015/09/10 13:55:51 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2645] [jobmanager] Fail job execution if final accumulators cannot be merged and forward exceptions. - posted by fh...@apache.org on 2015/09/10 13:55:52 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats - posted by fh...@apache.org on 2015/09/10 13:55:53 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2631] [streaming] Fixes the StreamFold operator and adds OutputTypeConfigurable interface to support type injection at StreamGraph creation. - posted by fh...@apache.org on 2015/09/10 14:32:00 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats - posted by fh...@apache.org on 2015/09/10 14:32:01 UTC, 0 replies.
- flink git commit: [FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats - posted by fh...@apache.org on 2015/09/10 14:33:34 UTC, 0 replies.
- flink git commit: [FLINK-2408] Define all maven properties outside build profiles - posted by rm...@apache.org on 2015/09/10 14:36:59 UTC, 0 replies.
- flink git commit: [FLINK-2632] [client] Fix web client to respect the class loader of submitted jobs - posted by fh...@apache.org on 2015/09/10 15:34:47 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-2577] [streaming] Fix Stalling Watermarks when Sources Close - posted by fh...@apache.org on 2015/09/10 18:55:46 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2639] Add repository for hdp specific jetty to 'vendor-repos' - posted by fh...@apache.org on 2015/09/10 18:55:47 UTC, 0 replies.
- buildbot success in ASF Buildbot on flink-docs-master - posted by bu...@apache.org on 2015/09/11 02:22:37 UTC, 2 replies.
- flink git commit: [FLINK-2639] Add repository for hdp specific jetty to 'vendor-repos' - posted by rm...@apache.org on 2015/09/11 11:58:54 UTC, 0 replies.
- flink git commit: [hotfix] Add missing import - posted by rm...@apache.org on 2015/09/11 13:10:31 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2647] [streaming core] Distinguish between "close" (flushing buffered data) and "dispose" (cleanup resources) in streaming operators. - posted by se...@apache.org on 2015/09/11 13:48:25 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [tests] Fix warnings and casts in AbstractGenericArraySerializerTest - posted by se...@apache.org on 2015/09/11 13:48:26 UTC, 0 replies.
- flink git commit: [FLINK-2656] Fix behavior of FlinkKafkaConsumer for out of range offsets - posted by rm...@apache.org on 2015/09/11 14:11:20 UTC, 2 replies.
- flink git commit: [FLINK-2654] Add JavaDoc to ParameterTool class - posted by fh...@apache.org on 2015/09/11 16:28:26 UTC, 1 replies.
- buildbot success in ASF Buildbot on flink-docs-release-0.9 - posted by bu...@apache.org on 2015/09/13 03:20:10 UTC, 1 replies.
- flink git commit: [HOTFIX] Fix broken build due to cherry-pick of commit 767bdf49c - posted by fh...@apache.org on 2015/09/14 13:45:38 UTC, 0 replies.
- flink git commit: [streaming] Appropriate Exception message in WriteSinkFunction - posted by mb...@apache.org on 2015/09/14 15:12:49 UTC, 0 replies.
- flink git commit: [FLINK-2658] fieldsGrouping for multiple output streams fails - added SplitStreamTypeKeySelector and JUnit tests - posted by mj...@apache.org on 2015/09/14 17:59:27 UTC, 1 replies.
- flink git commit: [FLINK-2664] [streaming] Allow partitioned state removal - posted by gy...@apache.org on 2015/09/14 18:33:46 UTC, 0 replies.
- buildbot failure in ASF Buildbot on flink-docs-master - posted by bu...@apache.org on 2015/09/15 02:00:06 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2373] Add configuration parameter to createRemoteEnvironment method - posted by fh...@apache.org on 2015/09/15 14:50:35 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2655] Minimize intermediate merging of external merge sort. - posted by fh...@apache.org on 2015/09/15 14:50:36 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-2533] [java-api] Gap based random sample optimization. - posted by fh...@apache.org on 2015/09/15 14:50:37 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-2665] [api] [runtime] Makes ExecutionConfig serializable by forcing Kryo serializers to be Serializable - posted by fh...@apache.org on 2015/09/15 14:50:38 UTC, 0 replies.
- buildbot exception in ASF Buildbot on flink-docs-release-0.9 - posted by bu...@apache.org on 2015/09/16 03:00:00 UTC, 1 replies.
- flink git commit: [FLINK-2670] [tests] Add tests that validate memory release under concurrent modification exceptions - posted by se...@apache.org on 2015/09/16 16:07:05 UTC, 0 replies.
- flink-web git commit: Add brief description of performance job on feature page. - posted by se...@apache.org on 2015/09/16 16:19:28 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-1851] [tableAPI] Add support for casting in Table Expression Parser - Also fix code generation for casting between primitives. - Extends documentation for TableAPI expressions - posted by fh...@apache.org on 2015/09/16 16:57:20 UTC, 0 replies.
- [2/3] flink git commit: [TableAPI] [tests] Disambiguate result of test programs to DataSet - posted by fh...@apache.org on 2015/09/16 16:57:21 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2641] integrate off-heap memory configuration - add offheap configuration parameter taskmanager.memory.off-heap - remove offheap ratio parameter and reuse memory fraction parameter - set JVM -XX:MaxDirectMemorySize paramete - posted by fh...@apache.org on 2015/09/16 16:57:22 UTC, 0 replies.
- [1/3] flink-web git commit: Sync features on frontpage - posted by uc...@apache.org on 2015/09/16 17:01:26 UTC, 0 replies.
- [2/3] flink-web git commit: Add anchors to features page - posted by uc...@apache.org on 2015/09/16 17:01:27 UTC, 0 replies.
- [3/3] flink-web git commit: Update build for frontpage update - posted by uc...@apache.org on 2015/09/16 17:01:28 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-2595] [tests] Fixed unclosed JarFile in ClassLoaderUtilsTest - posted by fh...@apache.org on 2015/09/17 13:24:04 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-2640] [yarn] integrate off-heap configuration - posted by fh...@apache.org on 2015/09/17 13:24:05 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Adds test for equality relation's symmetric property - A - posted by fh...@apache.org on 2015/09/17 13:24:06 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Adds test for equality relation's symmetric property - A - posted by fh...@apache.org on 2015/09/17 13:24:07 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Adds test for equality relation's symmetric property - A - posted by fh...@apache.org on 2015/09/17 13:24:08 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Adds test for equality relation's symmetric property - A - posted by fh...@apache.org on 2015/09/17 13:24:09 UTC, 0 replies.
- [7/9] flink git commit: [FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups. - posted by fh...@apache.org on 2015/09/17 13:24:10 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator - posted by fh...@apache.org on 2015/09/17 13:24:11 UTC, 0 replies.
- [9/9] flink git commit: [FLINK-2691] [documentation] Fix broken links to Python script on QuickStart docs - posted by fh...@apache.org on 2015/09/17 13:24:12 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Adds test for equality relation's symmetric property - A - posted by fh...@apache.org on 2015/09/17 14:04:03 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Adds test for equality relation's symmetric property - A - posted by fh...@apache.org on 2015/09/17 14:04:04 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Adds test for equality relation's symmetric property - A - posted by fh...@apache.org on 2015/09/17 14:04:05 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Adds test for equality relation's symmetric property - A - posted by fh...@apache.org on 2015/09/17 14:04:06 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-2691] [documentation] Fix broken links to Python script on QuickStart docs - posted by fh...@apache.org on 2015/09/17 14:04:07 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups. - posted by fh...@apache.org on 2015/09/17 14:04:08 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator - posted by fh...@apache.org on 2015/09/17 14:04:09 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-2691] [documentation] Fix broken links to Python script on QuickStart docs - posted by fh...@apache.org on 2015/09/17 15:38:30 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups. - posted by fh...@apache.org on 2015/09/17 15:38:31 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator - posted by fh...@apache.org on 2015/09/17 15:38:32 UTC, 0 replies.
- [01/51] [abbrv] flink git commit: [FLINK-2415] [optimizer] Create and attach proper JobGraph describing JSON plans to JobGraph for batch jobs. - posted by se...@apache.org on 2015/09/17 20:19:33 UTC, 0 replies.
- [02/51] [abbrv] flink git commit: [FLINK-2415] [optimizer] Create and attach proper JobGraph describing JSON plans to JobGraph for batch jobs. - posted by se...@apache.org on 2015/09/17 20:19:34 UTC, 0 replies.
- [03/51] [abbrv] flink git commit: [FLINK-2415] [optimizer] Create and attach proper JobGraph describing JSON plans to JobGraph for batch jobs. - posted by se...@apache.org on 2015/09/17 20:19:35 UTC, 0 replies.
- [04/51] [abbrv] flink git commit: [FLINK-2415] [optimizer] Create and attach proper JobGraph describing JSON plans to JobGraph for batch jobs. - posted by se...@apache.org on 2015/09/17 20:19:36 UTC, 0 replies.
- [05/51] [abbrv] flink git commit: [FLINK-2547] [web dashboard] Add handlers for cluster status and web dashboard configuration - posted by se...@apache.org on 2015/09/17 20:19:37 UTC, 0 replies.
- [06/51] [abbrv] flink git commit: [FLINK-2547] [web dashboard] Updated web dashboard after request/response changes - posted by se...@apache.org on 2015/09/17 20:19:38 UTC, 0 replies.
- [07/51] [abbrv] flink git commit: [FLINK-2547] [web dashboard] Updated web dashboard after request/response changes - posted by se...@apache.org on 2015/09/17 20:19:39 UTC, 0 replies.
- [08/51] [abbrv] flink git commit: [FLINK-2547] [web dashboard] Updated web dashboard after request/response changes - posted by se...@apache.org on 2015/09/17 20:19:40 UTC, 0 replies.
- [09/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Changed overview and timeline - posted by se...@apache.org on 2015/09/17 20:19:41 UTC, 0 replies.
- [10/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Changed overview and timeline - posted by se...@apache.org on 2015/09/17 20:19:42 UTC, 0 replies.
- [11/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Changed overview and timeline - posted by se...@apache.org on 2015/09/17 20:19:43 UTC, 0 replies.
- [12/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Changed overview and timeline - posted by se...@apache.org on 2015/09/17 20:19:44 UTC, 0 replies.
- [13/51] [abbrv] flink git commit: [FLINK-2415] [web dashboard] Provide more data in the job overview responses - posted by se...@apache.org on 2015/09/17 20:19:45 UTC, 0 replies.
- [14/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Added tooltips to timeline - posted by se...@apache.org on 2015/09/17 20:19:46 UTC, 0 replies.
- [15/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Added tooltips to timeline - posted by se...@apache.org on 2015/09/17 20:19:47 UTC, 0 replies.
- [16/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Added tooltips to timeline - posted by se...@apache.org on 2015/09/17 20:19:48 UTC, 0 replies.
- [17/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Added tooltips to timeline - posted by se...@apache.org on 2015/09/17 20:19:49 UTC, 0 replies.
- [18/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Add view for exceptions - posted by se...@apache.org on 2015/09/17 20:19:50 UTC, 0 replies.
- [19/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Add view for exceptions - posted by se...@apache.org on 2015/09/17 20:19:51 UTC, 0 replies.
- [20/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Add view for exceptions - posted by se...@apache.org on 2015/09/17 20:19:52 UTC, 0 replies.
- [21/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Auto-update overview page - posted by se...@apache.org on 2015/09/17 20:19:53 UTC, 0 replies.
- [22/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Auto-update overview page - posted by se...@apache.org on 2015/09/17 20:19:54 UTC, 0 replies.
- [23/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Auto-update overview page - posted by se...@apache.org on 2015/09/17 20:19:55 UTC, 0 replies.
- [24/51] [abbrv] flink git commit: [FLINK-2687] [monitoring API] Extend vertex requests with subtask data and accumulators - posted by se...@apache.org on 2015/09/17 20:19:56 UTC, 0 replies.
- [25/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Extend exceptions view - posted by se...@apache.org on 2015/09/17 20:19:57 UTC, 0 replies.
- [26/51] [abbrv] flink git commit: [FLINK-2415] [monitoring api] Add vertex details request handler, unify IDs between vertices and plan - posted by se...@apache.org on 2015/09/17 20:19:58 UTC, 0 replies.
- [27/51] [abbrv] flink git commit: [FLINK-2415] [monitoring api] Add vertex details request handler, unify IDs between vertices and plan - posted by se...@apache.org on 2015/09/17 20:19:59 UTC, 0 replies.
- [28/51] [abbrv] flink git commit: [FLINK-2554] [web dashboard] Add request hander that lists exceptions encountered during execution - posted by se...@apache.org on 2015/09/17 20:20:00 UTC, 0 replies.
- [29/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Adjust view for details of a job - posted by se...@apache.org on 2015/09/17 20:20:01 UTC, 0 replies.
- [30/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Adjust view for details of a job - posted by se...@apache.org on 2015/09/17 20:20:02 UTC, 0 replies.
- [31/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Adjust view for details of a job - posted by se...@apache.org on 2015/09/17 20:20:03 UTC, 0 replies.
- [32/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Adjust view for details of a job - posted by se...@apache.org on 2015/09/17 20:20:04 UTC, 0 replies.
- [33/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] New node organization - posted by se...@apache.org on 2015/09/17 20:20:05 UTC, 0 replies.
- [34/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] New node organization - posted by se...@apache.org on 2015/09/17 20:20:06 UTC, 0 replies.
- [35/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] New node organization - posted by se...@apache.org on 2015/09/17 20:20:07 UTC, 0 replies.
- [36/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Add subtasks to vertex display - posted by se...@apache.org on 2015/09/17 20:20:08 UTC, 0 replies.
- [37/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Add subtasks to vertex display - posted by se...@apache.org on 2015/09/17 20:20:09 UTC, 0 replies.
- [38/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Add subtasks to vertex display - posted by se...@apache.org on 2015/09/17 20:20:10 UTC, 0 replies.
- [39/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Add auto-refresh to dashboard - posted by se...@apache.org on 2015/09/17 20:20:11 UTC, 0 replies.
- [40/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Add auto-refresh to dashboard - posted by se...@apache.org on 2015/09/17 20:20:12 UTC, 0 replies.
- [41/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Show plan (and optimizer properties) as a dedicated view - posted by se...@apache.org on 2015/09/17 20:20:13 UTC, 0 replies.
- [42/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Show plan (and optimizer properties) as a dedicated view - posted by se...@apache.org on 2015/09/17 20:20:14 UTC, 0 replies.
- [43/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Show plan (and optimizer properties) as a dedicated view - posted by se...@apache.org on 2015/09/17 20:20:15 UTC, 0 replies.
- [44/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Added status counts for a job - posted by se...@apache.org on 2015/09/17 20:20:16 UTC, 0 replies.
- [45/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Timeline for running tasks - posted by se...@apache.org on 2015/09/17 20:20:17 UTC, 0 replies.
- [46/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Timeline for running tasks - posted by se...@apache.org on 2015/09/17 20:20:18 UTC, 0 replies.
- [47/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Timeline for running tasks - posted by se...@apache.org on 2015/09/17 20:20:19 UTC, 0 replies.
- [48/51] [abbrv] flink git commit: [FLINK-2687] [monitoring api] Add handlers for subtask details and accumulators - posted by se...@apache.org on 2015/09/17 20:20:20 UTC, 0 replies.
- [49/51] [abbrv] flink git commit: Revert "[FLINK-2605] [runtime] Unclosed RandomAccessFile may leak resource in StaticFileServerHandler" - posted by se...@apache.org on 2015/09/17 20:20:21 UTC, 0 replies.
- [50/51] [abbrv] flink git commit: [FLINK-2688] [monitoring api] Add docs for monitoring REST API. - posted by se...@apache.org on 2015/09/17 20:20:22 UTC, 0 replies.
- [51/51] [abbrv] flink git commit: [FLINK-2688] [monitoring api] Integrate monitoring request handler with HA leader handling - posted by se...@apache.org on 2015/09/17 20:20:23 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-2698] Add trailing newline to flink-conf.yaml - posted by se...@apache.org on 2015/09/18 13:48:59 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-2701] [streaming] Add getter for wrapped Java environment to Scala ExecutionEnvironment - posted by se...@apache.org on 2015/09/18 13:49:00 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-2557] [core] TypeExtractor properly returns MissingTypeInfo - posted by se...@apache.org on 2015/09/18 13:49:01 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-2627] [scala api] Makes scala data set utils easier to access. - posted by se...@apache.org on 2015/09/18 13:49:02 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-2702] [examples] Add a distributed copy utility example - posted by se...@apache.org on 2015/09/18 13:49:03 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-2702] [examples] Add JAR packaging for DistCp example, plus minor cleanups. - posted by se...@apache.org on 2015/09/18 13:49:04 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-2704] [streaming] Clean up naming of State/Checkpoint Interfaces - posted by se...@apache.org on 2015/09/18 13:49:05 UTC, 0 replies.
- [1/3] flink-web git commit: Add blog post about off-heap memory - posted by se...@apache.org on 2015/09/18 14:32:24 UTC, 0 replies.
- [2/3] flink-web git commit: Add blog post about off-heap memory - posted by se...@apache.org on 2015/09/18 14:32:25 UTC, 0 replies.
- [3/3] flink-web git commit: Add blog post about off-heap memory - posted by se...@apache.org on 2015/09/18 14:32:26 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2583] [hdfs connector] Add Stream Sink For Rolling HDFS Files - posted by se...@apache.org on 2015/09/18 16:03:57 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2583] [hdfs connector] Add Stream Sink For Rolling HDFS Files - posted by se...@apache.org on 2015/09/18 16:03:58 UTC, 0 replies.
- [3/4] flink git commit: [hotfix] [build] Fix curator deps, Exclude Curator deps in Tests - posted by se...@apache.org on 2015/09/18 16:03:59 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-2643] [build] Change Travis Build Matrix to Include Recent Hadoop Versions - posted by se...@apache.org on 2015/09/18 16:04:00 UTC, 0 replies.
- flink git commit: [FLINK-2707] [streaming] Set StateCheckpointer before default state value - posted by gy...@apache.org on 2015/09/18 19:15:46 UTC, 0 replies.
- flink git commit: [tempfix] [streaming] Disable fork reuse in streaming tests - posted by se...@apache.org on 2015/09/20 02:17:46 UTC, 0 replies.
- flink git commit: [test-stability] Hardens TaskManagerRegistrationTest by increasing the timeouts - posted by tr...@apache.org on 2015/09/21 11:16:34 UTC, 0 replies.
- [1/7] flink git commit: [tests] [runtime] Disable for reuse for runtime unit tests - posted by se...@apache.org on 2015/09/21 13:30:28 UTC, 0 replies.
- [2/7] flink git commit: [hotfix] [taskmanager] Add chain failure cause to exception when updating task execution state on JobManager - posted by se...@apache.org on 2015/09/21 13:30:29 UTC, 0 replies.
- [3/7] flink git commit: [hotfix] [tests] Remove sysout logging in LargeRecordHandlerITCase - posted by se...@apache.org on 2015/09/21 13:30:30 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-2711] [tests] Increase timeout for TaskManager tests upon partition lookups - posted by se...@apache.org on 2015/09/21 13:30:31 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-2357] [web dashboard] Fixed broken plan on second entry - posted by se...@apache.org on 2015/09/21 13:30:32 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-2357] [web dashboard] Fixed broken plan on second entry - posted by se...@apache.org on 2015/09/21 13:30:33 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-2357] [web dashboard] Fixed broken plan on second entry - posted by se...@apache.org on 2015/09/21 13:30:34 UTC, 0 replies.
- flink git commit: [FLINK2392] Increase memory for TaskManager - posted by rm...@apache.org on 2015/09/21 13:48:01 UTC, 0 replies.
- flink git commit: [build system] Update secret keys for travis log delivery - posted by rm...@apache.org on 2015/09/21 15:21:38 UTC, 0 replies.
- svn commit: r10577 - /release/flink/KEYS - posted by fh...@apache.org on 2015/09/21 16:22:57 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2536] [streaming] Cleanups and improvements on SocketClientSink - posted by se...@apache.org on 2015/09/21 17:23:21 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2536] [streaming] Add a re-connect attempty to socket sink - posted by se...@apache.org on 2015/09/21 17:23:22 UTC, 0 replies.
- flink git commit: [hotfix] Use InetAddress.getLocalHost() as first approach when detecting the TMs own ip/hostname - posted by rm...@apache.org on 2015/09/21 18:24:01 UTC, 1 replies.
- flink git commit: [FLINK-2713] [streaming] Set state restore to lazy to avoid StateCheckpointer issues and reduce checkpoint overhead - posted by gy...@apache.org on 2015/09/21 20:02:39 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-2649] [scala shell] Fix unclosed stream in case of an error in JarHelper#unjar() - posted by se...@apache.org on 2015/09/21 23:34:42 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2648] [FLINK-2717] [runtime] Harden memory release in sorters against asynchronous canceling - posted by se...@apache.org on 2015/09/21 23:34:43 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-2724] [runtime] Fix object reuse in GroupReduceCombineDriver and ReduceCombineDriver - posted by se...@apache.org on 2015/09/21 23:34:44 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-2710] [streaming] Fix and improve SocketTextStreamFunction and SocketTextStreamFunctionTest - posted by se...@apache.org on 2015/09/21 23:34:45 UTC, 0 replies.
- flink git commit: [FLINK-2392][yarn tests] Use log event which is guaranteed to show up to test whether the job was successful - posted by rm...@apache.org on 2015/09/22 09:21:11 UTC, 0 replies.
- flink git commit: [test-stability] Sets the number of ZooKeeper servers of TestingCluster in ForkableFlinkMiniCluster to 1 in order to avoid test failures when two servers try to bind to the same port. - posted by tr...@apache.org on 2015/09/22 11:21:26 UTC, 0 replies.
- flink git commit: [FLINK-2392][yarn tests] Produce more log output on travis for the flink-yarn-tests to avoid running into the 300s limit - posted by rm...@apache.org on 2015/09/22 12:31:07 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-2683] [FLINK-2682] [runtime] Add dedicated operator for aligned processing time windows. - posted by se...@apache.org on 2015/09/22 13:25:49 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2683] [FLINK-2682] [runtime] Add dedicated operator for aligned processing time windows. - posted by se...@apache.org on 2015/09/22 13:25:50 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2675] [streaming] Add utilities for scheduled triggers. - posted by se...@apache.org on 2015/09/22 13:25:51 UTC, 0 replies.
- flink git commit: [FLINK-2643] [build] Update Travis build matrix and change snapshot deploy profiles - posted by se...@apache.org on 2015/09/22 14:29:44 UTC, 0 replies.
- flink git commit: [FLINK-2722] Use InetAddress.getLocalHost() as first approach when detecting the TMs own ip/hostname - posted by rm...@apache.org on 2015/09/22 15:03:29 UTC, 0 replies.
- flink git commit: [FLINK-2392][yarn tests] Address concurrent modification exception - posted by rm...@apache.org on 2015/09/22 18:26:19 UTC, 0 replies.
- flink git commit: [Maven] fix order of parent module information - posted by mx...@apache.org on 2015/09/22 19:21:31 UTC, 1 replies.
- [1/4] flink git commit: [FLINK-2097] temporarily disable session management API - posted by mx...@apache.org on 2015/09/22 21:57:17 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-2097][core] implement a job session management - posted by mx...@apache.org on 2015/09/22 21:57:18 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-2097][core] implement a job session management - posted by mx...@apache.org on 2015/09/22 21:57:19 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-2097][core] implement a job session management - posted by mx...@apache.org on 2015/09/22 21:57:20 UTC, 0 replies.
- flink git commit: Commit for release 0.10.0-milestone-1 - posted by fh...@apache.org on 2015/09/22 23:19:11 UTC, 1 replies.
- Git Push Summary - posted by fh...@apache.org on 2015/09/22 23:20:21 UTC, 0 replies.
- flink git commit: [test-stability] Replaces Curator's TestingCluster with TestingServer in ZooKeeperElection/RetrievalTests. Increased the timeout to 200s in ZooKeeperLeaderElectionTest. - posted by tr...@apache.org on 2015/09/23 11:19:46 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-2729] [web-dashboard] Add TaskManager overview - posted by uc...@apache.org on 2015/09/23 11:36:26 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2729] [web-dashboard] Add TaskManager overview - posted by uc...@apache.org on 2015/09/23 11:36:27 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2729] [web-dashboard] Add TaskManager overview - posted by uc...@apache.org on 2015/09/23 11:36:28 UTC, 0 replies.
- flink git commit: [tests] Add RetryOnFailure annotation - posted by uc...@apache.org on 2015/09/23 11:46:16 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-2696] [test-stability] Hardens ZookeeperOffsetHandlerTest by letting Curator's TestingServer select the port to bind to instead of using NetUtils.getAvailablePort. - posted by tr...@apache.org on 2015/09/23 12:13:11 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2694] [test-stability] Hardens the JobManagerProcessReapingTest.testReapProcessOnFailure test case by letting the JobManager choose its port instead of predetermining it via the NetUtils.getAvailablePort. - posted by tr...@apache.org on 2015/09/23 12:13:12 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2705] [yarn] Excludes commons-codec:1.3 from aws-java-jdk dependency to resolve dependency ambiguity - posted by tr...@apache.org on 2015/09/23 12:13:13 UTC, 0 replies.
- flink git commit: [FLINK-2746] [tests] Add RetryOnException annotation for tests - posted by se...@apache.org on 2015/09/23 14:05:07 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2744] [kafka connector] Reduce number of concurrent test forks to improce test stability on CI environment. - posted by se...@apache.org on 2015/09/23 15:25:23 UTC, 0 replies.
- [2/2] flink git commit: [tests] Improve Kafka concurrent produce/consumer test by allowing retries when connecting to non-leader broker. - posted by se...@apache.org on 2015/09/23 15:25:24 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2734] [streaming] Fix ArrayKeySelector - posted by se...@apache.org on 2015/09/23 17:15:42 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [streaming] Improve error message for key operations on non-composite types - posted by se...@apache.org on 2015/09/23 17:15:43 UTC, 0 replies.
- flink git commit: fix broken link to config page in quickstart - posted by mx...@apache.org on 2015/09/23 18:04:06 UTC, 0 replies.
- flink git commit: [tests] Harden SocketClientSinkTest - posted by uc...@apache.org on 2015/09/23 19:49:55 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2651] Add Netty to dependency management - posted by uc...@apache.org on 2015/09/23 20:00:11 UTC, 0 replies.
- [2/2] flink git commit: Bump Netty version to 4.0.31.Final - posted by uc...@apache.org on 2015/09/23 20:00:12 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2675] [streaming] Integrate Timer Service with StreamTask - posted by se...@apache.org on 2015/09/23 21:12:22 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2675] [streaming] Integrate Timer Service with StreamTask - posted by se...@apache.org on 2015/09/23 21:12:23 UTC, 0 replies.
- [1/2] flink git commit: [jobmanager] Fix indentation - posted by uc...@apache.org on 2015/09/23 22:07:01 UTC, 0 replies.
- [2/2] flink git commit: Adjust Netty version in flink-dist/LICENSE - posted by uc...@apache.org on 2015/09/23 22:07:02 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2200] [build system] Add scala version suffix to artifact id for Scala 2.11 - posted by rm...@apache.org on 2015/09/24 09:50:46 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-2200] [build system] Deploy Flink 2.11 with every build (nightly) - posted by rm...@apache.org on 2015/09/24 09:50:47 UTC, 1 replies.
- flink git commit: wip - posted by rm...@apache.org on 2015/09/24 10:54:40 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-1520] [gelly] Read edges and vertices from CSV files - posted by va...@apache.org on 2015/09/24 11:40:49 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-1520] [gelly] add types methods and make formatting changes to the graph csv reader - posted by va...@apache.org on 2015/09/24 11:40:50 UTC, 0 replies.
- flink git commit: wip: fix snapshot deployment for hadoop1, parallelize hadoop2 deployment - posted by rm...@apache.org on 2015/09/24 14:00:14 UTC, 0 replies.
- flink git commit: [FLINK-2751] [docs] Add quickstart menu to the navigation bar of documentation - posted by ch...@apache.org on 2015/09/24 14:08:31 UTC, 1 replies.
- flink git commit: [FLINK-2616] [test-stability] Fixes ZooKeeperLeaderElectionTest.testMultipleLeaders by introducing a second retrieval service to retrieve the leader address after the faulty address has been written. - posted by tr...@apache.org on 2015/09/24 14:57:23 UTC, 0 replies.
- flink git commit: [docs] fix typo of the RabbitMQ Java example (added braces) - posted by mb...@apache.org on 2015/09/24 17:00:45 UTC, 0 replies.
- flink git commit: [utils] Missing getters for ParameterTool - posted by mb...@apache.org on 2015/09/24 21:41:12 UTC, 0 replies.
- flink git commit: [docs] fix broken scala shell link - posted by mx...@apache.org on 2015/09/25 13:07:08 UTC, 0 replies.
- flink git commit: [scripts] Exclude .git in source release - posted by uc...@apache.org on 2015/09/25 16:17:01 UTC, 0 replies.
- flink git commit: [FLINK-2690] [api-breaking] [scala api] [java api] Adds functionality to the CsvInputFormat to find fields defined in a super class of a Pojo. Refactors CsvInputFormat to share code between this format and ScalaCsvInputFormat. - posted by tr...@apache.org on 2015/09/28 12:23:08 UTC, 0 replies.
- [01/12] flink git commit: Add Window parameter to KeyedWindowFunction, move to package windowing - posted by al...@apache.org on 2015/09/28 18:14:57 UTC, 0 replies.
- [02/12] flink git commit: Move window operators and tests to windowing package - posted by al...@apache.org on 2015/09/28 18:14:58 UTC, 0 replies.
- [03/12] flink git commit: Move window operators and tests to windowing package - posted by al...@apache.org on 2015/09/28 18:14:59 UTC, 0 replies.
- [04/12] flink git commit: Move window operators and tests to windowing package - posted by al...@apache.org on 2015/09/28 18:15:00 UTC, 0 replies.
- [05/12] flink git commit: Fix some typos and naming inconsistencies in new Windowing Code - posted by al...@apache.org on 2015/09/28 18:15:01 UTC, 0 replies.
- [06/12] flink git commit: Add Count and Delta WindowPolicy - posted by al...@apache.org on 2015/09/28 18:15:02 UTC, 0 replies.
- [07/12] flink git commit: Harmonize generic parameter names in Stream API classes - posted by al...@apache.org on 2015/09/28 18:15:03 UTC, 0 replies.
- [08/12] flink git commit: [FLINK-2753] [streaming] [api breaking] Add first parts of new window API for key grouped windows - posted by al...@apache.org on 2015/09/28 18:15:04 UTC, 0 replies.
- [09/12] flink git commit: Move delta window functions to package functions.windowing.delta - posted by al...@apache.org on 2015/09/28 18:15:05 UTC, 0 replies.
- [10/12] flink git commit: [FLINK-2677] Add a general-purpose keyed-window operator - posted by al...@apache.org on 2015/09/28 18:15:06 UTC, 0 replies.
- [11/12] flink git commit: [FLINK-2677] Add a general-purpose keyed-window operator - posted by al...@apache.org on 2015/09/28 18:15:07 UTC, 0 replies.
- [12/12] flink git commit: [FLINK-2677] Add a general-purpose keyed-window operator - posted by al...@apache.org on 2015/09/28 18:15:08 UTC, 0 replies.
- flink git commit: [hotfix][streaming] correct return type of execute(..) method - posted by mx...@apache.org on 2015/09/28 23:25:40 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-2561] [gelly] add GraphMetrics Scala example - posted by va...@apache.org on 2015/09/29 00:39:01 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-2561] [gelly] convert existing tests to use collect instead of files; add tests for newly added operations. - posted by va...@apache.org on 2015/09/29 00:39:02 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-2561] [gelly] add missing methods to Graph: add-remove edges/vertices, difference, graph creation methods, validate, getTriplets. Add missing utility mappers. - posted by va...@apache.org on 2015/09/29 00:39:03 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-2768] [docs] Fix wrong java version requirement in quickstart (1.6 -> 1.7 and 6.x -> 7.x) - posted by se...@apache.org on 2015/09/29 14:08:32 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-2769] [dashboard] Remove hard coded job server URL - posted by se...@apache.org on 2015/09/29 14:08:33 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-2769] [dashboard] Remove hard coded job server URL - posted by se...@apache.org on 2015/09/29 14:08:34 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-2756] [scripts] Fix start/stop scripts for paths with spaces - posted by se...@apache.org on 2015/09/29 14:08:35 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-2723] [core] CopyableValue method to copy into new instance - posted by se...@apache.org on 2015/09/29 14:08:36 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-2754] Fixed FixedLengthRecordSorter write to multi memory pages issue and add more unit tests. - posted by se...@apache.org on 2015/09/29 14:08:37 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-2653] [runtime] Enable object reuse in MergeIterator - posted by se...@apache.org on 2015/09/29 14:08:38 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-2761] [scala-shell] Prevent creation of new environment in Scala Shell - posted by se...@apache.org on 2015/09/29 14:08:39 UTC, 0 replies.
- flink git commit: [FLINK-2763] [runtime] Fix hash table spilling partition selection. - posted by se...@apache.org on 2015/09/29 15:22:31 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-2777] [docs] Fix Scala API description in programming_guide.html - posted by se...@apache.org on 2015/09/29 21:02:08 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-2754] Add a new module for micro benchmark. - posted by se...@apache.org on 2015/09/29 21:02:09 UTC, 0 replies.
- flink git commit: [FLINK-2775] [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes - posted by hs...@apache.org on 2015/09/30 00:02:36 UTC, 0 replies.
- flink git commit: [FLINK-2764] [WebClient] WebClient cannot display multiple Jobs - posted by mj...@apache.org on 2015/09/30 00:10:37 UTC, 0 replies.
- flink git commit: [FLINK-2703] Prepare Flink for being used with Logback. - posted by rm...@apache.org on 2015/09/30 18:01:10 UTC, 0 replies.