[1/2] flink git commit: [hotfix] [kafka] Fix NPE in Kafka09Fetcher

Repository: flink Updated Branches: refs/heads/release-1.1 400c49ca0 -> 98b399d4b [hotfix] [kafka] Fix NPE in Kafka09Fetcher Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6f333616 Tree:

[2/2] flink git commit: [FLINK-4311] [hbase-connector] Fixed TableInputFormat to process multiple input splits.

[FLINK-4311] [hbase-connector] Fixed TableInputFormat to process multiple input splits. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/98b399d4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/98b399d4 Diff:

flink git commit: [FLINK-2662] [dataSet] [optimizer] Fix merging of unions with multiple outputs.

Repository: flink Updated Branches: refs/heads/master 5c02988b0 -> 303f6fee9 [FLINK-2662] [dataSet] [optimizer] Fix merging of unions with multiple outputs. Translate union with N outputs into N unions with single output. This closes #2508. Project:

flink git commit: [FLINK-3874] [tableApi] Add KafkaJsonTableSink

Repository: flink Updated Branches: refs/heads/master 481091043 -> abb449678 [FLINK-3874] [tableApi] Add KafkaJsonTableSink This closes #2244 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/abb44967 Tree:

flink git commit: [FLINK-3899] [docs] Add examples for incremental window computation.

Repository: flink Updated Branches: refs/heads/release-1.1 016c381cd -> 717fc906d [FLINK-3899] [docs] Add examples for incremental window computation. This closes #2368 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3866] StringArraySerializer does not treat type as immutable.

Repository: flink Updated Branches: refs/heads/master a497ebc80 -> 502ae585c [FLINK-3866] StringArraySerializer does not treat type as immutable. This closes #2289 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/502ae585

[3/3] flink git commit: [FLINK-3977] [dataStream] InternalWindowFunctions implement OutputTypeConfigurable.

[FLINK-3977] [dataStream] InternalWindowFunctions implement OutputTypeConfigurable. - setOutputType calls are forwarded to wrapped functions. - test added for InternalWindowFucntions. This closes #2118 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/3] flink git commit: [FLINK-3949] [metrics] Add numSplitsProcessed counter metric.

[FLINK-3949] [metrics] Add numSplitsProcessed counter metric. This closes #2119 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5a0c268d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5a0c268d Diff:

[1/3] flink git commit: [FLINK-3641] Add documentation for DataSet distributed cache.

Repository: flink Updated Branches: refs/heads/master bce355093 -> ba62df14a [FLINK-3641] Add documentation for DataSet distributed cache. This closes #2122 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba62df14 Tree:

[3/3] flink git commit: [FLINK-4077] [tableAPI] Register Pojo DataSet/DataStream as Table with field references.

[FLINK-4077] [tableAPI] Register Pojo DataSet/DataStream as Table with field references. This closes #2107 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/efc344a4 Tree:

[1/3] flink git commit: [FLINK-3650] [dataSet] Add maxBy/minBy to Scala DataSet API

Repository: flink Updated Branches: refs/heads/master b63e19b09 -> efc344a4e [FLINK-3650] [dataSet] Add maxBy/minBy to Scala DataSet API This closes #1856 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7cc69434 Tree:

[2/3] flink git commit: [FLINK-3649] [docs] Add documentation for DataSet minBy / maxBy.

[FLINK-3649] [docs] Add documentation for DataSet minBy / maxBy. This closes #2104 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/298c0092 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/298c0092 Diff:

[2/2] flink git commit: [FLINK-4024] [streaming] Fix InputFormat lifecycle in FileSourceFunction.

[FLINK-4024] [streaming] Fix InputFormat lifecycle in FileSourceFunction. This closes #2100 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fe0eb602 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fe0eb602 Diff:

[1/2] flink git commit: [FLINK-3908] [core] Fix resetting of FieldParser error state.

Repository: flink Updated Branches: refs/heads/master 867be9b6a -> fe0eb602d [FLINK-3908] [core] Fix resetting of FieldParser error state. This closes #2007 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8747978 Tree:

flink git commit: [FLINK-3323] [docs] Add documentation for NiFi connector.

Repository: flink Updated Branches: refs/heads/master d353895ba -> 8227b0f75 [FLINK-3323] [docs] Add documentation for NiFi connector. This closes #2099 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8227b0f7 Tree:

[2/2] flink git commit: [FLINK-3971] [tableAPI] Fix handling of null values in aggregations.

[FLINK-3971] [tableAPI] Fix handling of null values in aggregations. This closes #2049 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fdf43609 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fdf43609 Diff:

flink git commit: [FLINK-3944] [tableAPI] Add rewrite rules to reorder Cartesian products and joins.

Repository: flink Updated Branches: refs/heads/master 2bffd7b9e -> 85793a25a [FLINK-3944] [tableAPI] Add rewrite rules to reorder Cartesian products and joins. These rules are necessary to resolve join orders that initially contain Cartesian products due to the order in which base relations

flink git commit: [Flink-2971] [tableAPI] Add outer joins to the Table API and SQL.

Repository: flink Updated Branches: refs/heads/master 573a92fc5 -> cbc5f8303 [Flink-2971] [tableAPI] Add outer joins to the Table API and SQL. This closes #1981 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cbc5f830

[2/2] flink git commit: [FLINK-3941] [tableAPI] Add support for UNION to Table API.

[FLINK-3941] [tableAPI] Add support for UNION to Table API. - Fix FLINK-3696 (type issues of DataSetUnion by forwarding expected types to input operators). This closes #2025 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: [FLINK-3936] [tableAPI] Add MIN/MAX aggregation for Boolean.

Repository: flink Updated Branches: refs/heads/master ec38a212e -> ef5832d8f [FLINK-3936] [tableAPI] Add MIN/MAX aggregation for Boolean. This closes #2035 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5784f395 Tree:

[2/5] flink-web git commit: Rebuild website for Stream SQL blog post

t/news/2015/12/04/Introducing-windows.html @@ -160,7 +160,7 @@ 04 Dec 2015 by Fabian Hueske (https://twitter.com/fhueske;>@fhueske) -The data analysis space is witnessing an evolution from batch to stream processing for many use cases. Although batch can be handled as a spe

[3/5] flink-web git commit: Rebuild website for Stream SQL blog post

/blog/index.html @@ -161,6 +161,18 @@ + Stream Processing for Everyone with SQL and Apache Flink + 24 May 2016 by Fabian Hueske (https://twitter.com/fhueske;>@fhueske) + + About six months ago, the Apache Flink community started an effort to add a SQL interf

[1/5] flink-web git commit: Add Stream SQL blog post

he Flink" +date: 2016-05-24 10:00:00 +author: "Fabian Hueske" +author-twitter: "fhueske" +excerpt: "About six months ago, the Apache Flink community started an effort to add a SQL interface for stream data analysis. SQL is the standard language to access and

[2/2] flink git commit: [FLINK-3728] [tableAPI] Improve error message and documentation for unsupported SQL features.

[FLINK-3728] [tableAPI] Improve error message and documentation for unsupported SQL features. This closes #2018 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/78f55119 Tree:

[1/2] flink git commit: [FLINK-3955] [tableAPI] Rename Table.toSink() to Table.writeToSink().

Repository: flink Updated Branches: refs/heads/master 343d05a40 -> 78f551194 [FLINK-3955] [tableAPI] Rename Table.toSink() to Table.writeToSink(). This closes #2023 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [hotfix] [tableAPI] Moved tests to correct package.

Repository: flink Updated Branches: refs/heads/master 885fbaf66 -> 343d05a40 [hotfix] [tableAPI] Moved tests to correct package. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/343d05a4 Tree:

[4/4] flink git commit: [FLINK-3632] [tableAPI] Clean up TableAPI exceptions.

[FLINK-3632] [tableAPI] Clean up TableAPI exceptions. This closes #2015 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9cc62966 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9cc62966 Diff:

[2/4] flink git commit: [hotfix] [tableAPI] Throw helpful exception for unsupported ORDER BY features.

[hotfix] [tableAPI] Throw helpful exception for unsupported ORDER BY features. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/905ac6ed Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/905ac6ed Diff:

[2/4] flink git commit: [FLINK-3934] [tableAPI] Check for equi-join predicates before translation.

[FLINK-3934] [tableAPI] Check for equi-join predicates before translation. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3d6ce294 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3d6ce294 Diff:

[1/4] flink git commit: [hotfix] [tableAPI] Adapt tests to changed null-value support default

Repository: flink Updated Branches: refs/heads/master 09b428bd6 -> 996ad4e5b [hotfix] [tableAPI] Adapt tests to changed null-value support default Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/960f4acc Tree:

[3/4] flink git commit: [FLINK-3935] [optimizer] Fix check of key fields and ordering in PartitionNode.

[FLINK-3935] [optimizer] Fix check of key fields and ordering in PartitionNode. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/853a5359 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/853a5359 Diff:

[2/2] flink git commit: [FLINK-3926] [core] Fix NumberFormatException in TupleTypeInfo.getFieldIndex()

[FLINK-3926] [core] Fix NumberFormatException in TupleTypeInfo.getFieldIndex() This closes #2004 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db5ff636 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/db5ff636 Diff:

[1/3] flink git commit: [FLINK-3926] [core] Fix NumberFormatException in TupleTypeInfo.getFieldIndex()

Repository: flink Updated Branches: refs/heads/master fd3dba6ee -> 09b428bd6 [FLINK-3926] [core] Fix NumberFormatException in TupleTypeInfo.getFieldIndex() This closes #2004 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/5] flink git commit: [FLINK-3754] [tableAPI] Add validation phase to Table API before construction of RelNodes.

[FLINK-3754] [tableAPI] Add validation phase to Table API before construction of RelNodes. This closes #1958 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f0d543f8 Tree:

[5/5] flink git commit: [FLINK-3913] [docs] Clean up spelling mistakes.

[FLINK-3913] [docs] Clean up spelling mistakes. This closes #1992 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4fbd8eb9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4fbd8eb9 Diff:

[4/5] flink git commit: [FLINK-3900] [tableAPI] Set nullCheck=true as default in TableConfig.

[FLINK-3900] [tableAPI] Set nullCheck=true as default in TableConfig. This closes #1994 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f2e60575 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f2e60575 Diff:

[2/5] flink git commit: [FLINK-3754] [tableAPI] Add validation phase to Table API before construction of RelNodes.

http://git-wip-us.apache.org/repos/asf/flink/blob/f0d543f8/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/RexNodeTranslator.scala -- diff --git

flink git commit: [FLINK-3912] [docs] Fix errors in Batch Scala API Documentation, Join section

Repository: flink Updated Branches: refs/heads/master 96b353d98 -> a9fc71d85 [FLINK-3912] [docs] Fix errors in Batch Scala API Documentation, Join section This closes #1991 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3878] Fix support multiple identical temp directories in FileCache

Repository: flink Updated Branches: refs/heads/release-1.0 647525515 -> 4ae55cfd7 [FLINK-3878] Fix support multiple identical temp directories in FileCache This closes #1965 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [FLINK-3878] Fix support multiple identical temp directories in FileCache

[FLINK-3878] Fix support multiple identical temp directories in FileCache This closes #1965 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c90d365 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3c90d365 Diff:

[1/3] flink git commit: [FLINK-3856] [core] [api-extending] Create types for java.sql.Date/Time/Timestamp

Repository: flink Updated Branches: refs/heads/master 43bd6f6e4 -> 3c90d3654 [FLINK-3856] [core] [api-extending] Create types for java.sql.Date/Time/Timestamp This closes #1959 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/4] flink git commit: [hotfix] [tableAPI] Fix SQL queries on TableSources.

[hotfix] [tableAPI] Fix SQL queries on TableSources. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ed07933 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7ed07933 Diff:

[3/4] flink git commit: [FLINK-3842] [tableApi] Fix handling null record/row in generated code

[FLINK-3842] [tableApi] Fix handling null record/row in generated code This closes #1974 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/08e80546 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/08e80546 Diff:

[1/4] flink git commit: [FLINK-3821] [dataSet] Remove Guava usage in flink-java non-test files.

Repository: flink Updated Branches: refs/heads/master 05c765e57 -> 43bd6f6e4 [FLINK-3821] [dataSet] Remove Guava usage in flink-java non-test files. - replaced CharSets with StandardCharsets - added checkElementIndex to Flink Preconditions - replaced Guava Preconditions with Flink

[03/10] flink git commit: [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

http://git-wip-us.apache.org/repos/asf/flink/blob/70978f56/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java -- diff --git

[04/10] flink git commit: [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

http://git-wip-us.apache.org/repos/asf/flink/blob/70978f56/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YarnTestBase.java -- diff --git a/flink-yarn-tests/src/main/java/org/apache/flink/yarn/YarnTestBase.java

[08/10] flink git commit: [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

http://git-wip-us.apache.org/repos/asf/flink/blob/70978f56/flink-test-utils/src/main/java/org/apache/flink/test/testdata/WordCountData.java -- diff --git

[02/10] flink git commit: [FLINK-3519] [core] Add warning about subclasses to Tuple JavaDocs.

[FLINK-3519] [core] Add warning about subclasses to Tuple JavaDocs. - Bring TupleGenerator up to date with the Tuple classes. This closes #1724 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f186446d Tree:

[10/10] flink git commit: [FLINK-1996] [tableApi] Add TableSink interface to emit tables to external storage.

[FLINK-1996] [tableApi] Add TableSink interface to emit tables to external storage. - Add a CsvTableSink This closes #1961 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/13bce315 Tree:

[06/10] flink git commit: [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

http://git-wip-us.apache.org/repos/asf/flink/blob/70978f56/flink-test-utils/src/test/java/org/apache/flink/test/testdata/WordCountData.java -- diff --git

[09/10] flink git commit: [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

[FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies. This closes #1915 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/70978f56 Tree:

[07/10] flink git commit: [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

http://git-wip-us.apache.org/repos/asf/flink/blob/70978f56/flink-test-utils/src/main/scala/org/apache/flink/test/util/ForkableFlinkMiniCluster.scala -- diff --git

flink git commit: [FLINK-2946] Add support for orderBy() to batch Table API and SQL.

Repository: flink Updated Branches: refs/heads/master c81151e4e -> a5ad7d913 [FLINK-2946] Add support for orderBy() to batch Table API and SQL. This closes #1926. Closed because CsvTableSource has been implemented. This closes #939. Project:

flink git commit: [FLINK-2828] [tableAPI] Add TableSource interfaces for external tables.

Repository: flink Updated Branches: refs/heads/master 80b09eaef -> 4f5dbc2ed [FLINK-2828] [tableAPI] Add TableSource interfaces for external tables. - Add CsvTableSource as a reference implementation for TableSources. This closes #1939 Project:

flink git commit: [FLINK-3835] [optimizer] Add input id to JSON plan to resolve ambiguous input names.

Repository: flink Updated Branches: refs/heads/release-1.0 014a686ec -> 4a34f6f73 [FLINK-3835] [optimizer] Add input id to JSON plan to resolve ambiguous input names. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3835] [optimizer] Add input id to JSON plan to resolve ambiguous input names.

Repository: flink Updated Branches: refs/heads/master 130a22d6c -> 80b09eaef [FLINK-3835] [optimizer] Add input id to JSON plan to resolve ambiguous input names. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80b09eae

flink git commit: [hotfix] [tableAPI] Fix DataStreamScanRule, fix indention, improve class names.

Repository: flink Updated Branches: refs/heads/master 7498d3e35 -> 8305c1755 [hotfix] [tableAPI] Fix DataStreamScanRule, fix indention, improve class names. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8305c175 Tree:

[2/3] flink git commit: [FLINK-2998] [dataSet] Add support for explicit range partitioning for joins and coGroup.

[FLINK-2998] [dataSet] Add support for explicit range partitioning for joins and coGroup. This closes #1838 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/605b6d87 Tree:

[1/3] flink git commit: [FLINK-3665] [dataSet] Add support for sort orders in range partitioning.

Repository: flink Updated Branches: refs/heads/master c33325e3f -> a43bade0d [FLINK-3665] [dataSet] Add support for sort orders in range partitioning. This closes #1848 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [FLINK-3781] Ensure BlobClient is closed.

[FLINK-3781] Ensure BlobClient is closed. This closes #1908 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a43bade0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a43bade0 Diff:

flink git commit: [FLINK-3657] [dataSet] Change access of DataSetUtils.countElements() to 'public'

Repository: flink Updated Branches: refs/heads/master d938c5f59 -> 5f993c65e [FLINK-3657] [dataSet] Change access of DataSetUtils.countElements() to 'public' This closes #1829 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/3] flink git commit: [FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals()

Repository: flink Updated Branches: refs/heads/release-1.0 aadc5fad5 -> c1eb247e9 [FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5b69dd8c Tree:

[3/3] flink git commit: [FLINK-2544] [docs] Add Java 8 version for building PowerMock tests to docs

[FLINK-2544] [docs] Add Java 8 version for building PowerMock tests to docs Java 8 update 11 introduced a stricter bytecode verifier that leads to failures in unit tests that use the PowerMock runner. The tests run correctly in Java 8u51 or above. Project:

[2/3] flink git commit: [FLINK-3762] [core] Enable Kryo reference tracking

[FLINK-3762] [core] Enable Kryo reference tracking Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b4b08ca2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b4b08ca2 Diff:

[11/12] flink git commit: [FLINK-3762] [core] Enable Kryo reference tracking

[FLINK-3762] [core] Enable Kryo reference tracking This closes #1891 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dc78a747 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dc78a747 Diff:

[02/12] flink git commit: [FLINK-3700] [core] Remove Guava dependency from flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/760a0d9e/flink-core/src/main/java/org/apache/flink/types/StringValue.java -- diff --git a/flink-core/src/main/java/org/apache/flink/types/StringValue.java

[01/12] flink git commit: [FLINK-3700] [core] Remove Guava dependency from flink-core

Repository: flink Updated Branches: refs/heads/master 1b93b3242 -> d938c5f59 http://git-wip-us.apache.org/repos/asf/flink/blob/760a0d9e/flink-runtime/src/test/java/org/apache/flink/runtime/util/MathUtilTest.java -- diff --git

[08/12] flink git commit: [FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.

http://git-wip-us.apache.org/repos/asf/flink/blob/1acd8445/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/AsITCase.java -- diff --git

[05/12] flink git commit: [FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals()

[FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals() This closes #1871 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f3d3a449 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f3d3a449 Diff:

[09/12] flink git commit: [FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.

http://git-wip-us.apache.org/repos/asf/flink/blob/1acd8445/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/scala/table/TableConversions.scala -- diff --git

[03/12] flink git commit: [FLINK-3700] [core] Remove Guava dependency from flink-core

[FLINK-3700] [core] Remove Guava dependency from flink-core Almost all Guava functionality used within flink-core has corresponding utils in Flink's codebase, or the JDK library. This replaces the Guava code as follows - Preconditions calls by Flink's Preconditions class - Collection utils

[10/12] flink git commit: [FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.

[FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext. - Removes Translators (JavaBatchTranslator, ScalaBatchTranslator, JavaStreamTranslator, ScalaStreamTranslator) - Removes TranslationContext - Creates TableEnvironments for Java/Scala DataSet/DataStream

[12/12] flink git commit: [FLINK-3759] [table] Throw exception if NULL literal is encountered in non-null mode.

[FLINK-3759] [table] Throw exception if NULL literal is encountered in non-null mode. This closes #1892 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/722155a1 Tree:

[06/12] flink git commit: [FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.

http://git-wip-us.apache.org/repos/asf/flink/blob/1acd8445/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/CastingITCase.scala -- diff --git

flink git commit: [FLINK-3736] [tableAPI] Move toRexNode logic into each expression's implementation.

Repository: flink Updated Branches: refs/heads/master 427de663c -> ba46ab6b6 [FLINK-3736] [tableAPI] Move toRexNode logic into each expression's implementation. This closes #1870 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [FLINK-2444] Add tests for HadoopInputFormats

[FLINK-2444] Add tests for HadoopInputFormats Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1ca4f36d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1ca4f36d Diff:

[1/3] flink git commit: [FLINK-2445] Add tests for HadoopOutputFormats

Repository: flink Updated Branches: refs/heads/release-1.0 1909bdb41 -> 1ca4f36d0 [FLINK-2445] Add tests for HadoopOutputFormats Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/edf343ab Tree:

[2/3] flink git commit: [FLINK-2445] Improve HadoopOutputFormatTests

[FLINK-2445] Improve HadoopOutputFormatTests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da989c42 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/da989c42 Diff:

[2/4] flink git commit: [FLINK-2445] Add tests for HadoopOutputFormats

[FLINK-2445] Add tests for HadoopOutputFormats This closes #1486 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8e4a001b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8e4a001b Diff:

[4/4] flink git commit: [FLINK-2997] [dataSet] Add support for range partitioning with custom data distribution.

[FLINK-2997] [dataSet] Add support for range partitioning with custom data distribution. This closes #1776 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8299bf9 Tree:

[3/4] flink git commit: [FLINK-2444] Add tests for HadoopInputFormats

[FLINK-2444] Add tests for HadoopInputFormats This closes #1628 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a6c3778f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a6c3778f Diff:

[1/4] flink git commit: [FLINK-2445] Improve HadoopOutputFormatTests

Repository: flink Updated Branches: refs/heads/master f7a3c8104 -> b8299bf92 [FLINK-2445] Improve HadoopOutputFormatTests This closes #1628 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bcb34dd5 Tree:

[2/2] flink git commit: [FLINK-3179] [dataSet][optimizer] Log a WARN message if combiner is not added in front of PartitionOperator

[FLINK-3179] [dataSet][optimizer] Log a WARN message if combiner is not added in front of PartitionOperator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd5773ed Tree:

[1/2] flink git commit: [FLINK-3602] Fix TypeExtractor and add support for recursive types

Repository: flink Updated Branches: refs/heads/release-1.0 954cdc113 -> cd5773ed3 [FLINK-3602] Fix TypeExtractor and add support for recursive types Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0880c594 Tree:

[4/4] flink git commit: [FLINK-3611] [docs] Correct link in CONTRIBUTING.md

[FLINK-3611] [docs] Correct link in CONTRIBUTING.md This closes #1786 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/77c867a6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/77c867a6 Diff:

[3/4] flink git commit: [FLINK-3631] [tableAPI] Check type compatibility for comparison expressions in CodeGenerator

[FLINK-3631] [tableAPI] Check type compatibility for comparison expressions in CodeGenerator This closes #1823 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/22d327f0 Tree:

[2/4] flink git commit: [FLINK-3602] Fix TypeExtractor and add support for recursive types

[FLINK-3602] Fix TypeExtractor and add support for recursive types This closes #1787 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7785288a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7785288a Diff:

[flink] Git Push Summary

Repository: flink Updated Branches: refs/heads/tableOnCalcite [deleted] 9dfed3427

flink git commit: [FLINK-3621] [docs] Improve documentation of memory configuration parameters

Repository: flink Updated Branches: refs/heads/master 543c04949 -> 40d5205bc [FLINK-3621] [docs] Improve documentation of memory configuration parameters This closes #1801 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3621] [docs] Improve documentation of memory configuration parameters

Repository: flink Updated Branches: refs/heads/release-1.0 165065c3e -> 6749874dc [FLINK-3621] [docs] Improve documentation of memory configuration parameters This closes #1801 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3333] [docs] Improve documentation of DataSet object-reuse modes.

Repository: flink Updated Branches: refs/heads/release-1.0 3d8c7c1ea -> 165065c3e [FLINK-] [docs] Improve documentation of DataSet object-reuse modes. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/165065c3 Tree:

[1/3] flink git commit: [FLINK-3596] DataSet RelNode refactoring

Repository: flink Updated Branches: refs/heads/tableOnCalcite e34e43954 -> d720b002a http://git-wip-us.apache.org/repos/asf/flink/blob/22621e02/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala

[3/3] flink git commit: [FLINK-3596] Finalized DataSet RelNode refactoring

[FLINK-3596] Finalized DataSet RelNode refactoring Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d720b002 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d720b002 Diff:

[2/3] flink git commit: [FLINK-3596] DataSet RelNode refactoring

[FLINK-3596] DataSet RelNode refactoring - remove the intermediate flink relnode layer and the dataset rules - move code generation from rules to DataSet nodes - remove unused DataSete nodes - move code generation from join rule to DataSetJoin node - merge DataSetMap and DataSetReduce into

[2/2] flink git commit: [FLINK-3498] Implement TRIM, SUBSTRING as reference design for Table API

[FLINK-3498] Implement TRIM, SUBSTRING as reference design for Table API Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d940c366 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d940c366 Diff:

[1/2] flink git commit: [FLINK-3486] [tableAPI] Fix broken renaming of all fields.

Repository: flink Updated Branches: refs/heads/tableOnCalcite 031d6f745 -> d940c3663 [FLINK-3486] [tableAPI] Fix broken renaming of all fields. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5fe9357f Tree:

flink git commit: [FLINK-3502] Add test case. Bug was resolved by a previous commit.

Repository: flink Updated Branches: refs/heads/tableOnCalcite 4a63e2914 -> e097cf7db [FLINK-3502] Add test case. Bug was resolved by a previous commit. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e097cf7d Tree:

[2/2] flink git commit: [FLINK-3385] [runtime] Fix outer join skipping unprobed partitions

[FLINK-3385] [runtime] Fix outer join skipping unprobed partitions This closes #1680 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1c48e346 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1c48e346 Diff:

[1/2] flink git commit: [hotfix] [runtime] Fix processing unmatched build-side when all buckets spilled

Repository: flink Updated Branches: refs/heads/master 8656ed5ea -> 1c48e3462 [hotfix] [runtime] Fix processing unmatched build-side when all buckets spilled Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/03923c34 Tree:

[1/2] flink git commit: [FLINK-3226] Casting support for arithmetic operators

Repository: flink Updated Branches: refs/heads/tableOnCalcite 7233c241d -> 1c53c873a [FLINK-3226] Casting support for arithmetic operators Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9d765d08 Tree:

<    6   7   8   9   10   11   12   13   14   15   >