[01/13] flink git commit: [FLINK-2800] [kryo] Fix Kryo serialization to clear buffered data

Repository: flink Updated Branches: refs/heads/master 2b8303cdc -> 676854b92 [FLINK-2800] [kryo] Fix Kryo serialization to clear buffered data The Kryo serializer uses Kryo's Output class to buffer individual write operations before it is written to the underlying output stream. This Output

[06/13] flink git commit: [FLINK-2559] Clean up JavaDocs

http://git-wip-us.apache.org/repos/asf/flink/blob/680b5a90/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java -- diff --git

[04/13] flink git commit: [FLINK-2900] [hadoop-compat] Remove Record API code from Hadoop Compat module

[FLINK-2900] [hadoop-compat] Remove Record API code from Hadoop Compat module This closes #1293 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ff04baa Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2ff04baa Diff:

[08/13] flink git commit: [FLINK-2559] Clean up JavaDocs

http://git-wip-us.apache.org/repos/asf/flink/blob/680b5a90/flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/relational/WebLogAnalysis.java -- diff --git

[07/13] flink git commit: [FLINK-2559] Clean up JavaDocs

http://git-wip-us.apache.org/repos/asf/flink/blob/680b5a90/flink-java/src/main/java/org/apache/flink/api/java/operators/join/JoinOperatorSetsBase.java -- diff --git

[05/13] flink git commit: [FLINK-2932] Examples in docs now download shell script using https instead of http

[FLINK-2932] Examples in docs now download shell script using https instead of http This closes #1309 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ec7bf50d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ec7bf50d

[02/13] flink git commit: [FLINK-2869] [tests] Port IOManagerPerformanceBenchmark to JMH.

[FLINK-2869] [tests] Port IOManagerPerformanceBenchmark to JMH. This closes #1270. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3abbcd1e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3abbcd1e Diff:

[12/13] flink git commit: [FLINK-2934] Remove placeholder pages for job.statistics, taskmanager.log and taskmanager.stdout

[FLINK-2934] Remove placeholder pages for job.statistics, taskmanager.log and taskmanager.stdout This closes #1307 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1fd386e7 Tree:

[13/13] flink git commit: [FLINK-2902][web-dashboard] Sort finished jobs by their end time, running jobs by start time

[FLINK-2902][web-dashboard] Sort finished jobs by their end time, running jobs by start time This closes #1296 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/676854b9 Tree:

[11/13] flink git commit: [FLINK-2934] Remove placeholder pages for job.statistics, taskmanager.log and taskmanager.stdout

http://git-wip-us.apache.org/repos/asf/flink/blob/1fd386e7/flink-runtime-web/web-dashboard/web/js/index.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/index.js b/flink-runtime-web/web-dashboard/web/js/index.js index

[10/13] flink git commit: [FLINK-2934] Remove placeholder pages for job.statistics, taskmanager.log and taskmanager.stdout

http://git-wip-us.apache.org/repos/asf/flink/blob/1fd386e7/flink-runtime-web/web-dashboard/web/partials/jobs/job.html -- diff --git a/flink-runtime-web/web-dashboard/web/partials/jobs/job.html

[06/10] flink git commit: [FLINK-2902][web-dashboard] Sort finished jobs by their end time, running jobs by start time

[FLINK-2902][web-dashboard] Sort finished jobs by their end time, running jobs by start time This closes #1296 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fcc1eed3 Tree:

flink git commit: [FLINK-2800] [kryo] Fix Kryo serialization to clear buffered data

Repository: flink Updated Branches: refs/heads/release-0.9 9178a58bb -> 19abef456 [FLINK-2800] [kryo] Fix Kryo serialization to clear buffered data The Kryo serializer uses Kryo's Output class to buffer individual write operations before it is written to the underlying output stream. This

[3/4] flink git commit: [FLINK-2874] Fix Avro getter/setter recognition

[FLINK-2874] Fix Avro getter/setter recognition This closes #1252 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17e7b423 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/17e7b423 Diff:

[4/4] flink git commit: [FLINK-2874] Fix recognition of Scala default setters

[FLINK-2874] Fix recognition of Scala default setters Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd7ed8e3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cd7ed8e3 Diff:

[4/4] flink git commit: [FLINK-2874] Fix recognition of Scala default setters

[FLINK-2874] Fix recognition of Scala default setters Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c72eff4a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c72eff4a Diff:

[2/4] flink git commit: [FLINK-2668] [DataSet] [api-breaking] Chained Projections are no longer appended

[FLINK-2668] [DataSet] [api-breaking] Chained Projections are no longer appended This closes #1279 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c3eb8b8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c3eb8b8

[3/4] flink git commit: [FLINK-2874] Fix Avro getter/setter recognition

[FLINK-2874] Fix Avro getter/setter recognition This closes #1252 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42b5ead5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/42b5ead5 Diff:

[2/2] flink-web git commit: rebuild website

17 +292,6 @@ release is a preview release that contains known issues. - - Peeking into Apache Flink's Engine Room - 13 Mar 2015 by Fabian Hüske (https://twitter.com/fhueske;>@fhueske) - - Joins are prevalent operations in many data processing applications. Most data proce

[1/2] flink-web git commit: Added release 0.10.0 announcement

Repository: flink-web Updated Branches: refs/heads/asf-site abc8d08cc -> 4e2b23965 Added release 0.10.0 announcement Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/f82224b3 Tree:

[2/2] flink git commit: [FLINK-2903][web-dashboard] Format numeric values of received/sent counters.

[FLINK-2903][web-dashboard] Format numeric values of received/sent counters. This closes #1326 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/50ab9a37 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/50ab9a37 Diff:

[2/2] flink git commit: [FLINK-2903][web-dashboard] Format numeric values of received/sent counters.

[FLINK-2903][web-dashboard] Format numeric values of received/sent counters. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/81f8c05d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/81f8c05d Diff:

[1/2] flink git commit: [FLINK-2943][web-dashboard] Rename bytes/records read/written to received/sent. [hotfix][web-dashboard] Fix taskmanager charts legend.

Repository: flink Updated Branches: refs/heads/release-0.10 f1bf28237 -> 81f8c05d5 [FLINK-2943][web-dashboard] Rename bytes/records read/written to received/sent. [hotfix][web-dashboard] Fix taskmanager charts legend. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[09/10] flink git commit: [FLINK-2107] Add hash-based strategies for left and right outer joins.

http://git-wip-us.apache.org/repos/asf/flink/blob/5671c77c/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/NonReusingBuildFirstHashJoinIterator.java -- diff --git

[08/10] flink git commit: [FLINK-2107] Add hash-based strategies for left and right outer joins.

http://git-wip-us.apache.org/repos/asf/flink/blob/5671c77c/flink-runtime/src/test/java/org/apache/flink/runtime/operators/AbstractOuterJoinTaskExternalITCase.java -- diff --git

[02/10] flink git commit: [FLINK-2725] Add Max/Min/Sum aggregation for mutable types.

[FLINK-2725] Add Max/Min/Sum aggregation for mutable types. This closes #1191 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da248b15 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/da248b15 Diff:

[05/10] flink git commit: [FLINK-2842] [documentation] Remove Flink S3FileSystem, extend documentation to use Hadoop S3FileSystem.

[FLINK-2842] [documentation] Remove Flink S3FileSystem, extend documentation to use Hadoop S3FileSystem. This closes #1245 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c9005779 Tree:

[07/10] flink git commit: [FLINK-2107] Add hash-based strategies for left and right outer joins.

http://git-wip-us.apache.org/repos/asf/flink/blob/5671c77c/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashMatchIteratorITCase.java -- diff --git

[03/10] flink git commit: [FLINK-2857] [gelly] Improve Gelly API and documentation. - Improve javadocs of Graph creation methods - Add fromTuple2 creation methods - Rename mapper parameters to vertexI

http://git-wip-us.apache.org/repos/asf/flink/blob/640e63be/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/example/EuclideanGraphWeighing.java -- diff --git

[5/6] flink git commit: [FLINK-2479] Refactor runtime.operators.* tests

[FLINK-2479] Refactor runtime.operators.* tests This closes #1160 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fbc18b96 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fbc18b96 Diff:

[4/6] flink git commit: [FLINK-2479] Refactor runtime.operators.* tests

http://git-wip-us.apache.org/repos/asf/flink/blob/fbc18b96/flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingReOpenableHashTableITCase.java -- diff --git

[2/6] flink git commit: [FLINK-2479] Refactor runtime.operators.* tests

http://git-wip-us.apache.org/repos/asf/flink/blob/fbc18b96/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/TestData.java -- diff --git

[6/6] flink git commit: [FLINK-2774] [scala shell] Extended default imports for ScalaShell

[FLINK-2774] [scala shell] Extended default imports for ScalaShell This closes #1247 -- PRs closed due to inactivity This closes #1077 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c82ebbfc Tree:

[2/4] flink-web git commit: Build website

http://git-wip-us.apache.org/repos/asf/flink-web/blob/415ee891/content/news/2014/11/18/hadoop-compatibility.html -- diff --git a/content/news/2014/11/18/hadoop-compatibility.html

[4/4] flink-web git commit: Build website

Build website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/415ee891 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/415ee891 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/415ee891 Branch:

[3/6] flink git commit: [FLINK-2834] Global round-robin for temporary directories

[FLINK-2834] Global round-robin for temporary directories Multiple TaskManager filesystems can be used by configuring multiple temporary directories. This patch changes the process of spilling files from a per-operator round-robin to a global round-robin such that each directory is written to

flink git commit: [FLINK-2834] Global round-robin for temporary directories

Repository: flink Updated Branches: refs/heads/release-0.9 b3429ed55 -> 96099951e [FLINK-2834] Global round-robin for temporary directories Multiple TaskManager filesystems can be used by configuring multiple temporary directories. This patch changes the process of spilling files from a

[2/6] flink git commit: [docs] Fix documentation for building Flink with Scala 2.11 or 2.10

[docs] Fix documentation for building Flink with Scala 2.11 or 2.10 This closes #1260 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e3cabe7c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e3cabe7c Diff:

[5/6] flink git commit: [FLINK-2876] Minutiae

[FLINK-2876] Minutiae A collection of small documentation and grammar updates. This closes #1277 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ea58 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ea58

[6/6] flink git commit: [FLINK-2820] Configuration not passed to JobGraphGenerator

[FLINK-2820] Configuration not passed to JobGraphGenerator This was previously reported as FLINK-2625 (commit 8a84937215ea575fa94a00d11c2517902d252756). The Client class was concurrently refactored with FLINK-2097 (commit 71bf2f570861daae53b24bfcf1d06aedb85311b9). This closes #1278 Project:

[4/6] flink git commit: [FLINK-2880] [streaming] Allow DeserializationSchema to forward exceptions.

[FLINK-2880] [streaming] Allow DeserializationSchema to forward exceptions. This closes #1275 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a959bcb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7a959bcb Diff:

[1/6] flink git commit: [FLINK-2743] Add XORShfitRandom and use it in RandomSamplers.

Repository: flink Updated Branches: refs/heads/master 22510f0e2 -> 4c1cffd9d [FLINK-2743] Add XORShfitRandom and use it in RandomSamplers. This closes #1170 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5fb1c479 Tree:

[1/2] flink git commit: [FLINK-2066][core] Add configuration of delay between execution retries at job level

Repository: flink Updated Branches: refs/heads/master b489c3673 -> 8d62033c2 [FLINK-2066][core] Add configuration of delay between execution retries at job level This closes #1223 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/6] flink git commit: [FLINK-2576] [javaAPI] [scalaAPI] Restored binary compatibility for DataSet (inner) join.

Repository: flink Updated Branches: refs/heads/master 04558574c -> 1272cd5d0 [FLINK-2576] [javaAPI] [scalaAPI] Restored binary compatibility for DataSet (inner) join. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[4/6] flink git commit: [FLINK-2576] [javaAPI] [scalaAPI] [optimizer] Add outerJoin to DataSet API (Java, Scala) and optimizer.

http://git-wip-us.apache.org/repos/asf/flink/blob/b00c1d7e/flink-java/src/main/java/org/apache/flink/api/java/operators/JoinOperator.java -- diff --git

[2/6] flink git commit: [FLINK-2576] [javaAPI] [scalaAPI] [optimizer] Add outerJoin to DataSet API (Java, Scala) and optimizer.

http://git-wip-us.apache.org/repos/asf/flink/blob/b00c1d7e/flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/OuterJoinITCase.java -- diff --git

[6/6] flink git commit: [FLINK-2576] Add outer join base operator.

[FLINK-2576] Add outer join base operator. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6b76 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6b76 Diff:

[1/3] flink git commit: [FLINK-2106] [runtime] Rename DriverStrategy.MERGE to DriverStrategy.INNER_MERGE

Repository: flink Updated Branches: refs/heads/master 24f7fa9ef -> 2da82f915 [FLINK-2106] [runtime] Rename DriverStrategy.MERGE to DriverStrategy.INNER_MERGE This closes #1052 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [FLINK-2106] [runtime] Add Outer Join drivers and Outer Merge strategies to Runtime

[FLINK-2106] [runtime] Add Outer Join drivers and Outer Merge strategies to Runtime Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f3dee23b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f3dee23b Diff:

flink git commit: [FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats

Repository: flink Updated Branches: refs/heads/release-0.9 ae2b59d83 -> d656fc33a [FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats This closes # Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-2632] [client] Fix web client to respect the class loader of submitted jobs

Repository: flink Updated Branches: refs/heads/master 79a7bb213 -> 9c2eaa8dc [FLINK-2632] [client] Fix web client to respect the class loader of submitted jobs This closes #1114 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: [FLINK-2631] [streaming] Fixes the StreamFold operator and adds OutputTypeConfigurable interface to support type injection at StreamGraph creation.

Repository: flink Updated Branches: refs/heads/release-0.10.0-milestone-1 563ee9ad8 -> ba44abf9c [FLINK-2631] [streaming] Fixes the StreamFold operator and adds OutputTypeConfigurable interface to support type injection at StreamGraph creation. Adds test for non serializable fold type. Adds

[2/2] flink git commit: [FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats

[FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats This closes # Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba44abf9 Tree:

[2/3] flink git commit: [FLINK-2645] [jobmanager] Fail job execution if final accumulators cannot be merged and forward exceptions.

[FLINK-2645] [jobmanager] Fail job execution if final accumulators cannot be merged and forward exceptions. This closes #1112 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/16fb4e91 Tree:

flink git commit: [FLINK-2632] [client] Fix web client to respect the class loader of submitted jobs

Repository: flink Updated Branches: refs/heads/release-0.10.0-milestone-1 ba44abf9c -> d81a89644 [FLINK-2632] [client] Fix web client to respect the class loader of submitted jobs This closes #1114 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/3] flink git commit: [FLINK-2631] [streaming] Fixes the StreamFold operator and adds OutputTypeConfigurable interface to support type injection at StreamGraph creation.

Repository: flink Updated Branches: refs/heads/master c94fdcdd5 -> 8754352ff [FLINK-2631] [streaming] Fixes the StreamFold operator and adds OutputTypeConfigurable interface to support type injection at StreamGraph creation. Adds test for non serializable fold type. Adds test to verify

[3/3] flink git commit: [FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats

[FLINK-2617] [hadoop-compat] Added static mutexes for configure, open, close HadoopFormats This closes # Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8754352f Tree:

flink git commit: [FLINK-1674] Modified test cases for nested avro type

Repository: flink Updated Branches: refs/heads/master a9c29a760 -> 0a005700d [FLINK-1674] Modified test cases for nested avro type This closes #1091 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0a005700 Tree:

flink git commit: [FLINK-2493] Simplify names of example program JARs

Repository: flink Updated Branches: refs/heads/master 0a005700d -> bbddda776 [FLINK-2493] Simplify names of example program JARs This closes #1094 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bbddda77 Tree:

[2/2] flink git commit: [FLINK-2639] Add repository for hdp specific jetty to 'vendor-repos'

[FLINK-2639] Add repository for hdp specific jetty to 'vendor-repos' This closes #1113 - Closing unresponsive PR: This closes #862 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aec4b157 Tree:

flink git commit: [HOTFIX] Fix broken build due to cherry-pick of commit 767bdf49c

Repository: flink Updated Branches: refs/heads/release-0.10.0-milestone-1 07a597927 -> dbae51af9 [HOTFIX] Fix broken build due to cherry-pick of commit 767bdf49c Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dbae51af

[2/3] flink git commit: [TableAPI] [tests] Disambiguate result of test programs to DataSet

[TableAPI] [tests] Disambiguate result of test programs to DataSet This closes #1131 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a3150a3c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a3150a3c Diff:

[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 fractio

[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 parameter correctly This closes #1129 Project:

[1/7] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Ad

Repository: flink Updated Branches: refs/heads/release-0.10.0-milestone-1 4ee9e2c86 -> f4cb5938a http://git-wip-us.apache.org/repos/asf/flink/blob/b49b1552/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/StreamWindowTypeInfoTest.java

[4/7] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Ad

[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 - Adds test for PojoTypeInfo serializability This closes #1134

[3/7] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Ad

http://git-wip-us.apache.org/repos/asf/flink/blob/b49b1552/flink-java/src/main/java/org/apache/flink/api/java/typeutils/EnumTypeInfo.java -- diff --git

[2/7] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Ad

http://git-wip-us.apache.org/repos/asf/flink/blob/b49b1552/flink-java/src/test/java/org/apache/flink/api/java/typeutils/EnumTypeInfoTest.java -- diff --git

[7/7] flink git commit: [FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator

[FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator This closes #1130 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f4cb5938 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f4cb5938 Diff:

[5/7] flink git commit: [FLINK-2691] [documentation] Fix broken links to Python script on QuickStart docs

[FLINK-2691] [documentation] Fix broken links to Python script on QuickStart docs This closes #1140 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a11a90f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7a11a90f

[6/7] flink git commit: [FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups.

[FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups. This closes #1136 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0e5cdfb3 Tree:

[6/9] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Ad

[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 - Adds test for PojoTypeInfo serializability This closes #1134

[4/9] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Ad

http://git-wip-us.apache.org/repos/asf/flink/blob/8ca853e0/flink-java/src/test/java/org/apache/flink/api/java/typeutils/EnumTypeInfoTest.java -- diff --git

[5/9] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Ad

http://git-wip-us.apache.org/repos/asf/flink/blob/8ca853e0/flink-java/src/main/java/org/apache/flink/api/java/typeutils/EnumTypeInfo.java -- diff --git

[8/9] flink git commit: [FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator

[FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator This closes #1130 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c269158c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c269158c Diff:

[1/9] flink git commit: [FLINK-2595] [tests] Fixed unclosed JarFile in ClassLoaderUtilsTest

Repository: flink Updated Branches: refs/heads/master 76a40d59e -> 77989d3cb [FLINK-2595] [tests] Fixed unclosed JarFile in ClassLoaderUtilsTest This closes #1137 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c9e2c8b

[9/9] flink git commit: [FLINK-2691] [documentation] Fix broken links to Python script on QuickStart docs

[FLINK-2691] [documentation] Fix broken links to Python script on QuickStart docs This closes #1140 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/77989d3c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/77989d3c

[3/9] flink git commit: [FLINK-2637] [api-breaking] [types] Adds equals and hashCode method to TypeInformations and TypeSerializers - Fixes ObjectArrayTypeInfo - Makes CompositeTypes serializable - Ad

http://git-wip-us.apache.org/repos/asf/flink/blob/8ca853e0/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/StreamWindowTypeInfoTest.java -- diff --git

[7/9] flink git commit: [FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups.

[FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups. This closes #1136 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/988a04eb Tree:

[2/9] flink git commit: [FLINK-2640] [yarn] integrate off-heap configuration

[FLINK-2640] [yarn] integrate off-heap configuration This closes #1132 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/93c95b6a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/93c95b6a Diff:

[2/3] flink git commit: [FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups.

[FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups. This closes #1136 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/43e23ba5 Tree:

[3/3] flink git commit: [FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator

[FLINK-2659] [runtime] Fix object reuse in UnionWithTempOperator This closes #1130 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ad09721f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ad09721f Diff:

[1/3] flink git commit: [FLINK-2691] [documentation] Fix broken links to Python script on QuickStart docs

Repository: flink Updated Branches: refs/heads/release-0.9 c007f72e6 -> ad09721fb [FLINK-2691] [documentation] Fix broken links to Python script on QuickStart docs This closes #1140 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-2654] Add JavaDoc to ParameterTool class

Repository: flink Updated Branches: refs/heads/master 635456890 -> b73fef242 [FLINK-2654] Add JavaDoc to ParameterTool class This closes #1116 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b73fef24 Tree:

flink git commit: [FLINK-2654] Add JavaDoc to ParameterTool class

Repository: flink Updated Branches: refs/heads/release-0.10.0-milestone-1 84d8767be -> 07a597927 [FLINK-2654] Add JavaDoc to ParameterTool class This closes #1116 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/07a59792

[2/4] flink git commit: [FLINK-2655] Minimize intermediate merging of external merge sort.

[FLINK-2655] Minimize intermediate merging of external merge sort. This closes #1118 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a75dd627 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a75dd627 Diff:

[1/4] flink git commit: [FLINK-2373] Add configuration parameter to createRemoteEnvironment method

Repository: flink Updated Branches: refs/heads/master 8a75025ab -> 2cc5d98c6 [FLINK-2373] Add configuration parameter to createRemoteEnvironment method This closes #1066 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [Maven] fix order of parent module information

Repository: flink Updated Branches: refs/heads/release-0.10.0-milestone-1 356eef089 -> ed3bbb93e [Maven] fix order of parent module information An order other than "groupId, artifactId, version" can cause problems with the release scripts. This needs to be properly fixed in

flink git commit: Commit for release 0.10.0-milestone-1

Repository: flink Updated Branches: refs/heads/0.10.0-milestone-1-rc1 [created] ffdd484ce Commit for release 0.10.0-milestone-1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ffdd484c Tree:

Git Push Summary

Repository: flink Updated Branches: refs/heads/0.10.0-milestone-1-rc1 [deleted] ffdd484ce

svn commit: r10577 - /release/flink/KEYS

Author: fhueske Date: Mon Sep 21 14:22:55 2015 New Revision: 10577 Log: Added my (fhueske's) public key Modified: release/flink/KEYS Modified: release/flink/KEYS == --- release/flink/KEYS (original) +++ release

flink git commit: [FLINK-2972] [JavaAPI] Remove Chill dependency from flink-java.

Repository: flink Updated Branches: refs/heads/master d5a6b13ab -> cd899f3be [FLINK-2972] [JavaAPI] Remove Chill dependency from flink-java. This closes #1331 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd899f3b

[4/4] flink-web git commit: rebuild website

rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/0507169a Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/0507169a Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/0507169a

[3/4] flink-web git commit: rebuild website

http://git-wip-us.apache.org/repos/asf/flink-web/blob/0507169a/content/blog/page2/index.html -- diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html index 445f2be..3d3cfaa 100644 ---

[1/3] flink git commit: [FLINK-3112] Remove unused RecordModelPostPass and replace JavaPlan by Plan.

Repository: flink Updated Branches: refs/heads/master 0cae3eae2 -> 4dbb10f52 [FLINK-3112] Remove unused RecordModelPostPass and replace JavaPlan by Plan. This closes #1436 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/3] flink git commit: [FLINK-3113] Remove unused and unsupported global-order methods from GenericDataSinkBase

[FLINK-3113] Remove unused and unsupported global-order methods from GenericDataSinkBase This closes #1435 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9547f08a Tree:

[3/3] flink git commit: [FLINK-3108] [java] JoinOperator's with() calls the wrong TypeExtractor method

[FLINK-3108] [java] JoinOperator's with() calls the wrong TypeExtractor method This closes #1440 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4dbb10f5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4dbb10f5 Diff:

flink git commit: [FLINK-3108] [java] JoinOperator's with() calls the wrong TypeExtractor method

Repository: flink Updated Branches: refs/heads/release-0.10 a36822100 -> 9268514b7 [FLINK-3108] [java] JoinOperator's with() calls the wrong TypeExtractor method Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9268514b

flink git commit: [FLINK-3147] Expose HadoopOutputFormatBase fields as protected

Repository: flink Updated Branches: refs/heads/release-0.10 f97803040 -> 85804c03c [FLINK-3147] Expose HadoopOutputFormatBase fields as protected Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/85804c03 Tree:

[1/2] flink git commit: [FLINK-2882] [core] Improve performance of string conversions - Memoize string representations of AbstractID. - Use lookup table for byte-to-hex conversion in StringUtils.

Repository: flink Updated Branches: refs/heads/master e24861886 -> 19cbc787b [FLINK-2882] [core] Improve performance of string conversions - Memoize string representations of AbstractID. - Use lookup table for byte-to-hex conversion in StringUtils. This closes #1455 Project:

[2/2] flink git commit: [FLINK-3147] Expose HadoopOutputFormatBase fields as protected

[FLINK-3147] Expose HadoopOutputFormatBase fields as protected This closes #1442 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/19cbc787 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/19cbc787 Diff:

<    1   2   3   4   5   6   7   8   9   10   >