[4/5] flink git commit: [javaDocs] Fix JavaDoc examples in tumbling and sliding time windows

[javaDocs] Fix JavaDoc examples in tumbling and sliding time windows This closes #1490 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d31b00d3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d31b00d3 Diff:

[1/5] flink git commit: [refactor] Change if-else conditions to switch-case statements.

Repository: flink Updated Branches: refs/heads/master c674a6558 -> 08c81378b [refactor] Change if-else conditions to switch-case statements. This closes #1485 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/54b89b95

[2/8] flink git commit: [FLINK-7] Add range partitioning with automatic sampling of key distribution

[FLINK-7] Add range partitioning with automatic sampling of key distribution This closes #1255 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f5957ce3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f5957ce3 Diff:

[1/8] flink git commit: [FLINK-7] Add range partitioning with automatic sampling of key distribution

Repository: flink Updated Branches: refs/heads/master aec6ded5e -> c08bcf1e0 http://git-wip-us.apache.org/repos/asf/flink/blob/f5957ce3/flink-tests/src/test/scala/org/apache/flink/api/scala/operators/PartitionITCase.scala --

[7/8] flink git commit: [FLINK-3180] [runtime] Log direct memory usage in MemoryLogger

[FLINK-3180] [runtime] Log direct memory usage in MemoryLogger - The off-heap stats reported by the memory logger didn't include direct memory. This closes #1466 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af996301

[5/8] flink git commit: [FLINK-3180] [runtime] Log direct memory usage in MemoryLogger

http://git-wip-us.apache.org/repos/asf/flink/blob/af996301/flink-runtime-web/web-dashboard/web/partials/taskmanager/taskmanager.metrics.html -- diff --git

[3/8] flink git commit: [FLINK-7] Prevent range partitioning inside iterations.

[FLINK-7] Prevent range partitioning inside iterations. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a6a05288 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a6a05288 Diff:

[4/8] flink git commit: [FLINK-3116] Remove RecordOperator

[FLINK-3116] Remove RecordOperator This closes #1444 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba2aba80 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ba2aba80 Diff:

[6/8] flink git commit: [FLINK-3180] [runtime] Log direct memory usage in MemoryLogger

http://git-wip-us.apache.org/repos/asf/flink/blob/af996301/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

[1/2] flink git commit: [docs] Fix typos in streaming documentation

Repository: flink Updated Branches: refs/heads/release-0.10 0b6adc4c5 -> 16e5ab09f [docs] Fix typos in streaming documentation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/efbfc6ae Tree:

[2/2] flink git commit: [docs][hotfix] Fix wrong window definitions in the docs

[docs][hotfix] Fix wrong window definitions in the docs This closes #1407 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/16e5ab09 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/16e5ab09 Diff:

[6/8] flink git commit: [FLINK-3059] Improve JavaDocs for DataSet.writeAsText()

[FLINK-3059] Improve JavaDocs for DataSet.writeAsText() Currently the JavaDocs of writeAsText() state it simply generates a file, but this is not always true and it depends on the environment configuration. This commit improves the JavaDocs of writeAsText(). This closes #1392 Project:

[3/8] flink git commit: [FLINK-2906] Remove Record API

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

[2/8] flink git commit: [FLINK-2906] Remove Record API

http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-java/src/test/java/org/apache/flink/api/java/record/ReduceWrappingFunctionTest.java -- diff --git

[1/8] flink git commit: [FLINK-2906] Remove Record API

Repository: flink Updated Branches: refs/heads/master 8fddbf06c -> dcce6def9 http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-test-utils/src/main/java/org/apache/flink/test/util/RecordAPITestBase.java -- diff

[8/8] flink git commit: [docs][hotfix] Fix wrong window definitions in the docs

[docs][hotfix] Fix wrong window definitions in the docs This closes #1407 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dcce6def Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dcce6def Diff:

[7/8] flink git commit: [typo-fix] Fix typo in DelimitedInputFormat.java

[typo-fix] Fix typo in DelimitedInputFormat.java This closes #1405 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/804611ce Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/804611ce Diff:

[4/8] flink git commit: [FLINK-2906] Remove Record API

http://git-wip-us.apache.org/repos/asf/flink/blob/c787a037/flink-java/src/main/java/org/apache/flink/api/java/record/io/DelimitedOutputFormat.java -- diff --git

[04/16] flink git commit: Remove deprecation warning suppressions

Remove deprecation warning suppressions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/348d5016 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/348d5016 Diff:

[02/16] flink git commit: Remove Record API program tests

http://git-wip-us.apache.org/repos/asf/flink/blob/f84f/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/TPCHQuery3WithUnionITCase.java -- diff --git

[01/16] flink git commit: Remove Record API program tests

Repository: flink Updated Branches: refs/heads/master 5558e7688 -> ebba20dfa http://git-wip-us.apache.org/repos/asf/flink/blob/f84f/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/WebLogAnalysisITCase.java

[15/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #1

http://git-wip-us.apache.org/repos/asf/flink/blob/8abae2c2/flink-tests/src/test/java/org/apache/flink/test/iterative/IterationTerminationWithTwoTails.java -- diff --git

[06/16] flink git commit: Move operator ITCases into correct package

Move operator ITCases into correct package Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8543dd90 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8543dd90 Diff:

[11/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #2

http://git-wip-us.apache.org/repos/asf/flink/blob/ebba20df/flink-tests/src/test/java/org/apache/flink/test/recordJobs/kmeans/udfs/PointInFormat.java -- diff --git

[05/16] flink git commit: Remove ITCases for Record API operators

Remove ITCases for Record API operators Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/50ced5e3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/50ced5e3 Diff:

[09/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #2

http://git-wip-us.apache.org/repos/asf/flink/blob/ebba20df/flink-tests/src/test/java/org/apache/flink/test/recordJobs/util/InfiniteIntegerInputFormatWithDelay.java -- diff --git

[13/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #2

[FLINK-2901] Remove Record API dependencies from flink-tests #2 This closes #1306 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ebba20df Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ebba20df Diff:

[12/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #2

http://git-wip-us.apache.org/repos/asf/flink/blob/ebba20df/flink-tests/src/test/java/org/apache/flink/test/recordJobs/graph/EnumTrianglesWithDegrees.java -- diff --git

[14/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #1

http://git-wip-us.apache.org/repos/asf/flink/blob/8abae2c2/flink-tests/src/test/java/org/apache/flink/test/testPrograms/util/tests/TupleTest.java -- diff --git

[16/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #1

[FLINK-2901] Remove Record API dependencies from flink-tests #1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8abae2c2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8abae2c2 Diff:

[07/16] flink git commit: Remove Record API dependencies from WordCount compiler test

Remove Record API dependencies from WordCount compiler test Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d353ef49 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d353ef49 Diff:

[10/16] flink git commit: [FLINK-2901] Remove Record API dependencies from flink-tests #2

http://git-wip-us.apache.org/repos/asf/flink/blob/ebba20df/flink-tests/src/test/java/org/apache/flink/test/recordJobs/relational/WebLogAnalysis.java -- diff --git

[4/4] flink git commit: [FLINK-3192] [TableAPI] Add explain support to print the sql-execution plan.

[FLINK-3192] [TableAPI] Add explain support to print the sql-execution plan. This closes #1477 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dbbab0a9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dbbab0a9 Diff:

[2/4] flink git commit: [FLINK-3218] Fix overriding of user parameters when merging Hadoop configurations

[FLINK-3218] Fix overriding of user parameters when merging Hadoop configurations This closes #1496 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ee0bc131 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ee0bc131

[1/4] flink git commit: [FLINK-3189] Fix argument parsing of CLI client INFO action

Repository: flink Updated Branches: refs/heads/master a065ed091 -> dbbab0a90 [FLINK-3189] Fix argument parsing of CLI client INFO action This closes #1493 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a5b05566 Tree:

[3/4] flink git commit: [FLINK-3224] [DataStream] Call setInputType() on output formats that implement InputTypeConfigurable

[FLINK-3224] [DataStream] Call setInputType() on output formats that implement InputTypeConfigurable This closes #1497 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b474da62 Tree:

[1/3] flink git commit: [FLINK-3189] Fix argument parsing of CLI client INFO action

Repository: flink Updated Branches: refs/heads/release-0.10 1d05dbe54 -> a726da6d1 [FLINK-3189] Fix argument parsing of CLI client INFO action This closes #1493 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ab2f14a0

[3/3] flink git commit: [FLINK-3224] [DataStream] Call setInputType() on output formats that implement InputTypeConfigurable

[FLINK-3224] [DataStream] Call setInputType() on output formats that implement InputTypeConfigurable This closes #1497 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a726da6d Tree:

[2/3] flink git commit: [FLINK-3218] Fix overriding of user parameters when merging Hadoop configurations

[FLINK-3218] Fix overriding of user parameters when merging Hadoop configurations This closes #1496 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e6e0fd92 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e6e0fd92

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

[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/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:

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

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:

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

[flink] Git Push Summary

Repository: flink Updated Branches: refs/heads/tableOnCalcite [created] a65cd8db1

[2/2] flink git commit: [Refactor] [DataSet] Refactor key selector translation in DataSet API. Clean up several compiler warnings.

[Refactor] [DataSet] Refactor key selector translation in DataSet API. Clean up several compiler warnings. This closes #1509 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/544abb93 Tree:

[1/2] flink git commit: [Refactor] [DataSet] Refactor key selector translation in DataSet API. Clean up several compiler warnings.

Repository: flink Updated Branches: refs/heads/master 153a67881 -> 544abb937 http://git-wip-us.apache.org/repos/asf/flink/blob/544abb93/flink-java/src/main/java/org/apache/flink/api/java/operators/ReduceOperator.java -- diff

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

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

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

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

flink git commit: [FLINK-3226] Add DataSet scan and conversion to DataSet[Row]

Repository: flink Updated Branches: refs/heads/tableOnCalcite 297564646 -> 1f3eda984 [FLINK-3226] Add DataSet scan and conversion to DataSet[Row] This closes #1579. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[28/50] [abbrv] flink git commit: [FLINK-3391] [tests] Fix typo in test config

[FLINK-3391] [tests] Fix typo in test config Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ed7d3da7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ed7d3da7 Diff:

[31/50] [abbrv] flink git commit: [FLINK-3389] [rocksdb] Add pre-defined option profiles.

[FLINK-3389] [rocksdb] Add pre-defined option profiles. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/be72758d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/be72758d Diff:

[19/50] [abbrv] flink git commit: [FLINK-3350] [tests] Increase default test Akka ask and ZooKeeper timeouts

[FLINK-3350] [tests] Increase default test Akka ask and ZooKeeper timeouts Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8f40251 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b8f40251 Diff:

[14/50] [abbrv] flink git commit: [FLINK-3366] Rename @Experimental annotation to @PublicEvolving

[FLINK-3366] Rename @Experimental annotation to @PublicEvolving This closes #1599 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/572855da Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/572855da Diff:

[42/50] [abbrv] flink git commit: [FLINK-3225] Implemented optimization of Table API queries via Calcite

[FLINK-3225] Implemented optimization of Table API queries via Calcite - added logical Flink nodes and translation rules - added stubs for DataSet translation rules - ported DataSetNodes to Scala - reactivated tests and added expected NotImplementedError Project:

[03/50] [abbrv] flink git commit: [FLINK-3357] [core] Drop AbstractID#toShortString()

[FLINK-3357] [core] Drop AbstractID#toShortString() This closes #1601 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28feede7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/28feede7 Diff:

[40/50] [abbrv] flink git commit: [FLINK-3225] Implemented optimization of Table API queries via Calcite

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

[11/50] [abbrv] flink git commit: [build system] Skip javadoc generation for java8 and snapshot deployments

[build system] Skip javadoc generation for java8 and snapshot deployments Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/59b237b5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/59b237b5 Diff:

[20/50] [abbrv] flink git commit: [hotfix] [tests] Ignore ZooKeeper logs in process tests

[hotfix] [tests] Ignore ZooKeeper logs in process tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3a643c07 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3a643c07 Diff:

[09/50] [abbrv] flink git commit: [hotfix] Add missing entries to condif reference doc and removed outdated webclient entries

[hotfix] Add missing entries to condif reference doc and removed outdated webclient entries Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/72f8228a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/72f8228a Diff:

[15/50] [abbrv] flink git commit: [FLINK-3234] [dataSet] Add KeySelector support to sortPartition operation.

[FLINK-3234] [dataSet] Add KeySelector support to sortPartition operation. This closes #1585 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0a63797a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0a63797a Diff:

[43/50] [abbrv] flink git commit: [FLINK-3226] Implement a CodeGenerator for an efficient translation to DataSet programs

http://git-wip-us.apache.org/repos/asf/flink/blob/a4ad9dd5/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RenamingProxyTypeInfo.scala -- diff --git

[35/50] [abbrv] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

http://git-wip-us.apache.org/repos/asf/flink/blob/ed6cc91e/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/VerifyNoNestedAggregates.scala -- diff --git

[23/50] [abbrv] flink git commit: [FLINK-3260] [runtime] Enforce terminal state of Executions

[FLINK-3260] [runtime] Enforce terminal state of Executions This commit fixes the problem that Executions could leave their terminal state FINISHED to transition to FAILED. Such a transition will be propagated to the ExecutionGraph where it entails JobStatus changes. Since the Execution already

[50/50] [abbrv] flink git commit: [FLINK-3226] implement getUniqueName method in TranslationContext

[FLINK-3226] implement getUniqueName method in TranslationContext This closes #1600 and #1567 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e7428263 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e7428263 Diff:

[39/50] [abbrv] flink git commit: [Flink-3226] Translate logical plan FlinkRels into physical plan DataSetRels.

[Flink-3226] Translate logical plan FlinkRels into physical plan DataSetRels. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6dd2d779 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6dd2d779 Diff:

[46/50] [abbrv] flink git commit: [FLINK-3226] implement GroupReduce translation; enable tests for supported operations

http://git-wip-us.apache.org/repos/asf/flink/blob/18e7f2f4/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/ExpressionsITCase.scala -- diff --git

[33/50] [abbrv] flink git commit: [hotfix][travis] deploy snapshots only for master branch

[hotfix][travis] deploy snapshots only for master branch Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1dee62b4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1dee62b4 Diff:

[13/50] [abbrv] flink git commit: [FLINK-3366] Rename @Experimental annotation to @PublicEvolving

http://git-wip-us.apache.org/repos/asf/flink/blob/572855da/flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java -- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java

[18/50] [abbrv] flink git commit: [FLINK-3341] Make 'auto.offset.reset' compatible with Kafka 0.8 and 0.9

[FLINK-3341] Make 'auto.offset.reset' compatible with Kafka 0.8 and 0.9 This closes #1597 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9173825a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9173825a Diff:

[16/50] [abbrv] flink git commit: [docs] Fixed typo in Storm Compatibility page

[docs] Fixed typo in Storm Compatibility page This closes #1618 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aeee6efd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/aeee6efd Diff:

[07/50] [abbrv] flink git commit: [FLINK-3286] Remove the files from the debian packaging as well

[FLINK-3286] Remove the files from the debian packaging as well Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a4f0692e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a4f0692e Diff:

[27/50] [abbrv] flink git commit: [FLINK-3369] [runtime] Make RemoteTransportException instance of CancelTaskException

[FLINK-3369] [runtime] Make RemoteTransportException instance of CancelTaskException Problem: RemoteTransportException (RTE) is thrown on data transfer failures when the remote data producer fails. Because RTE is an instance of IOException, it can happen that the RTE is reported as the root job

[34/50] [abbrv] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

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

[45/50] [abbrv] flink git commit: [FLINK-3226] Implement a CodeGenerator for an efficient translation to DataSet programs

[FLINK-3226] Implement a CodeGenerator for an efficient translation to DataSet programs This closes #1595 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a4ad9dd5 Tree:

[12/50] [abbrv] flink git commit: [FLINK-3366] Rename @Experimental annotation to @PublicEvolving

http://git-wip-us.apache.org/repos/asf/flink/blob/572855da/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala -- diff --git

[38/50] [abbrv] flink git commit: [FLINK-3225] Enforce translation to DataSetNodes

[FLINK-3225] Enforce translation to DataSetNodes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3cb76fcb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3cb76fcb Diff:

[24/50] [abbrv] flink git commit: [FLINK-3107] [runtime] Start checkpoint ID counter with periodic scheduler

[FLINK-3107] [runtime] Start checkpoint ID counter with periodic scheduler Problem: The job manager enables checkpoints during submission of streaming programs. This can lead to call to a call to `ZooKeeperCheckpointIDCounter.start()`, which communicates with ZooKeeper. This can block the job

[32/50] [abbrv] flink git commit: [FLINK-3358] [FLINK-3351] [rocksdb] Add simple constructors and automatic temp path configuration

[FLINK-3358] [FLINK-3351] [rocksdb] Add simple constructors and automatic temp path configuration This adds constructors that only take a backup dir URI and use it to initialize both the RocksDB file backups and the FileSystem state backend for non-partitioned state. Also, the

[26/50] [abbrv] flink git commit: [FLINK-3384] [kafka] Add ClosableQueue for message exchanges between Kafka Threads

[FLINK-3384] [kafka] Add ClosableQueue for message exchanges between Kafka Threads Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd324ea7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fd324ea7 Diff:

[04/50] [abbrv] flink git commit: [hotfix] Update comments in 'ChainingStrategy' and remove outdated 'FORCE_ALWAYS' constant

[hotfix] Update comments in 'ChainingStrategy' and remove outdated 'FORCE_ALWAYS' constant Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9c83ea2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9c83ea2 Diff:

[10/50] [abbrv] flink git commit: [FLINK-3373] [build] Revert HTTP Components versions because of incompatibility with Hadoop >= 2.6.0

[FLINK-3373] [build] Revert HTTP Components versions because of incompatibility with Hadoop >= 2.6.0 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/de231d74 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/de231d74

[30/50] [abbrv] flink git commit: [FLINK-3271] [build] Don't exclude jetty-util dependency from the Hadoop dependencies

[FLINK-3271] [build] Don't exclude jetty-util dependency from the Hadoop dependencies This closes #1543 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82c7383a Tree:

[22/50] [abbrv] flink git commit: [hotfix] [tests] Reset state to allow retry on failure

[hotfix] [tests] Reset state to allow retry on failure This closes #1611 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/48b74546 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/48b74546 Diff:

[48/50] [abbrv] flink git commit: [FLINK-3282] add FlinkRelNode interface.

[FLINK-3282] add FlinkRelNode interface. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20235e0a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/20235e0a Diff:

[05/50] [abbrv] flink git commit: [hotfix] Cleanup routing of records in OperatorChain

[hotfix] Cleanup routing of records in OperatorChain Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28c6254e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/28c6254e Diff:

[02/50] [abbrv] flink git commit: [hotfix] typo IllegalArgumentException

[hotfix] typo IllegalArgumentException This closes #1602 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c47f385 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c47f385 Diff:

[49/50] [abbrv] flink git commit: [FLINK-3226] Add DataSet scan and conversion to DataSet[Row]

[FLINK-3226] Add DataSet scan and conversion to DataSet[Row] This closes #1579. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/99f60c84 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/99f60c84 Diff:

[29/50] [abbrv] flink git commit: [FLINK-3364] [runtime, yarn] Move SavepointStore initialization out of JobManager constructor

[FLINK-3364] [runtime, yarn] Move SavepointStore initialization out of JobManager constructor This closes #1622. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dcea46e8 Tree:

[21/50] [abbrv] flink git commit: [hotfix] [tests] Log retry rule failures on warn level

[hotfix] [tests] Log retry rule failures on warn level Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/756cbaff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/756cbaff Diff:

[06/50] [abbrv] flink git commit: [FLINK-3355] [rocksdb backend] Allow passing options to the RocksDB backend.

[FLINK-3355] [rocksdb backend] Allow passing options to the RocksDB backend. This also cleans up the generics in the RocksDB state classes. This closes #1608 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9ee16794 Tree:

[4/4] flink git commit: [FLINK-3366] Rename @Experimental annotation to @PublicEvolving

[FLINK-3366] Rename @Experimental annotation to @PublicEvolving This closes #1599 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/572855da Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/572855da Diff:

[1/4] flink git commit: [FLINK-3234] [dataSet] Add KeySelector support to sortPartition operation.

Repository: flink Updated Branches: refs/heads/master 59b237b5d -> 0a63797a6 [FLINK-3234] [dataSet] Add KeySelector support to sortPartition operation. This closes #1585 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

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