[2/2] flink git commit: [FLINK-3226] Translation of explicit casting

[FLINK-3226] Translation of explicit casting Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1c53c873 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1c53c873 Diff:

[7/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-streaming-java and flink-streaming-scala

http://git-wip-us.apache.org/repos/asf/flink/blob/c9db63b9/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java -- diff --git

[1/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-java and flink-scala

Repository: flink Updated Branches: refs/heads/master 937963e33 -> c9db63b93 http://git-wip-us.apache.org/repos/asf/flink/blob/e5f33b6d/flink-java/src/main/java/org/apache/flink/api/java/operators/translation/TupleRightUnwrappingJoiner.java

[4/8] flink git commit: [FLINK-3367] Add PublicEvolving and Internal annotations to flink-core

http://git-wip-us.apache.org/repos/asf/flink/blob/53f8d773/flink-core/src/main/java/org/apache/flink/api/common/operators/base/CrossOperatorBase.java -- diff --git

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

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:

[2/3] flink git commit: [FLINK-3161] [dist] Externalize cluster start-up and tear-down when available

[FLINK-3161] [dist] Externalize cluster start-up and tear-down when available Parallelizes cluster start-up and tear-down when pdsh is available This closes #1523 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7d19115

[3/3] flink git commit: [FLINK-3254] [dataSet] Adding functionality to support the CombineFunction contract.

[FLINK-3254] [dataSet] Adding functionality to support the CombineFunction contract. This closes #1568 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aabb2688 Tree:

[1/3] flink git commit: [FLINK-3293] [yarn] Respect custom CLI Yarn name in JobManager mode

Repository: flink Updated Branches: refs/heads/master 1198664cb -> aabb2688a [FLINK-3293] [yarn] Respect custom CLI Yarn name in JobManager mode Added a method to set a default application name for the Flink Yarn session CLI. Switched the order, such that this name can now be overwritten by

flink git commit: [FLINK-3225] Enforce translation to DataSetNodes

Repository: flink Updated Branches: refs/heads/tableOnCalcite 7ecb70105 -> 297564646 [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/29756464 Tree:

[1/3] flink git commit: [FLINK-3225] Implemented optimization of Table API queries via Calcite

Repository: flink Updated Branches: refs/heads/tableOnCalcite 364928e74 -> 7ecb70105 http://git-wip-us.apache.org/repos/asf/flink/blob/7ecb7010/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/SelectITCase.java

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

[2/3] flink git commit: [FLINK-3225] Implemented optimization of Table API queries via Calcite

http://git-wip-us.apache.org/repos/asf/flink/blob/7ecb7010/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/operators/DataSetTable.scala -- diff --git

[3/6] flink git commit: [FLINK-1045][dataSet] Remove Combinable annotation.

http://git-wip-us.apache.org/repos/asf/flink/blob/5914e9ab/flink-tests/src/test/java/org/apache/flink/test/optimizer/examples/KMeansSingleStepTest.java -- diff --git

[2/6] flink git commit: [FLINK-1666][FLINK-1903][FLINK-3233] Refactor expression keys.

[FLINK-1666][FLINK-1903][FLINK-3233] Refactor expression keys. - Unify usage of expression keys: FLINK-1666 - Unify supported key expressions (incl. support for partitioning on atomic types: FLINK-3233) - Remove removal of duplicate keys: FLINK-1903 - Unify checks for sort keys - Add more tests

[5/6] flink git commit: [FLINK-3198][dataSet] Renames and documents better the use of the getDataSet() in Grouping.

[FLINK-3198][dataSet] Renames and documents better the use of the getDataSet() in Grouping. This closes #1548 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/902d420e Tree:

[4/6] flink git commit: [FLINK-1045][dataSet] Remove Combinable annotation.

[FLINK-1045][dataSet] Remove Combinable annotation. This closes #1522 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5914e9ab Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5914e9ab Diff:

[6/6] flink git commit: [FLINK-3289][docs] References to flink-contrib merged

[FLINK-3289][docs] References to flink-contrib merged This closes #1550 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1e67a059 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1e67a059 Diff:

[1/6] flink git commit: [FLINK-1666][FLINK-1903][FLINK-3233] Refactor expression keys.

Repository: flink Updated Branches: refs/heads/master 984013607 -> 1e67a0596 http://git-wip-us.apache.org/repos/asf/flink/blob/af029e7e/flink-java/src/test/java/org/apache/flink/api/java/operators/ExpressionKeysTest.java --

flink git commit: Renamed Table.scala to table.scala

Repository: flink Updated Branches: refs/heads/tableOnCalcite e4ee0c6d7 -> d6f04a7e9 Renamed Table.scala to table.scala Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d6f04a7e Tree:

[6/6] flink git commit: [FLINK-3285][maven] Skip deployment of flink-java8 module

[FLINK-3285][maven] Skip deployment of flink-java8 module This closes #1547 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4280e1f9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4280e1f9 Diff:

[1/6] flink git commit: [FLINK-3280] Change Boolean.getBoolean to Boolean.valueOf

Repository: flink Updated Branches: refs/heads/master 733847459 -> d39892624 [FLINK-3280] Change Boolean.getBoolean to Boolean.valueOf Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3989262 Tree:

[2/6] flink git commit: [FLINK-3209] Remove Unused ProcessingTime, EventTime and AbstractTime

[FLINK-3209] Remove Unused ProcessingTime, EventTime and AbstractTime Only keep Time for specifying time durations/intervals. This closes #1512 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf75f424 Tree:

[4/6] flink git commit: [hotfix] [docs] Tidy up documentation. Fix some non-idiomatic usage of return in scala code.

[hotfix] [docs] Tidy up documentation. Fix some non-idiomatic usage of return in scala code. This closes #1531 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ad1d5ed Tree:

[3/4] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

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

[1/4] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

Repository: flink Updated Branches: refs/heads/tableOnCalcite a65cd8db1 -> e4ee0c6d7 http://git-wip-us.apache.org/repos/asf/flink/blob/e4ee0c6d/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/UnionITCase.scala

[2/4] flink git commit: [FLINK-3223] Translate Table API calls to Calcite RelNodes.

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

[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

[flink] Git Push Summary

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

[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

[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

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

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

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

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

<    7   8   9   10   11   12   13   14   15   >