332 messages

org.apache.flink.commits [All Lists]

2015 August [All Months]

Page 1 (Messages 1 to 25): 1 2 3 4 5 6 7 8 9 10 11 12 13 14

flink git commit: [FLINK-2436] [streaming] Make ByteStreamStateHandles more robust - gyf...@apache.org
[3/5] flink git commit: [FLINK-2240] Add bloom filter to filter probe records during hash join. - sew...@apache.org
[2/4] flink git commit: [FLINK-2502] [storm compatibility] Fix FiniteStormSpout documenation rendering - added missing empty lines - additional minor improvements - sew...@apache.org
[3/4] flink git commit: [FLINK-2519] [streaming] Make checkpoint alignment aware of finished partitions. - sew...@apache.org
[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) - sew...@apache.org
flink git commit: [tests] Make timeout discarding checks in CheckpointCoordinatorTest more robust. - sew...@apache.org
[2/7] flink git commit: [FLINK-1962] Add Gelly Scala API - sew...@apache.org
[4/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator - aljo...@apache.org
[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 - vas...@apache.org
[2/4] flink-web git commit: [posts] Fix Gelly post markup - uc...@apache.org
flink git commit: [FLINK-2538] Close created JarFile in ClassLoaderUtil - uc...@apache.org
flink git commit: [FLINK-2460] [runtime] Check parent state in isReleased() check of partition view - uc...@apache.org
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 - sew...@apache.org
[31/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - sew...@apache.org
[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' - sew...@apache.org
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 - sew...@apache.org
[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' - sew...@apache.org
[35/51] [abbrv] flink git commit: [FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval. - sew...@apache.org
flink git commit: [scripts] Fixes path for taskmanager.sh in the start-cluster.sh script - troh...@apache.org
flink git commit: [scripts] Fixes path for taskmanager.sh in start-cluster.sh script - troh...@apache.org
[2/4] flink git commit: [FLINK-2543] [core] Make exception communication and result/failure notifications consistent with respect to serialization of exceptions - sew...@apache.org
[1/5] flink git commit: [FLINK-2594][client] implement a method to retrieve the accumulators of a job - sew...@apache.org
flink git commit: [FLINK-2584] Check for unshaded classes in fat jar and shade curator - sew...@apache.org
[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. - troh...@apache.org
[2/2] flink-web git commit: Build updated site - uc...@apache.org

Page 1 (Messages 1 to 25): 1 2 3 4 5 6 7 8 9 10 11 12 13 14